class Producer
Attributes
events[R]
Public Class Methods
new()
click to toggle source
# File lib/kafka_lite/producer.rb, line 5 def initialize @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/kafka_lite/producer.rb, line 19 def next_event raise 'SubclassResponsibility' end