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