@@ -143,10 +143,10 @@ discard block |
||
| 143 | 143 | */ |
| 144 | 144 | public function sendRequest(RequestInterface $request, array $options = []): ResponseInterface |
| 145 | 145 | { |
| 146 | - $chain = $this->createMiddlewareChain($this->middleware, function (RequestInterface $request, callable $responseChain) use ($options) { |
|
| 146 | + $chain = $this->createMiddlewareChain($this->middleware, function(RequestInterface $request, callable $responseChain) use ($options) { |
|
| 147 | 147 | $response = $this->client->sendRequest($request, $options); |
| 148 | 148 | $responseChain($request, $response); |
| 149 | - }, function (RequestInterface $request, ResponseInterface $response) { |
|
| 149 | + }, function(RequestInterface $request, ResponseInterface $response) { |
|
| 150 | 150 | $this->lastRequest = $request; |
| 151 | 151 | $this->lastResponse = $response; |
| 152 | 152 | }); |
@@ -167,14 +167,14 @@ discard block |
||
| 167 | 167 | // Build response chain |
| 168 | 168 | /** @var MiddlewareInterface $middleware */ |
| 169 | 169 | foreach ($middleware as $middleware) { |
| 170 | - $lastCallable = function (RequestInterface $request, ResponseInterface $response) use ($middleware, $responseChainNext) { |
|
| 170 | + $lastCallable = function(RequestInterface $request, ResponseInterface $response) use ($middleware, $responseChainNext) { |
|
| 171 | 171 | return $middleware->handleResponse($request, $response, $responseChainNext); |
| 172 | 172 | }; |
| 173 | 173 | |
| 174 | 174 | $responseChainNext = $lastCallable; |
| 175 | 175 | } |
| 176 | 176 | |
| 177 | - $requestChainLast = function (RequestInterface $request) use ($requestChainLast, $responseChainNext) { |
|
| 177 | + $requestChainLast = function(RequestInterface $request) use ($requestChainLast, $responseChainNext) { |
|
| 178 | 178 | // Send the actual request and get the response |
| 179 | 179 | $requestChainLast($request, $responseChainNext); |
| 180 | 180 | }; |
@@ -185,7 +185,7 @@ discard block |
||
| 185 | 185 | $requestChainNext = $requestChainLast; |
| 186 | 186 | /** @var MiddlewareInterface $middleware */ |
| 187 | 187 | foreach ($middleware as $middleware) { |
| 188 | - $lastCallable = function (RequestInterface $request) use ($middleware, $requestChainNext) { |
|
| 188 | + $lastCallable = function(RequestInterface $request) use ($middleware, $requestChainNext) { |
|
| 189 | 189 | return $middleware->handleRequest($request, $requestChainNext); |
| 190 | 190 | }; |
| 191 | 191 | |
@@ -96,7 +96,7 @@ discard block |
||
| 96 | 96 | $this->setOptionsFromRequest($curl, $request); |
| 97 | 97 | |
| 98 | 98 | $responseBuilder = new ResponseBuilder($this->responseFactory); |
| 99 | - curl_setopt($curl, CURLOPT_HEADERFUNCTION, function ($ch, $data) use ($responseBuilder) { |
|
| 99 | + curl_setopt($curl, CURLOPT_HEADERFUNCTION, function($ch, $data) use ($responseBuilder) { |
|
| 100 | 100 | $str = trim($data); |
| 101 | 101 | if ('' !== $str) { |
| 102 | 102 | if (0 === strpos(strtolower($str), 'http/')) { |
@@ -109,7 +109,7 @@ discard block |
||
| 109 | 109 | return \strlen($data); |
| 110 | 110 | }); |
| 111 | 111 | |
| 112 | - curl_setopt($curl, CURLOPT_WRITEFUNCTION, function ($ch, $data) use ($responseBuilder) { |
|
| 112 | + curl_setopt($curl, CURLOPT_WRITEFUNCTION, function($ch, $data) use ($responseBuilder) { |
|
| 113 | 113 | return $responseBuilder->writeBody($data); |
| 114 | 114 | }); |
| 115 | 115 | |
@@ -171,7 +171,7 @@ discard block |
||
| 171 | 171 | if (null !== $bodySize) { |
| 172 | 172 | $options[CURLOPT_INFILESIZE] = $bodySize; |
| 173 | 173 | } |
| 174 | - $options[CURLOPT_READFUNCTION] = function ($ch, $fd, $length) use ($body) { |
|
| 174 | + $options[CURLOPT_READFUNCTION] = function($ch, $fd, $length) use ($body) { |
|
| 175 | 175 | return $body->read($length); |
| 176 | 176 | }; |
| 177 | 177 | } else { |
@@ -96,7 +96,7 @@ discard block |
||
| 96 | 96 | $options = $this->validateOptions($options); |
| 97 | 97 | $originalCallback = $options->get('callback'); |
| 98 | 98 | $responseToReturn = null; |
| 99 | - $options = $options->add(['callback' => function (RequestInterface $request, ResponseInterface $response = null, ClientException $e = null) use (&$responseToReturn, $originalCallback) { |
|
| 99 | + $options = $options->add(['callback' => function(RequestInterface $request, ResponseInterface $response = null, ClientException $e = null) use (&$responseToReturn, $originalCallback) { |
|
| 100 | 100 | $responseToReturn = $response; |
| 101 | 101 | $originalCallback($request, $response, $e); |
| 102 | 102 | |
@@ -115,11 +115,11 @@ discard block |
||
| 115 | 115 | { |
| 116 | 116 | parent::configureOptions($resolver); |
| 117 | 117 | |
| 118 | - $resolver->setDefault('callback', function (RequestInterface $request, ResponseInterface $response = null, ClientException $e = null) { |
|
| 118 | + $resolver->setDefault('callback', function(RequestInterface $request, ResponseInterface $response = null, ClientException $e = null) { |
|
| 119 | 119 | }); |
| 120 | 120 | $resolver->setAllowedTypes('callback', 'callable'); |
| 121 | 121 | |
| 122 | - $resolver->setDefault('push_function_callback', function ($parent, $pushed, $headers) { |
|
| 122 | + $resolver->setDefault('push_function_callback', function($parent, $pushed, $headers) { |
|
| 123 | 123 | return CURL_PUSH_OK; |
| 124 | 124 | }); |
| 125 | 125 | $resolver->setAllowedTypes('push_function_callback', ['callable', 'null']); |
@@ -176,7 +176,7 @@ discard block |
||
| 176 | 176 | |
| 177 | 177 | curl_multi_setopt($this->curlm, CURLMOPT_PIPELINING, CURLPIPE_MULTIPLEX); |
| 178 | 178 | // We need to use $this->pushCb[] because of a bug in PHP |
| 179 | - curl_multi_setopt($this->curlm, CURLMOPT_PUSHFUNCTION, $this->pushCb[] = function ($parent, $pushed, $headers) use ($userCallbacks) { |
|
| 179 | + curl_multi_setopt($this->curlm, CURLMOPT_PUSHFUNCTION, $this->pushCb[] = function($parent, $pushed, $headers) use ($userCallbacks) { |
|
| 180 | 180 | // If any callback say no, then do not accept. |
| 181 | 181 | foreach ($userCallbacks as $callback) { |
| 182 | 182 | if (CURL_PUSH_DENY === $callback($parent, $pushed, $headers)) { |