Add multiplexing method (#417)

* Add multiplexing method

* Don't throw exceptions

* Rename resolveAll into multiplex

* Fix lowest test

* Fix early return

* Add a parameter to download body

* Catch exception for each response individually

* Throw on __destruct

* Apply suggestions

* Better handle of recurcion in exception

* Fix CS

* Rename into wait

Author: jderusse

tests/Integration/LambdaClientTest.php

@@ -3,11 +3,13 @@
 namespace AsyncAws\Lambda\Tests\Integration;
 
 use AsyncAws\Core\Credentials\NullProvider;
+use AsyncAws\Core\Result;
 use AsyncAws\Lambda\Input\AddLayerVersionPermissionRequest;
 use AsyncAws\Lambda\Input\InvocationRequest;
 use AsyncAws\Lambda\Input\ListLayerVersionsRequest;
 use AsyncAws\Lambda\Input\PublishLayerVersionRequest;
 use AsyncAws\Lambda\LambdaClient;
+use AsyncAws\Lambda\Result\InvocationResponse;
 use AsyncAws\Lambda\ValueObject\LayerVersionContentInput;
 use PHPUnit\Framework\TestCase;
 
@@ -55,6 +57,37 @@ public function testInvoke(): void
         self::assertSame('$LATEST', $result->getExecutedVersion());
     }
 
+    public function testInvokeWait(): void
+    {
+        if (!\method_exists(Result::class, 'wait')) {
+            self::markTestSkipped('Core does not contains the feature');
+        }
+
+        $client = $this->getClient();
+
+        $results = [];
+        $expected = [];
+        for ($i = 0; $i < 10; ++$i) {
+            $expected[] = '"hello ' . $i . '"';
+            $results[] = $client->Invoke(new InvocationRequest([
+                'FunctionName' => 'Index',
+                'Payload' => \json_encode(['name' => $i]),
+            ]));
+        }
+
+        $resolves = [];
+        /** @var InvocationResponse[] $result */
+        foreach (Result::wait($results, null, true) as $index => $result) {
+            // assert $index match original order
+            self::assertSame($expected[$index], $result->getPayload());
+            $resolves[] = $result->getPayload();
+        }
+
+        self::assertEqualsCanonicalizing($expected, $resolves);
+        // wait should mix responses
+        self::assertNotEquals($expected, $resolves);
+    }
+
     public function testListLayerVersions(): void
     {
         self::markTestSkipped('The Lambda Docker image does not implement AddLayerVersionPermission.');