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