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