bpolaszek / mercure-php-hub

src/Controller/SubscribeController.php

Spacing +1 added lines, -1 removed lines

@@ -114,7 +114,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

@@ -51,7 +51,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/Helpers/RedisHelper.php

Spacing +1 added lines, -1 removed lines

@@ -13,7 +13,7 @@
         /** @phpstan-ignore-next-line */
         $client->get('foo')->then(
             null,
-            function (\Exception $e) use ($loop, $logger) {
+            function(\Exception $e) use ($loop, $logger) {
                 $logger->error(\sprintf('Redis error: %s', $e->getMessage()));
                 $loop->stop();
             }

src/Transport/Redis/RedisTransport.php

Spacing +2 added lines, -2 removed lines

@@ -46,7 +46,7 @@ 
         $this->subscriber->subscribe($topicSelector);
         $this->subscriber->on(
             'message',
-            function (string $topic, string $payload) use ($topicSelector, $callback) {
+            function(string $topic, string $payload) use ($topicSelector, $callback) {
                 $this->dispatch($topic, $payload, $topicSelector, $callback);
             }
         );
@@ -74,7 +74,7 @@ 
         $this->subscriber->psubscribe($channel);
         $this->subscriber->on(
             'pmessage',
-            function (string $pattern, string $topic, string $payload) use ($topicSelector, $callback) {
+            function(string $pattern, string $topic, string $payload) use ($topicSelector, $callback) {
                 $this->dispatch($topic, $payload, $topicSelector, $callback);
             }
         );

src/Transport/PHP/PHPTransport.php

Spacing +1 added lines, -1 removed lines

@@ -28,7 +28,7 @@
 
     public function subscribe(string $subscribedTopic, callable $callback): PromiseInterface
     {
-        $this->emitter->on('message', function (string $topic, Message $message) use ($callback, $subscribedTopic) {
+        $this->emitter->on('message', function(string $topic, Message $message) use ($callback, $subscribedTopic) {
             if (!TopicMatcher::matchesTopicSelectors($topic, [$subscribedTopic])) {
                 return;
             }

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

src/Storage/Redis/RedisStorageFactory.php

Spacing +5 added lines, -5 removed lines

@@ -38,10 +38,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();
                             }
@@ -49,7 +49,7 @@ 
 
                         return $client;
                     },
-                    function (\Exception $exception) {
+                    function(\Exception $exception) {
                         $this->loop->stop();
                         $this->logger()->error($exception->getMessage());
                     }
@@ -59,7 +59,7 @@ 
 
         return all($promises)
             ->then(
-                function (iterable $results): array {
+                function(iterable $results): array {
                     $clients = [];
                     foreach ($results as $key => $client) {
                         $clients[$key] = $client;
@@ -72,7 +72,7 @@ 
                 }
             )
             ->then(
-                fn (array $clients): RedisStorage => new RedisStorage(
+                fn(array $clients): RedisStorage => new RedisStorage(
                     $clients['async'],
                     $clients['sync'],
                 )

src/Hub/Hub.php

Spacing +4 added lines, -4 removed lines

@@ -47,13 +47,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");
                 }
@@ -80,7 +80,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));
         });
@@ -105,7 +105,7 @@ 
     private function stop(int $signal, LoopInterface $loop): void
     {
         $this->shutdownSignal = $signal;
-        $loop->futureTick(function () use ($loop) {
+        $loop->futureTick(function() use ($loop) {
             $loop->stop();
         });
     }