Class: MQTTPipe::Pipe::Context

Inherits:

Object

Object
MQTTPipe::Pipe::Context

show all

Defined in:: lib/mqtt_pipe/pipe.rb

Instance Method Summary collapse

#initialize(client) ⇒ Context constructor

A new instance of Context.
#send(topic, *data) ⇒ Object

Constructor Details

#initialize(client) ⇒ `Context`

Returns a new instance of Context.



110
111
112

# File 'lib/mqtt_pipe/pipe.rb', line 110

def initialize client
  @client = client
end

Instance Method Details

#send(topic, *data) ⇒ `Object`

Raises:

(ConnectionError)

# File 'lib/mqtt_pipe/pipe.rb', line 114

def send topic, *data
  raise ConnectionError unless @client.connected?
  @client.publish topic, Packer.pack(*data)
end