class Asynchronic::QueueEngine::InMemory::Listener

Public Instance Methods

listen(queue, &block) click to toggle source
# File lib/asynchronic/queue_engine/in_memory.rb, line 71
def listen(queue, &block)
  @stopping = false

  loop do
    break if @stopping
    item = queue.pop
    next unless item
    block.call item
  end
end
stop() click to toggle source
# File lib/asynchronic/queue_engine/in_memory.rb, line 82
def stop
  @stopping = true
end