lib/em-synchrony/em-multi.rb in em-synchrony-1.0.4 vs lib/em-synchrony/em-multi.rb in em-synchrony-1.0.5

- old
+ new

@@ -11,14 +11,14 @@ end def add(name, conn) raise 'Duplicate Multi key' if @requests.key? name + @requests[name] = conn + fiber = Fiber.current conn.callback { @responses[:callback][name] = conn; check_progress(fiber) } conn.errback { @responses[:errback][name] = conn; check_progress(fiber) } - - @requests[name] = conn end def finished? (@responses[:callback].size + @responses[:errback].size) == @requests.size end