Method: DemoSocket#recv

Defined in:
lib/demo_socket.rb

#recv ⇒ Object 



37
38
39
40
41
42
43
44
45
46
47
48
49
50
 
# File 'lib/demo_socket.rb', line 37

def recv
  header = @tcp_socket.recv(4)
  raise BadMessage if header.size < 4

  expected_length = header.unpack('N')[0]
  msg = @tcp_socket.recv(expected_length)
  raise BadMessage if msg.size < expected_length

  puts ">>> #{msg.inspect}" if ENV['DEMO_DEBUG']
  
  JSON.parse(msg)
rescue Errno::ECONNRESET
  raise DeadSocket
end