bpolaszek / mercure-php-hub

src/Storage/Redis/RedisStorageFactory.php

Spacing +5 added lines, -5 removed lines

@@ -36,10 +36,10 @@ 
         $promises = [
             'async' => $factory->createClient($dsn)
                 ->then(
-                    function (AsynchronousClient $client) {
+                    function(AsynchronousClient $client) {
                         $client->on(
                             'close',
-                            function () {
+                            function() {
                                 $this->logger->error('Connection closed.');
                                 $this->loop->stop();
                             }
@@ -47,7 +47,7 @@ 
 
                         return $client;
                     },
-                    function (\Exception $exception) {
+                    function(\Exception $exception) {
                         $this->loop->stop();
                         $this->logger->error($exception->getMessage());
                     }
@@ -57,7 +57,7 @@ 
 
         return all($promises)
             ->then(
-                function (iterable $results): array {
+                function(iterable $results): array {
                     $clients = [];
                     foreach ($results as $key => $client) {
                         $clients[$key] = $client;
@@ -70,7 +70,7 @@ 
                 }
             )
             ->then(
-                fn (array $clients): RedisStorage => new RedisStorage(
+                fn(array $clients): RedisStorage => new RedisStorage(
                     $clients['async'],
                     $clients['sync'],
                 )

src/Controller/SubscribeController.php

Spacing +1 added lines, -1 removed lines

@@ -127,7 +127,7 @@
                     $topicSelector,
                     fn(string $topic, Message $message) => $this->sendIfAllowed($topic, $message, $request, $stream)
                 )
-                ->then(function (string $topic) use ($request) {
+                ->then(function(string $topic) use ($request) {
                     $clientId = $request->getAttribute('clientId');
                     $this->logger->debug("Client {$clientId} subscribed to {$topic}");
                 });

src/Controller/PublishController.php

Spacing +1 added lines, -1 removed lines

@@ -54,7 +54,7 @@
 
         $this->transport
             ->publish($input['topic'], $message)
-            ->then(fn () => $this->storage->storeMessage($input['topic'], $message));
+            ->then(fn() => $this->storage->storeMessage($input['topic'], $message));
 
         $this->logger->debug(
             \sprintf(

src/Hub/Hub.php

Spacing +4 added lines, -4 removed lines

@@ -44,13 +44,13 @@ 
         $localAddress = $this->config[Configuration::ADDR];
         $this->shutdownSignal = null;
         $this->metricsHandler->resetUsers($localAddress);
-        $this->loop->addSignal(SIGINT, function ($signal) {
+        $this->loop->addSignal(SIGINT, function($signal) {
             $this->stop($signal, $this->loop);
         });
         $this->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");
                 }
@@ -75,7 +75,7 @@ 
     private function createSocketConnection(string $localAddress, LoopInterface $loop): Socket\Server
     {
         $socket = new Socket\Server($localAddress, $loop);
-        $socket->on('connection', function (ConnectionInterface $connection) use ($localAddress) {
+        $socket->on('connection', function(ConnectionInterface $connection) use ($localAddress) {
             $this->metricsHandler->incrementUsers($localAddress);
             $connection->on('close', fn() => $this->metricsHandler->decrementUsers($localAddress));
         });
@@ -95,7 +95,7 @@ 
     private function stop(int $signal, LoopInterface $loop): void
     {
         $this->shutdownSignal = $signal;
-        $loop->futureTick(function () use ($loop) {
+        $loop->futureTick(function() use ($loop) {
             $loop->stop();
         });
     }

src/Transport/Redis/RedisTransportFactory.php

Spacing +8 added lines, -8 removed lines

@@ -34,10 +34,10 @@ 
         $promises = [
             'subscriber' => $factory->createClient($dsn)
                 ->then(
-                    function (AsynchronousClient $client) {
+                    function(AsynchronousClient $client) {
                         $client->on(
                             'close',
-                            function () {
+                            function() {
                                 $this->logger->error('Connection closed.');
                                 $this->loop->stop();
                             }
@@ -45,17 +45,17 @@ 
 
                         return $client;
                     },
-                    function (\Exception $exception) {
+                    function(\Exception $exception) {
                         $this->loop->stop();
                         $this->logger->error($exception->getMessage());
                     }
                 ),
             'publisher' => $factory->createClient($dsn)
                 ->then(
-                    function (AsynchronousClient $client) {
+                    function(AsynchronousClient $client) {
                         $client->on(
                             'close',
-                            function () {
+                            function() {
                                 $this->logger->error('Connection closed.');
                                 $this->loop->stop();
                             }
@@ -63,7 +63,7 @@ 
 
                         return $client;
                     },
-                    function (\Exception $exception) {
+                    function(\Exception $exception) {
                         $this->loop->stop();
                         $this->logger->error($exception->getMessage());
                     }
@@ -72,7 +72,7 @@ 
 
         return all($promises)
             ->then(
-                function (iterable $results): array {
+                function(iterable $results): array {
                     $clients = [];
                     foreach ($results as $key => $client) {
                         $clients[$key] = $client;
@@ -85,7 +85,7 @@ 
                 }
             )
             ->then(
-                fn (array $clients) => new RedisTransport($clients['subscriber'], $clients['publisher'])
+                fn(array $clients) => new RedisTransport($clients['subscriber'], $clients['publisher'])
             );
     }
 }

src/Command/ServeCommand.php

Spacing +1 added lines, -1 removed lines

@@ -50,7 +50,7 @@
             $config = $this->configuration->overrideWith(without_nullish_values($input->getOptions()))->asArray();
             $factory = $this->factory->withConfig($config);
             $loop->futureTick(
-                function () use ($config, $output) {
+                function() use ($config, $output) {
                     $this->displayConfiguration($config, $output);
                 }
             );