Rinda::NotifyTemplateEntry (Class)

In: rinda/tuplespace.rb
Parent: TemplateEntry

Documentation?

Methods

each   new   notify   pop  

Public Class methods

[Source]

# File rinda/tuplespace.rb, line 185
    def initialize(place, event, tuple, expires=nil)
      ary = [event, Rinda::Template.new(tuple)]
      super(ary, expires)
      @queue = Queue.new
      @done = false
    end

Public Instance methods

[Source]

# File rinda/tuplespace.rb, line 203
    def each
      while !@done
        it = pop
        yield(it)
      end
    rescue 
    ensure
      cancel
    end

[Source]

# File rinda/tuplespace.rb, line 192
    def notify(ev)
      @queue.push(ev)
    end

[Source]

# File rinda/tuplespace.rb, line 196
    def pop
      raise RequestExpiredError if @done
      it = @queue.pop
      @done = true if it[0] == 'close'
      return it
    end

[Validate]