@@ -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)) { |
@@ -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 |