In Files
- rinda/rinda.rb
Class/Module Index
- Rinda
- Rinda::DRbObjectTemplate
- Rinda::InvalidHashTupleKey
- Rinda::NotifyTemplateEntry
- Rinda::RequestCanceledError
- Rinda::RequestExpiredError
- Rinda::RindaError
- Rinda::RingFinger
- Rinda::RingProvider
- Rinda::RingServer
- Rinda::SimpleRenewer
- Rinda::Template
- Rinda::TemplateEntry
- Rinda::Tuple
- Rinda::TupleBag
- Rinda::TupleBag::TupleBin
- Rinda::TupleEntry
- Rinda::TupleSpace
- Rinda::TupleSpaceProxy
- Rinda::WaitTemplateEntry
Rinda::TupleSpaceProxy
TupleSpaceProxy allows a remote Tuplespace to appear as local.
Public Class Methods
new(ts)
Creates a new TupleSpaceProxy to wrap
ts
.
# File rinda/rinda.rb, line 258 def initialize(ts) @ts = ts end
Public Instance Methods
notify(ev, tuple, sec=nil)
Registers for notifications of event ev
on the proxied TupleSpace. See Rinda::TupleSpace#notify
# File rinda/rinda.rb, line 297 def notify(ev, tuple, sec=nil) @ts.notify(ev, tuple, sec) end
read(tuple, sec=nil, &block)
Reads tuple
from the proxied TupleSpace. See Rinda::TupleSpace#read.
# File rinda/rinda.rb, line 281 def read(tuple, sec=nil, &block) @ts.read(tuple, sec, &block) end
read_all(tuple)
Reads all tuples matching tuple
from the proxied TupleSpace. See Rinda::TupleSpace#read_all.
# File rinda/rinda.rb, line 289 def read_all(tuple) @ts.read_all(tuple) end
take(tuple, sec=nil, &block)
Takes tuple
from the proxied TupleSpace. See Rinda::TupleSpace#take.
# File rinda/rinda.rb, line 272 def take(tuple, sec=nil, &block) Port.deliver do |port| @ts.move(DRbObject.new(port), tuple, sec, &block) end end
write(tuple, sec=nil)
Adds tuple
to the proxied TupleSpace. See Rinda::TupleSpace#write.
# File rinda/rinda.rb, line 265 def write(tuple, sec=nil) @ts.write(tuple, sec) end