Merge pull request igrigorik#202 from exAspArk/fiber_iterator

Fix passing nested arrays to FIberIterator with iter

lib/em-synchrony/fiber_iterator.rb

@@ -7,7 +7,7 @@ class FiberIterator < EM::Synchrony::Iterator
  # and auto-advance the iterator after each call
  def each(foreach=nil, after=nil, &blk)
  fe = Proc.new do |obj, iter|
- Fiber.new { (foreach || blk).call(obj); iter.next }.resume
+ Fiber.new { (foreach || blk).call(obj, iter); iter.next }.resume
  end
 
  super(fe, after)

spec/fiber_iterator_spec.rb

@@ -18,6 +18,19 @@
  end
  end
 
+ it "works even with nested arrays and iterator" do
+ EM.synchrony do
+ results = []
+ list = [[1, 2], [3, 4]]
+
+ EM::Synchrony::FiberIterator.new(list, 2).each { |sublist, iter| results.push(sublist) }
+
+ expect(results).to eq(list)
+
+ EM.stop
+ end
+ end
+
  #
  # it "should sum values within the iterator" do
  # EM.synchrony do