bpolaszek / mercure-php-hub

src/Metrics/Redis/RedisMetricsHandler.php

Spacing +2 added lines, -2 removed lines

@@ -43,13 +43,13 @@
         /** @phpstan-ignore-next-line */
         return $this->client->keys('users:*')
             ->then(
-                function (array $keys) {
+                function(array $keys) {
                     $promises = [];
                     foreach ($keys as $key) {
                         $promises[] = $this->client->get($key); /** @phpstan-ignore-line */
                     }
 
-                    return all($promises)->then(fn (array $results): int => \array_sum($results));
+                    return all($promises)->then(fn(array $results): int => \array_sum($results));
                 }
             );
     }

src/Hub/Hub.php

Spacing +4 added lines, -4 removed lines

@@ -46,13 +46,13 @@ 
         $localAddress = $this->config[Configuration::ADDR];
         $this->shutdownSignal = null;
         $this->metricsHandler->resetUsers($localAddress);
-        $loop->addSignal(SIGINT, function ($signal) use ($loop) {
+        $loop->addSignal(SIGINT, function($signal) use ($loop) {
             $this->stop($signal, $loop);
         });
         $loop->addPeriodicTimer(
             15,
             fn() => $this->metricsHandler->getNbUsers()->then(
-                function (int $nbUsers) {
+                function(int $nbUsers) {
                     $memory = \memory_get_usage(true) / 1024 / 1024;
                     $this->logger()->debug("Users: {$nbUsers} - Memory: {$memory}MB");
                 }
@@ -87,7 +87,7 @@ 
     private function stop(int $signal, LoopInterface $loop): void
     {
         $this->shutdownSignal = $signal;
-        $loop->futureTick(function () use ($loop) {
+        $loop->futureTick(function() use ($loop) {
             $loop->stop();
         });
     }
@@ -97,7 +97,7 @@ 
         $socket = new Socket\Server($localAddress, $loop);
         $socket->on(
             'connection',
-            function (Socket\ConnectionInterface $connection) use ($localAddress) {
+            function(Socket\ConnectionInterface $connection) use ($localAddress) {
                 $this->metricsHandler->incrementUsers($localAddress);
                 $connection->on('close', fn() => $this->metricsHandler->decrementUsers($localAddress));
             }

src/Command/ServeCommand.php

Spacing +1 added lines, -1 removed lines

@@ -42,7 +42,7 @@
                 ->overrideWith($this->getInputOptions($input))
                 ->asArray();
 
-            $loop->futureTick(function () use ($config, $output) {
+            $loop->futureTick(function() use ($config, $output) {
                 $this->displayConfiguration($config, $output);
             });
 

src/Command/StressSubscribersCommand.php

Spacing +1 added lines, -1 removed lines

@@ -63,7 +63,7 @@
         $url = $url->withQuery($qs);
         $nbSubscribers = (int) $input->getOption('subscribers');
 
-        $requests = function (HttpClientInterface $client, string $url) use ($nbSubscribers) {
+        $requests = function(HttpClientInterface $client, string $url) use ($nbSubscribers) {
             for ($i = 0; $i < $nbSubscribers; $i++) {
                 yield $client->request('GET', $url);
             }