class DpStmMap::SocketTransport

Public Class Methods

new(socket) click to toggle source
# File lib/dp_stm_map/Manager.rb, line 260
def initialize socket
  @socket=socket
end

Public Instance Methods

close() click to toggle source
# File lib/dp_stm_map/Manager.rb, line 277
def close
  @socket.close
end
next_message() click to toggle source
# File lib/dp_stm_map/Manager.rb, line 264
def next_message
  length=@socket.read(8).unpack("Q>")[0]
  JsonMessage::deserialize(@socket.read(length))
end
send_message(msg) click to toggle source
# File lib/dp_stm_map/Manager.rb, line 269
def send_message msg

  data=msg.serialize
  @socket.write([data.bytesize].pack("Q>"))
  @socket.write(data)
  @socket.flush
end