Added a recursive option to all() function.

Fixes guzzle#46
bpolaszek · Oct 26, 2017 · c427866 · c427866
1 parent e9cdab6
commit c427866
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/src/functions.php b/src/functions.php
@@ -231,6 +231,15 @@ function ($reason, $idx, Promise $aggregate) {
     )->then(function () use (&$results) {
         ksort($results);
         return $results;
+    })->then(function ($results) use ($recursive, &$promises) {
+        if (true === $recursive && !$promises instanceof \Generator) {
+            foreach ($promises AS $promise) {
+                if (\GuzzleHttp\Promise\PromiseInterface::PENDING === $promise->getState()) {
+                    return all($promises, $recursive);
+                }
+            }
+        }
+        return $results;
     });
 
     if (true === $recursive) {