Class: Rinda::TupleSpaceProxy

Inherits:
Object
  • Object
show all
Defined in:
lib/skynet/message_queue_adapters/tuple_space.rb,
lib/skynet/skynet_tuplespace_server.rb

Instance Method Summary collapse

Instance Method Details

#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