@@ -61,7 +61,7 @@ |
||
61 | 61 | { |
62 | 62 | $promise = $next($request); |
63 | 63 | |
64 | - return $promise->then(function (ResponseInterface $response) use ($request) { |
|
64 | + return $promise->then(function(ResponseInterface $response) use ($request) { |
|
65 | 65 | return $this->transformResponseToException($request, $response); |
66 | 66 | }); |
67 | 67 | } |
@@ -44,7 +44,7 @@ |
||
44 | 44 | */ |
45 | 45 | public function handleRequest(RequestInterface $request, callable $next, callable $first): Promise |
46 | 46 | { |
47 | - $addHostNext = function (RequestInterface $request) use ($next, $first) { |
|
47 | + $addHostNext = function(RequestInterface $request) use ($next, $first) { |
|
48 | 48 | return $this->addHostPlugin->handleRequest($request, $next, $first); |
49 | 49 | }; |
50 | 50 |
@@ -117,7 +117,7 @@ discard block |
||
117 | 117 | ]); |
118 | 118 | $resolver->setAllowedTypes('preserve_header', ['bool', 'array']); |
119 | 119 | $resolver->setAllowedTypes('use_default_for_multiple', 'bool'); |
120 | - $resolver->setNormalizer('preserve_header', function (OptionsResolver $resolver, $value) { |
|
120 | + $resolver->setNormalizer('preserve_header', function(OptionsResolver $resolver, $value) { |
|
121 | 121 | if (\is_bool($value) && false === $value) { |
122 | 122 | return []; |
123 | 123 | } |
@@ -144,7 +144,7 @@ discard block |
||
144 | 144 | return $first($redirectRequest); |
145 | 145 | } |
146 | 146 | |
147 | - return $next($request)->then(function (ResponseInterface $response) use ($request, $first): ResponseInterface { |
|
147 | + return $next($request)->then(function(ResponseInterface $response) use ($request, $first): ResponseInterface { |
|
148 | 148 | $statusCode = $response->getStatusCode(); |
149 | 149 | |
150 | 150 | if (!\array_key_exists($statusCode, $this->redirectCodes)) { |
@@ -70,11 +70,11 @@ discard block |
||
70 | 70 | $resolver = new OptionsResolver(); |
71 | 71 | $resolver->setDefaults([ |
72 | 72 | 'retries' => 1, |
73 | - 'error_response_decider' => function (RequestInterface $request, ResponseInterface $response) { |
|
73 | + 'error_response_decider' => function(RequestInterface $request, ResponseInterface $response) { |
|
74 | 74 | // do not retry client errors |
75 | 75 | return $response->getStatusCode() >= 500 && $response->getStatusCode() < 600; |
76 | 76 | }, |
77 | - 'exception_decider' => function (RequestInterface $request, ClientExceptionInterface $e) { |
|
77 | + 'exception_decider' => function(RequestInterface $request, ClientExceptionInterface $e) { |
|
78 | 78 | // do not retry client errors |
79 | 79 | return !$e instanceof HttpException || $e->getCode() >= 500 && $e->getCode() < 600; |
80 | 80 | }, |
@@ -103,7 +103,7 @@ discard block |
||
103 | 103 | { |
104 | 104 | $chainIdentifier = spl_object_hash((object) $first); |
105 | 105 | |
106 | - return $next($request)->then(function (ResponseInterface $response) use ($request, $next, $first, $chainIdentifier) { |
|
106 | + return $next($request)->then(function(ResponseInterface $response) use ($request, $next, $first, $chainIdentifier) { |
|
107 | 107 | if (!\array_key_exists($chainIdentifier, $this->retryStorage)) { |
108 | 108 | $this->retryStorage[$chainIdentifier] = 0; |
109 | 109 | } |
@@ -124,7 +124,7 @@ discard block |
||
124 | 124 | } |
125 | 125 | |
126 | 126 | return $response; |
127 | - }, function (ClientExceptionInterface $exception) use ($request, $next, $first, $chainIdentifier) { |
|
127 | + }, function(ClientExceptionInterface $exception) use ($request, $next, $first, $chainIdentifier) { |
|
128 | 128 | if (!\array_key_exists($chainIdentifier, $this->retryStorage)) { |
129 | 129 | $this->retryStorage[$chainIdentifier] = 0; |
130 | 130 | } |
@@ -63,7 +63,7 @@ |
||
63 | 63 | $request = $request->withAddedHeader('Cookie', \implode('; ', array_unique($cookies))); |
64 | 64 | } |
65 | 65 | |
66 | - return $next($request)->then(function (ResponseInterface $response) use ($request) { |
|
66 | + return $next($request)->then(function(ResponseInterface $response) use ($request) { |
|
67 | 67 | if ($response->hasHeader('Set-Cookie')) { |
68 | 68 | $setCookies = $response->getHeader('Set-Cookie'); |
69 | 69 |
@@ -36,11 +36,11 @@ |
||
36 | 36 | { |
37 | 37 | $journal = $this->journal; |
38 | 38 | |
39 | - return $next($request)->then(function (ResponseInterface $response) use ($request, $journal) { |
|
39 | + return $next($request)->then(function(ResponseInterface $response) use ($request, $journal) { |
|
40 | 40 | $journal->addSuccess($request, $response); |
41 | 41 | |
42 | 42 | return $response; |
43 | - }, function (ClientExceptionInterface $exception) use ($request, $journal) { |
|
43 | + }, function(ClientExceptionInterface $exception) use ($request, $journal) { |
|
44 | 44 | $journal->addFailure($request, $exception); |
45 | 45 | |
46 | 46 | throw $exception; |
@@ -58,7 +58,7 @@ discard block |
||
58 | 58 | { |
59 | 59 | $deferred = new self($this->waitCallback); |
60 | 60 | |
61 | - $this->onFulfilledCallbacks[] = function (ResponseInterface $response) use ($onFulfilled, $deferred) { |
|
61 | + $this->onFulfilledCallbacks[] = function(ResponseInterface $response) use ($onFulfilled, $deferred) { |
|
62 | 62 | try { |
63 | 63 | if (null !== $onFulfilled) { |
64 | 64 | $response = $onFulfilled($response); |
@@ -69,7 +69,7 @@ discard block |
||
69 | 69 | } |
70 | 70 | }; |
71 | 71 | |
72 | - $this->onRejectedCallbacks[] = function (ClientExceptionInterface $exception) use ($onRejected, $deferred) { |
|
72 | + $this->onRejectedCallbacks[] = function(ClientExceptionInterface $exception) use ($onRejected, $deferred) { |
|
73 | 73 | try { |
74 | 74 | if (null !== $onRejected) { |
75 | 75 | $response = $onRejected($exception); |
@@ -44,7 +44,7 @@ |
||
44 | 44 | $reversedPlugins = array_reverse($this->plugins); |
45 | 45 | |
46 | 46 | foreach ($reversedPlugins as $plugin) { |
47 | - $lastCallable = function (RequestInterface $request) use ($plugin, $lastCallable) { |
|
47 | + $lastCallable = function(RequestInterface $request) use ($plugin, $lastCallable) { |
|
48 | 48 | return $plugin->handleRequest($request, $lastCallable, $this); |
49 | 49 | }; |
50 | 50 | } |
@@ -79,7 +79,7 @@ discard block |
||
79 | 79 | |
80 | 80 | // Else we want to use the synchronous call of the underlying client, |
81 | 81 | // and not the async one in the case we have both an async and sync call |
82 | - $pluginChain = $this->createPluginChain($this->plugins, function (RequestInterface $request) { |
|
82 | + $pluginChain = $this->createPluginChain($this->plugins, function(RequestInterface $request) { |
|
83 | 83 | try { |
84 | 84 | return new HttpFulfilledPromise($this->client->sendRequest($request)); |
85 | 85 | } catch (HttplugException $exception) { |
@@ -95,7 +95,7 @@ discard block |
||
95 | 95 | */ |
96 | 96 | public function sendAsyncRequest(RequestInterface $request) |
97 | 97 | { |
98 | - $pluginChain = $this->createPluginChain($this->plugins, function (RequestInterface $request) { |
|
98 | + $pluginChain = $this->createPluginChain($this->plugins, function(RequestInterface $request) { |
|
99 | 99 | return $this->client->sendAsyncRequest($request); |
100 | 100 | }); |
101 | 101 |