Class: Kafka::AsyncProducer::Timer
- Inherits:
-
Object
- Object
- Kafka::AsyncProducer::Timer
- Defined in:
- lib/kafka/async_producer.rb
Instance Method Summary collapse
-
#initialize(interval:, queue:) ⇒ Timer
constructor
A new instance of Timer.
- #run ⇒ Object
Constructor Details
#initialize(interval:, queue:) ⇒ Timer
Returns a new instance of Timer.
137 138 139 140 |
# File 'lib/kafka/async_producer.rb', line 137 def initialize(interval:, queue:) @queue = queue @interval = interval end |
Instance Method Details
#run ⇒ Object
142 143 144 145 146 147 |
# File 'lib/kafka/async_producer.rb', line 142 def run loop do sleep(@interval) @queue << [:deliver_messages, nil] end end |