class MQTTPipe::Pipe::Context
Public Class Methods
new(client)
click to toggle source
# File lib/mqtt_pipe/pipe.rb, line 110 def initialize client @client = client end
Public Instance Methods
send(topic, *data)
click to toggle source
# File lib/mqtt_pipe/pipe.rb, line 114 def send topic, *data raise ConnectionError unless @client.connected? @client.publish topic, Packer.pack(*data) end