Method: Rinda::TupleSpaceProxy#take

Defined in:
lib/skynet/message_queue_adapters/tuple_space.rb,
lib/skynet/tuplespace_server.rb

#take(tuple, sec = nil, &block) ⇒ Object 



3
4
5
6
7
 
# File 'lib/skynet/message_queue_adapters/tuple_space.rb', line 3

def take(tuple, sec=nil, &block)
  port = []
  port.push @ts.move(nil, tuple, sec, &block)
  port[0]
end