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