Class: Smartware::PubSubClient::PubSubHandler

Inherits:

EventMachine::Connection

• Object
• EventMachine::Connection
• Smartware::PubSubClient::PubSubHandler

Includes:

EventMachine::Protocols::LineProtocol

Defined in:

lib/smartware/pub_sub_client.rb

Instance Method Summary

• #initialize(client) ⇒ PubSubHandler constructor

  A new instance of PubSubHandler.

• #receive_line(line) ⇒ Object
• #send_record(data) ⇒ Object
• #unbind ⇒ Object

Constructor Details

#initialize(client) ⇒ PubSubHandler

Returns a new instance of PubSubHandler.

# File 'lib/smartware/pub_sub_client.rb', line 41

def initialize(client)
  @client = client
end

Instance Method Details

#receive_line(line) ⇒ Object

# File 'lib/smartware/pub_sub_client.rb', line 49

def receive_line(line)
  data = JSON.load line

  @client.receive data
end

#send_record(data) ⇒ Object

# File 'lib/smartware/pub_sub_client.rb', line 55

def send_record(data)
  send_data(JSON.dump(data) + "\r\n")
end

#unbind ⇒ Object

# File 'lib/smartware/pub_sub_client.rb', line 45

def unbind
  @client.broken
end