Method: RJR::Nodes::TCPConnection#receive_data

Defined in:
lib/rjr/nodes/tcp.rb

#receive_data(data) ⇒ Object

EventMachine::Connection#receive_data callback, handle request / response messages



38
39
40
41
42
43
44
45
46
47
 
# File 'lib/rjr/nodes/tcp.rb', line 38

def receive_data(data)
  # a large json-rpc message may be split over multiple packets
  #   (invocations of receive_data)
  # and multiple messages may be concatinated into one packet
  @data += data
  while extracted = MessageUtil.retrieve_json(@data)
    msg, @data = *extracted
    @rjr_node.send(:handle_message, msg, self) # XXX private method
  end
end