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/Storage/Redis/RedisStorageFactory.php

Spacing +5 added lines, -5 removed lines

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

src/Configuration/Configuration.php

Spacing +1 added lines, -1 removed lines

@@ -44,7 +44,7 @@
 
     private function export(): array
     {
-        $config = \array_map(fn ($value) => \is_string($value) && '' === \trim($value) ? null : $value, $this->config);
+        $config = \array_map(fn($value) => \is_string($value) && '' === \trim($value) ? null : $value, $this->config);
         if (null === $config[self::JWT_KEY] && null === $config[self::PUBLISHER_JWT_KEY]) {
             throw new \InvalidArgumentException(
                 "One of \"jwt_key\" or \"publisher_jwt_key\" configuration parameter must be defined."

src/Hub/Hub.php

Spacing +2 added lines, -2 removed lines

@@ -53,7 +53,7 @@ 
         $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");
                 }
@@ -61,7 +61,7 @@ 
         );
         $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/Transport/Redis/RedisTransportFactory.php

Spacing +8 added lines, -8 removed lines

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

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