Class: Takagi::Observer::Client

Inherits:
Object
  • Object
show all
Defined in:
lib/takagi/observer/client.rb

Overview

Lightweight CoAP observe client for integration testing.

Instance Method Summary collapse

Constructor Details

#initialize(uri) ⇒ Client

Returns a new instance of Client.



11
12
13
14
15
16
 
# File 'lib/takagi/observer/client.rb', line 11

def initialize(uri)
  @uri = URI.parse(uri)
  @token = SecureRandom.hex(4)
  @socket = UDPSocket.new
  @on_notify = nil
end

Instance Method Details

#on_notify(&block) ⇒ Object 



18
19
20
 
# File 'lib/takagi/observer/client.rb', line 18

def on_notify(&block)
  @on_notify = block
end

#stop ⇒ Object Also known as: close 



27
28
29
30
 
# File 'lib/takagi/observer/client.rb', line 27

def stop
  @running = false
  @socket.close unless @socket.closed?
end

#subscribe ⇒ Object 



22
23
24
25
 
# File 'lib/takagi/observer/client.rb', line 22

def subscribe
  send_observe_request
  listen_for_notifications
end