@@ -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 | ]); |