ggoffy / wggithub

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]);
         });

lib/Github/Http/Client/NoPrivateNetworkHttpClient.php

Spacing +1 added lines, -1 removed lines

@@ -78,7 +78,7 @@
         $subnets = $this->subnets;
         $lastPrimaryIp = '';
 
-        $options['on_progress'] = function (int $dlNow, int $dlSize, array $info) use ($onProgress, $subnets, &$lastPrimaryIp): void {
+        $options['on_progress'] = function(int $dlNow, int $dlSize, array $info) use ($onProgress, $subnets, &$lastPrimaryIp): void {
             if ($info['primary_ip'] !== $lastPrimaryIp) {
                 if (IpUtils::checkIp($info['primary_ip'], $subnets ?? self::PRIVATE_SUBNETS)) {
                     throw new TransportException(\sprintf('IP "%s" is blocked for "%s".', $info['primary_ip'], $info['url']));

lib/Github/Http/Client/MockHttpClient.php

Spacing +1 added lines, -1 removed lines

@@ -41,7 +41,7 @@
         }
 
         if (!$responseFactory instanceof \Iterator && null !== $responseFactory && !\is_callable($responseFactory)) {
-            $responseFactory = (static function () use ($responseFactory) {
+            $responseFactory = (static function() use ($responseFactory) {
                 yield from $responseFactory;
             })();
         }

lib/Github/Http/Client/TraceableHttpClient.php

Spacing +1 added lines, -1 removed lines

@@ -57,7 +57,7 @@
             $content = false;
         }
 
-        $options['on_progress'] = function (int $dlNow, int $dlSize, array $info) use (&$traceInfo, $onProgress) {
+        $options['on_progress'] = function(int $dlNow, int $dlSize, array $info) use (&$traceInfo, $onProgress) {
             $traceInfo = $info;
 
             if (null !== $onProgress) {

lib/Github/Http/Client/Response/AsyncResponse.php

Spacing +3 added lines, -3 removed lines

@@ -46,13 +46,13 @@ 
 
         if (null !== $onProgress = $options['on_progress'] ?? null) {
             $thisInfo = &$this->info;
-            $options['on_progress'] = static function (int $dlNow, int $dlSize, array $info) use (&$thisInfo, $onProgress) {
+            $options['on_progress'] = static function(int $dlNow, int $dlSize, array $info) use (&$thisInfo, $onProgress) {
                 $onProgress($dlNow, $dlSize, $thisInfo + $info);
             };
         }
         $this->response = $client->request($method, $url, ['buffer' => false] + $options);
         $this->passthru = $passthru;
-        $this->initializer = static function (self $response) {
+        $this->initializer = static function(self $response) {
             if (null === $response->shouldBuffer) {
                 return false;
             }
@@ -125,7 +125,7 @@ 
             $this->getHeaders(true);
         }
 
-        $handle = function () {
+        $handle = function() {
             $stream = $this->response instanceof StreamableInterface ? $this->response->toStream(false) : StreamWrapper::createResource($this->response);
 
             return stream_get_meta_data($stream)['wrapper_data']->stream_cast(\STREAM_CAST_FOR_SELECT);

lib/Github/Http/Client/Response/NativeResponse.php

Spacing +4 added lines, -4 removed lines

@@ -63,16 +63,16 @@ 
         $info['user_data'] = $options['user_data'];
         ++$multi->responseCount;
 
-        $this->initializer = static function (self $response) {
+        $this->initializer = static function(self $response) {
             return null === $response->remaining;
         };
 
         $pauseExpiry = &$this->pauseExpiry;
-        $info['pause_handler'] = static function (float $duration) use (&$pauseExpiry) {
+        $info['pause_handler'] = static function(float $duration) use (&$pauseExpiry) {
             $pauseExpiry = 0 < $duration ? micro\time(true) + $duration : 0;
         };
 
-        $this->canary = new Canary(static function () use ($multi, $id) {
+        $this->canary = new Canary(static function() use ($multi, $id) {
             if (null !== ($host = $multi->openHandles[$id][6] ?? null) && 0 >= --$multi->hosts[$host]) {
                 unset($multi->hosts[$host]);
             }
@@ -115,7 +115,7 @@ 
     {
         $url = $this->url;
 
-        set_error_handler(function ($type, $msg) use (&$url) {
+        set_error_handler(function($type, $msg) use (&$url) {
             if (\E_NOTICE !== $type || 'fopen(): Content-type not specified assuming application/x-www-form-urlencoded' !== $msg) {
                 throw new TransportException($msg);
             }

lib/Github/Http/Client/Response/CurlResponse.php

Spacing +8 added lines, -8 removed lines

@@ -75,7 +75,7 @@ 
             \curl_setopt($ch, \CURLOPT_PRIVATE, \in_array($method, ['GET', 'HEAD', 'OPTIONS', 'TRACE'], true) && 1.0 < (float) ($options['http_version'] ?? 1.1) ? 'H2' : 'H0'); // H = headers + retry counter
         }
 
-        \curl_setopt($ch, \CURLOPT_HEADERFUNCTION, static function ($ch, string $data) use (&$info, &$headers, $options, $multi, $id, &$location, $resolveRedirect, $logger): int {
+        \curl_setopt($ch, \CURLOPT_HEADERFUNCTION, static function($ch, string $data) use (&$info, &$headers, $options, $multi, $id, &$location, $resolveRedirect, $logger): int {
             if (0 !== substr_compare($data, "\r\n", -2)) {
                 return 0;
             }
@@ -91,7 +91,7 @@ 
 
         if (null === $options) {
             // Pushed response: buffer until requested
-            \curl_setopt($ch, \CURLOPT_WRITEFUNCTION, static function ($ch, string $data) use ($multi, $id): int {
+            \curl_setopt($ch, \CURLOPT_WRITEFUNCTION, static function($ch, string $data) use ($multi, $id): int {
                 $multi->handlesActivity[$id][] = $data;
                 curl_pause($ch, \CURLPAUSE_RECV);
 
@@ -102,7 +102,7 @@ 
         }
 
         $execCounter = $multi->execCounter;
-        $this->info['pause_handler'] = static function (float $duration) use ($ch, $multi, $execCounter) {
+        $this->info['pause_handler'] = static function(float $duration) use ($ch, $multi, $execCounter) {
             if (0 < $duration) {
                 if ($execCounter === $multi->execCounter) {
                     $multi->execCounter = !\is_float($execCounter) ? 1 + $execCounter : \PHP_INT_MIN;
@@ -128,7 +128,7 @@ 
         if ($onProgress = $options['on_progress']) {
             $url = isset($info['url']) ? ['url' => $info['url']] : [];
             \curl_setopt($ch, \CURLOPT_NOPROGRESS, false);
-            \curl_setopt($ch, \CURLOPT_PROGRESSFUNCTION, static function ($ch, $dlSize, $dlNow) use ($onProgress, &$info, $url, $multi, $debugBuffer) {
+            \curl_setopt($ch, \CURLOPT_PROGRESSFUNCTION, static function($ch, $dlSize, $dlNow) use ($onProgress, &$info, $url, $multi, $debugBuffer) {
                 try {
                     rewind($debugBuffer);
                     $debug = ['debug' => stream_get_contents($debugBuffer)];
@@ -144,7 +144,7 @@ 
             });
         }
 
-        \curl_setopt($ch, \CURLOPT_WRITEFUNCTION, static function ($ch, string $data) use ($multi, $id): int {
+        \curl_setopt($ch, \CURLOPT_WRITEFUNCTION, static function($ch, string $data) use ($multi, $id): int {
             if ('H' === (\curl_getinfo($ch, \CURLINFO_PRIVATE)[0] ?? null)) {
                 $multi->handlesActivity[$id][] = null;
                 $multi->handlesActivity[$id][] = new TransportException(\sprintf('Unsupported protocol for "%s"', \curl_getinfo($ch, \CURLINFO_EFFECTIVE_URL)));
@@ -152,7 +152,7 @@ 
                 return 0;
             }
 
-            \curl_setopt($ch, \CURLOPT_WRITEFUNCTION, static function ($ch, string $data) use ($multi, $id): int {
+            \curl_setopt($ch, \CURLOPT_WRITEFUNCTION, static function($ch, string $data) use ($multi, $id): int {
                 $multi->handlesActivity[$id][] = $data;
 
                 return \strlen($data);
@@ -163,7 +163,7 @@ 
             return \strlen($data);
         });
 
-        $this->initializer = static function (self $response) {
+        $this->initializer = static function(self $response) {
             $waitFor = \curl_getinfo($ch = $response->handle, \CURLINFO_PRIVATE);
 
             return 'H' === $waitFor[0];
@@ -173,7 +173,7 @@ 
         $multi->openHandles[$id] = [$ch, $options];
         curl_multi_add_handle($multi->handle, $ch);
 
-        $this->canary = new Canary(static function () use ($ch, $multi, $id) {
+        $this->canary = new Canary(static function() use ($ch, $multi, $id) {
             unset($multi->pauseExpiries[$id], $multi->openHandles[$id], $multi->handlesActivity[$id]);
             \curl_setopt($ch, \CURLOPT_PRIVATE, '_0');
 

lib/Github/Http/Client/Response/MockResponse.php

Spacing +3 added lines, -3 removed lines

@@ -126,7 +126,7 @@ 
         $response->requestOptions = $options;
         $response->id = ++self::$idSequence;
         $response->shouldBuffer = $options['buffer'] ?? true;
-        $response->initializer = static function (self $response) {
+        $response->initializer = static function(self $response) {
             return \is_array($response->body[0] ?? null);
         };
 
@@ -224,7 +224,7 @@ 
      */
     private static function writeRequest(self $response, array $options, ResponseInterface $mock)
     {
-        $onProgress = $options['on_progress'] ?? static function () {};
+        $onProgress = $options['on_progress'] ?? static function() {};
         $response->info += $mock->getInfo() ?: [];
 
         // simulate "size_upload" if it is set
@@ -267,7 +267,7 @@ 
      */
     private static function readResponse(self $response, array $options, ResponseInterface $mock, int &$offset)
     {
-        $onProgress = $options['on_progress'] ?? static function () {};
+        $onProgress = $options['on_progress'] ?? static function() {};
 
         // populate info related to headers
         $info = $mock->getInfo() ?: [];