Class: Metasploit::Aggregator::EnumeratorQueue

Inherits:

Object

• Object
• Metasploit::Aggregator::EnumeratorQueue

Extended by:

Forwardable

Defined in:

lib/metasploit/aggregator.rb

Overview

A EnumeratorQueue wraps a Queue to yield the items added to it.

Instance Method Summary

• #each_item ⇒ Object
• #initialize(sentinel) ⇒ EnumeratorQueue constructor

  A new instance of EnumeratorQueue.

Constructor Details

#initialize(sentinel) ⇒ EnumeratorQueue

Returns a new instance of EnumeratorQueue.

# File 'lib/metasploit/aggregator.rb', line 257

def initialize(sentinel)
  @q = Queue.new
  @sentinel = sentinel
end

Instance Method Details

#each_item ⇒ Object

# File 'lib/metasploit/aggregator.rb', line 262

def each_item
  return enum_for(:each_item) unless block_given?
  loop do
    r = @q.pop
    break if r.equal?(@sentinel)
    fail r if r.is_a? Exception
    yield r
  end
end