Class: EventMachine::Synchrony::FiberIterator
- Inherits:
-
EM::Synchrony::Iterator
- Object
- EM::Synchrony::Iterator
- EventMachine::Synchrony::FiberIterator
- Defined in:
- lib/em-synchrony/fiber_iterator.rb
Instance Method Summary collapse
-
#each(foreach = nil, after = nil, &blk) ⇒ Object
execute each iterator block within its own fiber and auto-advance the iterator after each call.
Instance Method Details
#each(foreach = nil, after = nil, &blk) ⇒ Object
execute each iterator block within its own fiber and auto-advance the iterator after each call
8 9 10 11 12 13 14 |
# File 'lib/em-synchrony/fiber_iterator.rb', line 8 def each(foreach=nil, after=nil, &blk) fe = Proc.new do |obj, iter| Fiber.new { (foreach || blk).call(obj); iter.next }.resume end super(fe, after) end |