class Kafka::AsyncProducer::Timer

def initialize(interval:, queue:)
  @queue = queue
  @interval = interval
end

def run
  # Permanently sleep if the timer interval is zero.
  Thread.stop if @interval.zero?
  loop do
    sleep(@interval)
    @queue << [:deliver_messages, nil]
  end
end