bpolaszek / mercure-php-hub

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/Transport/Redis/RedisTransportFactory.php

Spacing +8 added lines, -8 removed lines

@@ -36,10 +36,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();
                             }
@@ -47,17 +47,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();
                             }
@@ -65,7 +65,7 @@ 
 
                         return $client;
                     },
-                    function (\Exception $exception) {
+                    function(\Exception $exception) {
                         $this->loop->stop();
                         $this->logger()->error($exception->getMessage());
                     }
@@ -74,7 +74,7 @@ 
 
         return all($promises)
             ->then(
-                function (iterable $results): array {
+                function(iterable $results): array {
                     $clients = [];
                     foreach ($results as $key => $client) {
                         $clients[$key] = $client;
@@ -87,7 +87,7 @@ 
                 }
             )
             ->then(
-                fn (array $clients) => new RedisTransport($clients['subscriber'], $clients['publisher'])
+                fn(array $clients) => new RedisTransport($clients['subscriber'], $clients['publisher'])
             );
     }
 }

src/Metrics/Redis/RedisMetricsHandlerFactory.php

Spacing +1 added lines, -1 removed lines

@@ -33,6 +33,6 @@
         $factory = new Factory($this->loop);
 
         return $factory->createClient($dsn)
-            ->then(fn (AsynchronousClient $client) => new RedisMetricsHandler($client));
+            ->then(fn(AsynchronousClient $client) => new RedisMetricsHandler($client));
     }
 }

src/Command/GenerateJWTCommand.php

Spacing +1 added lines, -1 removed lines

@@ -206,7 +206,7 @@
             $value = $io->ask(
                 'TTL of this token in seconds (or hit ENTER for no expiration):',
                 null,
-                function ($value) {
+                function($value) {
                     if (null === $value) {
                         return null;
                     }