123456789_123456789_123456789_123456789_123456789_

Class: Rinda::NotifyTemplateEntry

Relationships & Source Files
Super Chains via Extension / Inclusion / Inheritance
Class Chain:
self, TemplateEntry, TupleEntry
Instance Chain:
self, TemplateEntry, TupleEntry, DRbUndumped
Inherits: Rinda::TemplateEntry
Defined in: lib/rinda/tuplespace.rb

Overview

A NotifyTemplateEntry is returned by TupleSpace#notify and is notified of TupleSpace changes. You may receive either your subscribed event or the ‘close’ event when iterating over notifications.

See TupleSpace#notify_event for valid notification types.

Example

ts = Rinda::TupleSpace.new
observer = ts.notify 'write', [nil]

Thread.start do
  observer.each { |t| p t }
end

3.times { |i| ts.write [i] }

Outputs:

['write', [0]]
['write', [1]]
['write', [2]]

Class Method Summary

TupleEntry - Inherited

.new

Creates a TupleEntry based on ary with an optional renewer or expiry time sec.

Instance Attribute Summary

TupleEntry - Inherited

#alive?

A TupleEntry is dead when it is canceled or expired.
#canceled?

Returns the canceled status.
#expired?

Has this tuple expired? (true/false).
#expires

Instance Method Summary

  • #each

    Yields event/tuple pairs until this NotifyTemplateEntry expires.

  • #notify(ev)

    Called by TupleSpace to notify this NotifyTemplateEntry of a new event.

  • #pop

    Retrieves a notification.

TemplateEntry - Inherited

#===

Alias for TemplateEntry#match.
#match

Matches this TemplateEntry against tuple.
#make_tuple

TupleEntry - Inherited

#[]

Retrieves key from the tuple.
#cancel

Marks this TupleEntry as canceled.
#fetch

Fetches key from the tuple.
#make_expires
Returns an expiry Time based on sec which can be one of: Numeric
sec seconds into the future true
the expiry time is the start of 1970 (i.e. expired) nil

it is Tue Jan 19 03:14:07 GMT Standard Time 2038 (i.e. when.
#make_tuple

Creates a Tuple for ary.
#renew

Reset the expiry time according to sec_or_renewer.
#size

The size of the tuple.
#value

Return the object which makes up the tuple itself: the Array or Hash.
#get_renewer

Returns a valid argument to make_expires and the renewer or nil.

Constructor Details

.new(place, event, tuple, expires = nil) ⇒ NotifyTemplateEntry

Creates a new NotifyTemplateEntry that watches place for events that match tuple.

[ GitHub ] 

  


# File 'lib/rinda/tuplespace.rb', line 245



def initialize(place, event, tuple, expires=nil)
  ary = [event, Rinda::Template.new(tuple)]
  super(ary, expires)
  @queue = Thread::Queue.new
  @done = false
end


  







Instance Method Details



  

    #each  
  



  

    

Yields event/tuple pairs until this NotifyTemplateEntry expires.


  



  [ GitHub ]


  

  


# File 'lib/rinda/tuplespace.rb', line 273



def each # :yields: event, tuple
  while !@done
    it = pop
    yield(it)
  end
rescue
ensure
  cancel
end


  








  

    #notify(ev)  
  



  

    

Called by TupleSpace to notify this NotifyTemplateEntry of a new event.


  



  [ GitHub ]


  

  


# File 'lib/rinda/tuplespace.rb', line 255



def notify(ev)
  @queue.push(ev)
end


  








  

    #pop  
  



  

    

Retrieves a notification.  Raises RequestExpiredError when this NotifyTemplateEntry expires.


  





  
Raises:





  [ GitHub ]


  

  


# File 'lib/rinda/tuplespace.rb', line 263



def pop
  raise RequestExpiredError if @done
  it = @queue.pop
  @done = true if it[0] == 'close'
  return it
end