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