Multi: yield fiber in perform only if requests are not finished yet

brownman · Oct 8, 2010 · e0d9934 · e0d9934
1 parent 9db40fb
commit e0d9934
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/lib/em-synchrony/em-multi.rb b/lib/em-synchrony/em-multi.rb
@@ -18,14 +18,18 @@ def add(name, conn)
         @requests.push(conn)
       end
 
+      def finished?
+        (@responses[:callback].size + @responses[:errback].size) == @requests.size
+      end
+
       def perform
-        Fiber.yield
+        Fiber.yield unless finished?
       end
 
       protected
 
         def check_progress(fiber)
-          if (@responses[:callback].size + @responses[:errback].size) == @requests.size
+          if finished?
             succeed
 
             # continue processing