ggoffy / wggithub

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() ?: [];

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

Spacing +9 added lines, -9 removed lines

@@ -67,7 +67,7 @@ 
             $request->setHeader('Accept-Encoding', 'gzip');
         }
 
-        $this->initializer = static function (self $response) {
+        $this->initializer = static function(self $response) {
             return null !== $response->options;
         };
 
@@ -89,8 +89,8 @@ 
         $info['user_data'] = $options['user_data'];
         $info['debug'] = '';
 
-        $onProgress = $options['on_progress'] ?? static function () {};
-        $onProgress = $this->onProgress = static function () use (&$info, $onProgress) {
+        $onProgress = $options['on_progress'] ?? static function() {};
+        $onProgress = $this->onProgress = static function() use (&$info, $onProgress) {
             $info['total_time'] = micro\time(true) - $info['start_time'];
             $onProgress((int) $info['size_download'], ((int) (1 + $info['download_content_length']) ?: 1) - 1, (array) $info);
         };
@@ -101,11 +101,11 @@ 
         $throttleWatcher = null;
 
         $this->id = $id = self::$nextId++;
-        Loop::defer(static function () use ($request, $multi, &$id, &$info, &$headers, $canceller, &$options, $onProgress, &$handle, $logger, &$pause) {
+        Loop::defer(static function() use ($request, $multi, &$id, &$info, &$headers, $canceller, &$options, $onProgress, &$handle, $logger, &$pause) {
             return new Coroutine(self::generateResponse($request, $multi, $id, $info, $headers, $canceller, $options, $onProgress, $handle, $logger, $pause));
         });
 
-        $info['pause_handler'] = static function (float $duration) use (&$throttleWatcher, &$pauseDeferred, &$pause) {
+        $info['pause_handler'] = static function(float $duration) use (&$throttleWatcher, &$pauseDeferred, &$pause) {
             if (null !== $throttleWatcher) {
                 Loop::cancel($throttleWatcher);
             }
@@ -117,7 +117,7 @@ 
                 $pauseDeferred = new Deferred();
                 $deferred->resolve();
             } else {
-                $throttleWatcher = Loop::delay(ceil(1000 * $duration), static function () use (&$pauseDeferred) {
+                $throttleWatcher = Loop::delay(ceil(1000 * $duration), static function() use (&$pauseDeferred) {
                     $deferred = $pauseDeferred;
                     $pauseDeferred = new Deferred();
                     $deferred->resolve();
@@ -128,7 +128,7 @@ 
         $multi->openHandles[$id] = $id;
         ++$multi->responseCount;
 
-        $this->canary = new Canary(static function () use ($canceller, $multi, $id) {
+        $this->canary = new Canary(static function() use ($canceller, $multi, $id) {
             $canceller->cancel();
             unset($multi->openHandles[$id], $multi->handlesActivity[$id]);
         });
@@ -202,7 +202,7 @@ 
     private static function select(ClientState $multi, float $timeout): int
     {
         $timeout += micro\time(true);
-        self::$delay = Loop::defer(static function () use ($timeout) {
+        self::$delay = Loop::defer(static function() use ($timeout) {
             if (0 < $timeout -= micro\time(true)) {
                 self::$delay = Loop::delay(ceil(1000 * $timeout), [Loop::class, 'stop']);
             } else {
@@ -217,7 +217,7 @@ 
 
     private static function generateResponse(Request $request, AmpClientState $multi, string $id, array &$info, array &$headers, CancellationTokenSource $canceller, array &$options, \Closure $onProgress, &$handle, ?LoggerInterface $logger, Promise &$pause)
     {
-        $request->setInformationalResponseHandler(static function (Response $response) use ($multi, $id, &$info, &$headers) {
+        $request->setInformationalResponseHandler(static function(Response $response) use ($multi, $id, &$info, &$headers) {
             self::addResponseHeaders($response, $info, $headers);
             $multi->handlesActivity[$id][] = new InformationalChunk($response->getStatus(), $response->getHeaders());
             self::stopLoop();

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

Spacing +1 added lines, -1 removed lines

@@ -73,7 +73,7 @@
             return null;
         }
 
-        return static function ($value) use ($callback) {
+        return static function($value) use ($callback) {
             return promise_for($callback($value));
         };
     }

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

Spacing +1 added lines, -1 removed lines

@@ -153,7 +153,7 @@
         $this->info['previous_info'][] = $this->response->getInfo();
         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);
             };
         }