ggoffy / wggithub

lib/Github/Http/Client/Common/Deferred.php

Spacing +2 added lines, -2 removed lines

@@ -58,7 +58,7 @@ 
     {
         $deferred = new self($this->waitCallback);
 
-        $this->onFulfilledCallbacks[] = function (ResponseInterface $response) use ($onFulfilled, $deferred) {
+        $this->onFulfilledCallbacks[] = function(ResponseInterface $response) use ($onFulfilled, $deferred) {
             try {
                 if (null !== $onFulfilled) {
                     $response = $onFulfilled($response);
@@ -69,7 +69,7 @@ 
             }
         };
 
-        $this->onRejectedCallbacks[] = function (ClientExceptionInterface $exception) use ($onRejected, $deferred) {
+        $this->onRejectedCallbacks[] = function(ClientExceptionInterface $exception) use ($onRejected, $deferred) {
             try {
                 if (null !== $onRejected) {
                     $response = $onRejected($exception);

lib/Github/Http/Client/Common/PluginChain.php

Spacing +1 added lines, -1 removed lines

@@ -44,7 +44,7 @@
         $reversedPlugins = array_reverse($this->plugins);
 
         foreach ($reversedPlugins as $plugin) {
-            $lastCallable = function (RequestInterface $request) use ($plugin, $lastCallable) {
+            $lastCallable = function(RequestInterface $request) use ($plugin, $lastCallable) {
                 return $plugin->handleRequest($request, $lastCallable, $this);
             };
         }

lib/Github/Http/Client/Common/PluginClient.php

Spacing +2 added lines, -2 removed lines

@@ -79,7 +79,7 @@ 
 
         // Else we want to use the synchronous call of the underlying client,
         // and not the async one in the case we have both an async and sync call
-        $pluginChain = $this->createPluginChain($this->plugins, function (RequestInterface $request) {
+        $pluginChain = $this->createPluginChain($this->plugins, function(RequestInterface $request) {
             try {
                 return new HttpFulfilledPromise($this->client->sendRequest($request));
             } catch (HttplugException $exception) {
@@ -95,7 +95,7 @@ 
      */
     public function sendAsyncRequest(RequestInterface $request)
     {
-        $pluginChain = $this->createPluginChain($this->plugins, function (RequestInterface $request) {
+        $pluginChain = $this->createPluginChain($this->plugins, function(RequestInterface $request) {
             return $this->client->sendAsyncRequest($request);
         });
 

lib/Github/Http/Client/Common/HttpClientPool/RandomClientPool.php

Spacing +1 added lines, -1 removed lines

@@ -18,7 +18,7 @@
      */
     protected function chooseHttpClient(): HttpClientPoolItem
     {
-        $clientPool = \array_filter($this->clientPool, function (HttpClientPoolItem $clientPoolItem) {
+        $clientPool = \array_filter($this->clientPool, function(HttpClientPoolItem $clientPoolItem) {
             return !$clientPoolItem->isDisabled();
         });
 

lib/Github/Http/Client/Common/HttpClientPool/HttpClientPoolItem.php

Spacing +2 added lines, -2 removed lines

@@ -103,11 +103,11 @@
 
         $this->incrementRequestCount();
 
-        return $this->client->sendAsyncRequest($request)->then(function ($response) {
+        return $this->client->sendAsyncRequest($request)->then(function($response) {
             $this->decrementRequestCount();
 
             return $response;
-        }, function ($exception) {
+        }, function($exception) {
             $this->disable();
             $this->decrementRequestCount();
 

lib/Github/Http/Client/Common/HttpClientPool/LeastUsedClientPool.php

Spacing +2 added lines, -2 removed lines

@@ -20,7 +20,7 @@ 
      */
     protected function chooseHttpClient(): HttpClientPoolItem
     {
-        $clientPool = \array_filter($this->clientPool, function (HttpClientPoolItem $clientPoolItem) {
+        $clientPool = \array_filter($this->clientPool, function(HttpClientPoolItem $clientPoolItem) {
             return !$clientPoolItem->isDisabled();
         });
 
@@ -28,7 +28,7 @@ 
             throw new HttpClientNotFoundException('Cannot choose a http client as there is no one present in the pool');
         }
 
-        usort($clientPool, function (HttpClientPoolItem $clientA, HttpClientPoolItem $clientB) {
+        usort($clientPool, function(HttpClientPoolItem $clientA, HttpClientPoolItem $clientB) {
             if ($clientA->getSendingRequestCount() === $clientB->getSendingRequestCount()) {
                 return 0;
             }

lib/Github/Http/Client/NativeHttpClient.php

Spacing +9 added lines, -9 removed lines

@@ -117,7 +117,7 @@ 
             // Memoize the last progress to ease calling the callback periodically when no network transfer happens
             $lastProgress = [0, 0];
             $maxDuration = 0 < $options['max_duration'] ? $options['max_duration'] : \INF;
-            $onProgress = static function (...$progress) use ($onProgress, &$lastProgress, &$info, $maxDuration) {
+            $onProgress = static function(...$progress) use ($onProgress, &$lastProgress, &$info, $maxDuration) {
                 if ($info['total_time'] >= $maxDuration) {
                     throw new TransportException(\sprintf('Max duration was reached for "%s".', \implode('', $info['url'])));
                 }
@@ -137,7 +137,7 @@ 
             };
         } elseif (0 < $options['max_duration']) {
             $maxDuration = $options['max_duration'];
-            $onProgress = static function () use (&$info, $maxDuration): void {
+            $onProgress = static function() use (&$info, $maxDuration): void {
                 if ($info['total_time'] >= $maxDuration) {
                     throw new TransportException(\sprintf('Max duration was reached for "%s".', \implode('', $info['url'])));
                 }
@@ -145,7 +145,7 @@ 
         }
 
         // Always register a notification callback to compute live stats about the response
-        $notification = static function (int $code, int $severity, ?string $msg, int $msgCode, int $dlNow, int $dlSize) use ($onProgress, &$info) {
+        $notification = static function(int $code, int $severity, ?string $msg, int $msgCode, int $dlNow, int $dlSize) use ($onProgress, &$info) {
             $info['total_time'] = micro\time(true) - $info['start_time'];
 
             if (\STREAM_NOTIFY_PROGRESS === $code) {
@@ -205,7 +205,7 @@ 
                 'allow_self_signed' => (bool) $options['peer_fingerprint'],
                 'SNI_enabled' => true,
                 'disable_compression' => true,
-            ], static function ($v) { return null !== $v; }),
+            ], static function($v) { return null !== $v; }),
             'socket' => [
                 'bindto' => $options['bindto'] ?: '0:0',
                 'tcp_nodelay' => true,
@@ -214,7 +214,7 @@ 
 
         $context = stream_context_create($context, ['notification' => $notification]);
 
-        $resolver = static function ($multi) use ($context, $options, $url, &$info, $onProgress) {
+        $resolver = static function($multi) use ($context, $options, $url, &$info, $onProgress) {
             [$host, $port] = self::parseHostPort($url, $info);
 
             if (!isset($options['normalized_headers']['host'])) {
@@ -324,18 +324,18 @@ 
         $redirectHeaders = [];
         if (0 < $maxRedirects = $options['max_redirects']) {
             $redirectHeaders = ['host' => $host];
-            $redirectHeaders['with_auth'] = $redirectHeaders['no_auth'] = \array_filter($options['headers'], static function ($h) {
+            $redirectHeaders['with_auth'] = $redirectHeaders['no_auth'] = \array_filter($options['headers'], static function($h) {
                 return 0 !== stripos($h, 'Host:');
             });
 
             if (isset($options['normalized_headers']['authorization']) || isset($options['normalized_headers']['cookie'])) {
-                $redirectHeaders['no_auth'] = \array_filter($redirectHeaders['no_auth'], static function ($h) {
+                $redirectHeaders['no_auth'] = \array_filter($redirectHeaders['no_auth'], static function($h) {
                     return 0 !== stripos($h, 'Authorization:') && 0 !== stripos($h, 'Cookie:');
                 });
             }
         }
 
-        return static function (NativeClientState $multi, ?string $location, $context) use ($redirectHeaders, $proxy, &$info, $maxRedirects, $onProgress): ?string {
+        return static function(NativeClientState $multi, ?string $location, $context) use ($redirectHeaders, $proxy, &$info, $maxRedirects, $onProgress) : ?string {
             if (null === $location || $info['http_code'] < 300 || 400 <= $info['http_code']) {
                 $info['redirect_url'] = null;
 
@@ -368,7 +368,7 @@ 
                 if ('POST' === $options['method'] || 303 === $info['http_code']) {
                     $info['http_method'] = $options['method'] = 'HEAD' === $options['method'] ? 'HEAD' : 'GET';
                     $options['content'] = '';
-                    $options['header'] = \array_filter($options['header'], static function ($h) {
+                    $options['header'] = \array_filter($options['header'], static function($h) {
                         return 0 !== stripos($h, 'Content-Length:') && 0 !== stripos($h, 'Content-Type:');
                     });
 

lib/Github/Http/Client/EventSourceHttpClient.php

Spacing +1 added lines, -1 removed lines

@@ -66,7 +66,7 @@
             }
         }
 
-        return new AsyncResponse($this->client, $method, $url, $options, static function (ChunkInterface $chunk, AsyncContext $context) use ($state, $method, $url, $options) {
+        return new AsyncResponse($this->client, $method, $url, $options, static function(ChunkInterface $chunk, AsyncContext $context) use ($state, $method, $url, $options) {
             if (null !== $state->buffer) {
                 $context->setInfo('reconnection_time', $state->reconnectionTime);
                 $isTimeout = false;

lib/Github/Http/Client/HttplugClient.php

Spacing +2 added lines, -2 removed lines

@@ -119,9 +119,9 @@
 
         $waitLoop = $this->waitLoop;
 
-        $promise = new GuzzlePromise(static function () use ($response, $waitLoop) {
+        $promise = new GuzzlePromise(static function() use ($response, $waitLoop) {
             $waitLoop->wait($response);
-        }, static function () use ($response, $promisePool) {
+        }, static function() use ($response, $promisePool) {
             $response->cancel();
             unset($promisePool[$response]);
         });