Changed retryAsync() code to be simpler thanks to Porter improvements.

Porter-connectors · Apr 19, 2018 · 4e8fde7 · 4e8fde7
1 parent 1bb5036
commit 4e8fde7
Showing 1 changed file with 12 additions and 20 deletions.
diff --git a/src/AsyncHttpConnector.php b/src/AsyncHttpConnector.php
@@ -35,26 +35,18 @@ public function fetchAsync(ConnectionContext $context, string $source): Promise
 
             return $context->retryAsync(
                 static function () use ($client, $source) {
-                    return \Amp\call(
-                        static function () use ($client, $source) {
-                            try {
-                                /** @var Response $response */
-                                $response = yield $client->request($source);
-                                // Retry HTTP timeouts, socket timeouts and DNS resolution errors.
-                            } catch (TimeoutException | SocketException | DnsException $exception) {
-                                // Convert exception to recoverable exception.
-                                throw new HttpConnectionException(
-                                    $exception->getMessage(),
-                                    $exception->getCode(),
-                                    $exception
-                                );
-                            }
-
-                            $body = yield $response->getBody();
-
-                            return HttpResponse::fromArtaxResponse($response, $body);
-                        }
-                    );
+                    try {
+                        /** @var Response $response */
+                        $response = yield $client->request($source);
+                        // Retry HTTP timeouts, socket timeouts and DNS resolution errors.
+                    } catch (TimeoutException | SocketException | DnsException $exception) {
+                        // Convert exception to recoverable exception.
+                        throw new HttpConnectionException($exception->getMessage(), $exception->getCode(), $exception);
+                    }
+
+                    $body = yield $response->getBody();
+
+                    return HttpResponse::fromArtaxResponse($response, $body);
                 }
             );
         });