Class: Fairy::CJunction::PortQueue

Inherits:
XThread::Queue
  • Object
show all
Includes:
Enumerable
Defined in:
lib/fairy/master/c-junction.rb

Instance Method Summary collapse

Constructor Details

#initializePortQueue

Returns a new instance of PortQueue.



44
45
46
# File 'lib/fairy/master/c-junction.rb', line 44

def initialize
  super(XThread::Queue.new)
end

Instance Method Details

#eachObject



48
49
50
51
52
# File 'lib/fairy/master/c-junction.rb', line 48

def each
  while e = pop
    yield e
  end
end