Support iterable type for all() + race() + any()

Author: clue

README.md

@@ -376,7 +376,7 @@ reject a promise, any language error or user land exception can be used to rejec
 #### all()
 
 ```php
-$promise = React\Promise\all(array $promisesOrValues);
+$promise = React\Promise\all(iterable $promisesOrValues);
 ```
 
 Returns a promise that will resolve only once all the items in
@@ -387,7 +387,7 @@ will be an array containing the resolution values of each of the items in
 #### race()
 
 ```php
-$promise = React\Promise\race(array $promisesOrValues);
+$promise = React\Promise\race(iterable $promisesOrValues);
 ```
 
 Initiates a competitive race that allows one winner. Returns a promise which is
@@ -399,7 +399,7 @@ contains 0 items.
 #### any()
 
 ```php
-$promise = React\Promise\any(array $promisesOrValues);
+$promise = React\Promise\any(iterable $promisesOrValues);
 ```
 
 Returns a promise that will resolve when any one of the items in

src/functions.php

@@ -68,11 +68,15 @@ function reject(\Throwable $reason): PromiseInterface
  * will be an array containing the resolution values of each of the items in
  * `$promisesOrValues`.
  *
- * @param array $promisesOrValues
+ * @param iterable $promisesOrValues
  * @return PromiseInterface
  */
-function all(array $promisesOrValues): PromiseInterface
+function all(iterable $promisesOrValues): PromiseInterface
 {
+    if (!\is_array($promisesOrValues)) {
+        $promisesOrValues = \iterator_to_array($promisesOrValues);
+    }
+
     if (!$promisesOrValues) {
         return resolve([]);
     }
@@ -109,11 +113,15 @@ function ($mapped) use ($i, &$values, &$toResolve, $resolve): void {
  * The returned promise will become **infinitely pending** if  `$promisesOrValues`
  * contains 0 items.
  *
- * @param array $promisesOrValues
+ * @param iterable $promisesOrValues
  * @return PromiseInterface
  */
-function race(array $promisesOrValues): PromiseInterface
+function race(iterable $promisesOrValues): PromiseInterface
 {
+    if (!\is_array($promisesOrValues)) {
+        $promisesOrValues = \iterator_to_array($promisesOrValues);
+    }
+
     if (!$promisesOrValues) {
         return new Promise(function (): void {});
     }
@@ -141,18 +149,22 @@ function race(array $promisesOrValues): PromiseInterface
  * The returned promise will also reject with a `React\Promise\Exception\LengthException`
  * if `$promisesOrValues` contains 0 items.
  *
- * @param array $promisesOrValues
+ * @param iterable $promisesOrValues
  * @return PromiseInterface
  */
-function any(array $promisesOrValues): PromiseInterface
+function any(iterable $promisesOrValues): PromiseInterface
 {
+    if (!\is_array($promisesOrValues)) {
+        $promisesOrValues = \iterator_to_array($promisesOrValues);
+    }
+
     $len = \count($promisesOrValues);
 
     if (!$promisesOrValues) {
         return reject(
             new Exception\LengthException(
                 \sprintf(
-                    'Input array must contain at least 1 item but contains only %s item%s.',
+                    'Must contain at least 1 item but contains only %s item%s.',
                     $len,
                     1 === $len ? '' : 's'
                 )

tests/FunctionAllTest.php

@@ -58,6 +58,24 @@ public function shouldResolveSparseArrayInput()
             ->then($mock);
     }
 
+    /** @test */
+    public function shouldResolveValuesGenerator()
+    {
+        $mock = $this->createCallableMock();
+        $mock
+            ->expects(self::once())
+            ->method('__invoke')
+            ->with(self::identicalTo([1, 2, 3]));
+
+        $gen = (function () {
+            for ($i = 1; $i <= 3; ++$i) {
+                yield $i;
+            }
+        })();
+
+        all($gen)->then($mock);
+    }
+
     /** @test */
     public function shouldRejectIfAnyInputPromiseRejects()
     {

tests/FunctionAnyTest.php

@@ -18,7 +18,7 @@ public function shouldRejectWithLengthExceptionWithEmptyInputArray()
             ->with(
                 self::callback(function ($exception) {
                     return $exception instanceof LengthException &&
-                           'Input array must contain at least 1 item but contains only 0 items.' === $exception->getMessage();
+                           'Must contain at least 1 item but contains only 0 items.' === $exception->getMessage();
                 })
             );
 
@@ -52,6 +52,24 @@ public function shouldResolveWithAPromisedInputValue()
             ->then($mock);
     }
 
+    /** @test */
+    public function shouldResolveValuesGenerator()
+    {
+        $mock = $this->createCallableMock();
+        $mock
+            ->expects(self::once())
+            ->method('__invoke')
+            ->with(self::identicalTo(1));
+
+        $gen = (function () {
+            for ($i = 1; $i <= 3; ++$i) {
+                yield $i;
+            }
+        })();
+
+        any($gen)->then($mock);
+    }
+
     /** @test */
     public function shouldRejectWithAllRejectedInputValuesIfAllInputsAreRejected()
     {

tests/FunctionRaceTest.php

@@ -65,6 +65,24 @@ public function shouldResolveSparseArrayInput()
         )->then($mock);
     }
 
+    /** @test */
+    public function shouldResolveValuesGenerator()
+    {
+        $mock = $this->createCallableMock();
+        $mock
+            ->expects(self::once())
+            ->method('__invoke')
+            ->with(self::identicalTo(1));
+
+        $gen = (function () {
+            for ($i = 1; $i <= 3; ++$i) {
+                yield $i;
+            }
+        })();
+
+        race($gen)->then($mock);
+    }
+
     /** @test */
     public function shouldRejectIfFirstSettledPromiseRejects()
     {