class ProxyProducer

Attributes

queue[R]

Public Class Methods

new() click to toggle source
Calls superclass method Producer::new
# File lib/kafka_lite/producer.rb, line 29
def initialize
  super
  @queue = Queue.new
end

Private Instance Methods

next_event() click to toggle source
# File lib/kafka_lite/producer.rb, line 36
def next_event
  @queue.pop
end