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