Method: Expedite::Protocol#recv_object

Defined in:
lib/expedite/protocol.rb

#recv_object(env) ⇒ Object 



33
34
35
36
37
38
39
40
 
# File 'lib/expedite/protocol.rb', line 33

def recv_object(env)
  len = self.gets.to_i
  data = self.read(len)
  e = self.read(1)
  env.log "recv_object len=#{len} data=... e=#{e}"
  raise "Unexpected end #{e}" if e != "$"
  Marshal.load(data)
end