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