class TrRMIte::EventProducer

Attributes

events[R]

Public Class Methods

new(queue_uri) click to toggle source
Calls superclass method TrRMIte::Producer::new
# File lib/TrRMIte/producer.rb, line 51
def initialize(queue_uri)
  super
  @events = Enumerator.new do |yielder|
    loop do
      if (event = next_event)
        yielder << event
      else
        raise StopIteration
      end
    end
  end
end

Private Instance Methods

next_event() click to toggle source
# File lib/TrRMIte/producer.rb, line 66
def next_event
  raise 'SubclassResponsibility'
end