Class Rinda::TupleSpaceProxy
In: lib/rinda/rinda.rb
Parent: Object

TupleSpaceProxy allows a remote Tuplespace to appear as local.

Methods

new   notify   read   read_all   take   write  

Public Class methods

new(ts)

Creates a new TupleSpaceProxy to wrap ts.

[Source]

     # File lib/rinda/rinda.rb, line 213
213:     def initialize(ts)
214:       @ts = ts
215:     end

Public Instance methods

notify(ev, tuple, sec=nil)

Registers for notifications of event ev on the proxied TupleSpace. See TupleSpace#notify

[Source]

     # File lib/rinda/rinda.rb, line 252
252:     def notify(ev, tuple, sec=nil)
253:       @ts.notify(ev, tuple, sec)
254:     end
read(tuple, sec=nil, &block)

Reads tuple from the proxied TupleSpace. See TupleSpace#read.

[Source]

     # File lib/rinda/rinda.rb, line 236
236:     def read(tuple, sec=nil, &block)
237:       @ts.read(tuple, sec, &block)
238:     end
read_all(tuple)

Reads all tuples matching tuple from the proxied TupleSpace. See TupleSpace#read_all.

[Source]

     # File lib/rinda/rinda.rb, line 244
244:     def read_all(tuple)
245:       @ts.read_all(tuple)
246:     end
take(tuple, sec=nil, &block)

Takes tuple from the proxied TupleSpace. See TupleSpace#take.

[Source]

     # File lib/rinda/rinda.rb, line 227
227:     def take(tuple, sec=nil, &block)
228:       port = []
229:       @ts.move(DRbObject.new(port), tuple, sec, &block)
230:       port[0]
231:     end
write(tuple, sec=nil)

Adds tuple to the proxied TupleSpace. See TupleSpace#write.

[Source]

     # File lib/rinda/rinda.rb, line 220
220:     def write(tuple, sec=nil)
221:       @ts.write(tuple, sec)
222:     end

[Validate]