Method: ConcurrentWorker::IPCDuplexChannel#recv

Defined in:
lib/concurrent_worker/common.rb

#recv ⇒ Object 



65
66
67
68
69
70
71
 
# File 'lib/concurrent_worker/common.rb', line 65

def recv
  begin
    Marshal.load(@rio)
  rescue IOError
    raise StopIteration
  end
end