diff --git a/lib/concurrent/promise.rb b/lib/concurrent/promise.rb index f23700e90..5846c6f08 100644 --- a/lib/concurrent/promise.rb +++ b/lib/concurrent/promise.rb @@ -479,6 +479,7 @@ def self.aggregate(method, *promises) unless completed.empty? || completed.send(method){|promise| promise.fulfilled? } raise PromiseExecutionError end + completed end composite end