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