lib/eventmachine/sync-defer.rb in sync-defer-0.9.3 vs lib/eventmachine/sync-defer.rb in sync-defer-0.9.4

@@ -43,14 +43,14 @@
             exception = e
           end
         },
         lambda{ |result|
           if exception
-            fiber.resume(nil, exception)
+            fiber.resume(nil, exception) if fiber.alive?
           else
             results[index] = result
             fiber.resume(results.sort.map(&:last), nil) if
-              results.size == funcs.size
+              results.size == funcs.size && fiber.alive?
           end
         })
     end
   end
 end