Class: Asynchronic::QueueEngine::InMemory::Listener

Inherits:
Object
  • Object
show all
Defined in:
lib/asynchronic/queue_engine/in_memory.rb

Instance Method Summary collapse

Instance Method Details

#listen(queue, &block) ⇒ Object 



71
72
73
74
75
76
77
78
79
80
 
# 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 ⇒ Object 



82
83
84
 
# File 'lib/asynchronic/queue_engine/in_memory.rb', line 82

def stop
  @stopping = true
end