| @@ -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 { | 
| @@ -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 | }); | 
| @@ -166,14 +166,14 @@ discard block | ||
| 166 | 166 | |
| 167 | 167 | // Build response chain | 
| 168 | 168 |          foreach ($middleware as $m) { | 
| 169 | -            $lastCallable = function (RequestInterface $request, ResponseInterface $response) use ($m, $responseChainNext) { | |
| 169 | +            $lastCallable = function(RequestInterface $request, ResponseInterface $response) use ($m, $responseChainNext) { | |
| 170 | 170 | return $m->handleResponse($request, $response, $responseChainNext); | 
| 171 | 171 | }; | 
| 172 | 172 | |
| 173 | 173 | $responseChainNext = $lastCallable; | 
| 174 | 174 | } | 
| 175 | 175 | |
| 176 | -        $requestChainLast = function (RequestInterface $request) use ($requestChainLast, $responseChainNext) { | |
| 176 | +        $requestChainLast = function(RequestInterface $request) use ($requestChainLast, $responseChainNext) { | |
| 177 | 177 | // Send the actual request and get the response | 
| 178 | 178 | $requestChainLast($request, $responseChainNext); | 
| 179 | 179 | }; | 
| @@ -183,7 +183,7 @@ discard block | ||
| 183 | 183 | // Build request chain | 
| 184 | 184 | $requestChainNext = $requestChainLast; | 
| 185 | 185 |          foreach ($middleware as $m) { | 
| 186 | -            $lastCallable = function (RequestInterface $request) use ($m, $requestChainNext) { | |
| 186 | +            $lastCallable = function(RequestInterface $request) use ($m, $requestChainNext) { | |
| 187 | 187 | return $m->handleRequest($request, $requestChainNext); | 
| 188 | 188 | }; | 
| 189 | 189 | |
| @@ -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']); | 
| @@ -301,7 +301,7 @@ discard block | ||
| 301 | 301 | curl_multi_setopt( | 
| 302 | 302 | $this->curlm, | 
| 303 | 303 | CURLMOPT_PUSHFUNCTION, | 
| 304 | -                $this->pushCb[] = function ($parent, $pushed, $headers) use ($userCallbacks) { | |
| 304 | +                $this->pushCb[] = function($parent, $pushed, $headers) use ($userCallbacks) { | |
| 305 | 305 | // If any callback say no, then do not accept. | 
| 306 | 306 |                      foreach ($userCallbacks as $callback) { | 
| 307 | 307 |                          if (CURL_PUSH_DENY === $callback($parent, $pushed, $headers)) { |