@@ -63,7 +63,7 @@ discard block |
||
| 63 | 63 | $stack->push(Middleware::log(new ConsoleLog(), new MessageFormatter($logTemplate)), 'logger'); |
| 64 | 64 | $stack->push( |
| 65 | 65 | Middleware::retry( |
| 66 | - static function ( |
|
| 66 | + static function( |
|
| 67 | 67 | int $retries, |
| 68 | 68 | RequestInterface $request, |
| 69 | 69 | ?ResponseInterface $response = null, |
@@ -77,7 +77,7 @@ discard block |
||
| 77 | 77 | ) |
| 78 | 78 | ); |
| 79 | 79 | }, |
| 80 | - static function (int $retries) { |
|
| 80 | + static function(int $retries) { |
|
| 81 | 81 | return 2 ** $retries * 1000; |
| 82 | 82 | } |
| 83 | 83 | ), |
@@ -118,7 +118,7 @@ discard block |
||
| 118 | 118 | { |
| 119 | 119 | $promise = $this->getRequestPromise($request); |
| 120 | 120 | $promise->otherwise( |
| 121 | - $onRejected ?? static function (\Throwable $throwable) { |
|
| 121 | + $onRejected ?? static function(\Throwable $throwable) { |
|
| 122 | 122 | return $throwable; |
| 123 | 123 | } |
| 124 | 124 | ); |
@@ -161,7 +161,7 @@ discard block |
||
| 161 | 161 | |
| 162 | 162 | return $this->client |
| 163 | 163 | ->sendAsync($request->getPsrRequest(), $request->getOptions()) |
| 164 | - ->then(function (ResponseInterface $response) use ($request, $cacheKey, $options) { |
|
| 164 | + ->then(function(ResponseInterface $response) use ($request, $cacheKey, $options) { |
|
| 165 | 165 | $parseResult = $request->getParseHandler()($request->getPsrRequest(), $response, $options); |
| 166 | 166 | if ($cacheKey !== null && $parseResult !== null) { |
| 167 | 167 | $this->cache->set($cacheKey, $parseResult, $options['cache_ttl']); |
@@ -180,9 +180,9 @@ discard block |
||
| 180 | 180 | */ |
| 181 | 181 | public function requestPool(array $requests, ?\Closure $onRejected = null): array |
| 182 | 182 | { |
| 183 | - $makeRequests = function () use ($requests): \Generator { |
|
| 183 | + $makeRequests = function() use ($requests) : \Generator { |
|
| 184 | 184 | foreach ($requests as $key => $request) { |
| 185 | - yield $key => function () use ($request): PromiseInterface { |
|
| 185 | + yield $key => function() use ($request): PromiseInterface { |
|
| 186 | 186 | return $this->getRequestPromise($request); |
| 187 | 187 | }; |
| 188 | 188 | } |
@@ -191,10 +191,10 @@ discard block |
||
| 191 | 191 | $results = []; |
| 192 | 192 | $pool = new Pool($this->client, $makeRequests(), [ |
| 193 | 193 | 'concurrency' => $options['concurrency'] ?? self::DEFAULT_CONCURRENCY, |
| 194 | - 'fulfilled' => static function ($result, $key) use (&$results): void { |
|
| 194 | + 'fulfilled' => static function($result, $key) use (&$results): void { |
|
| 195 | 195 | $results[$key] = $result; |
| 196 | 196 | }, |
| 197 | - 'rejected' => $onRejected ?? static function (\Throwable $throwable, $key): void { |
|
| 197 | + 'rejected' => $onRejected ?? static function(\Throwable $throwable, $key): void { |
|
| 198 | 198 | throw $throwable; |
| 199 | 199 | }, |
| 200 | 200 | ]); |