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