module SocketMessage
messages stream
Public Instance Methods
on_message(timeout=nil,&b)
click to toggle source
# File lib/minitcp.rb, line 359 def on_message(timeout=nil,&b) on_n_receive(6) do |head| len=head.to_i received_n_timeout(len,10_000) do |data| response=b.call(eval(data)) send(response) if response end end end
send_message(message)
click to toggle source
# File lib/minitcp.rb, line 368 def send_message(message) data=message.inspect send(("%6d" % data.size)+data,0) end