bpolaszek / mercure-php-hub

src/Hub/Hub.php

Spacing +6 added lines, -6 removed lines

@@ -85,13 +85,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");
                 }
@@ -143,7 +143,7 @@ 
         return $this->transport->publish($topic, $message)
             ->then(fn() => $this->storage->storeMessage($topic, $message))
             ->then(
-                function () use ($topic, $message) {
+                function() use ($topic, $message) {
                     $this->logger()->debug(\sprintf('Created message %s on topic %s', $message->getId(), $topic));
                 }
             );
@@ -153,7 +153,7 @@ 
     {
         return $this->storage->storeSubscriptions($subscriptions)
             ->then(
-                function () use ($subscriptions) {
+                function() use ($subscriptions) {
                     $promises = [];
                     foreach ($subscriptions as $subscription) {
                         $promises[] = $this->transport->publish(
@@ -183,7 +183,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->handleClosingConnection($connection, $localAddress));
         });
@@ -239,7 +239,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/Storage/Redis/RedisStorage.php

Spacing +4 added lines, -4 removed lines

@@ -74,7 +74,7 @@ 
         /** @phpstan-ignore-next-line */
         return $this->async->keys($keyPattern)
             ->then(
-                function (array $keys) use ($topic) {
+                function(array $keys) use ($topic) {
                     $promises = [];
                     foreach ($keys as $key) {
                         $promises[] = $this->async->get($key); /** @phpstan-ignore-line */
@@ -82,7 +82,7 @@ 
 
                     return all($promises)->then(
                         fn(array $subscriptions) => \array_map(
-                            function (string $serialized) {
+                            function(string $serialized) {
                                 $data = \json_decode($serialized, true);
 
                                 return new Subscription(
@@ -95,9 +95,9 @@ 
                             $subscriptions
                         )
                     )
-                        ->then(function (array $subscriptions) use ($topic): iterable {
+                        ->then(function(array $subscriptions) use ($topic): iterable {
                             foreach ($subscriptions as $subscription) {
-                                $matchtopic = null === $topic ||  TopicMatcher::matchesTopicSelectors(
+                                $matchtopic = null === $topic || TopicMatcher::matchesTopicSelectors(
                                     $subscription->getTopic(),
                                     [$topic]
                                 );

src/Controller/SubscriptionsController.php

Spacing +2 added lines, -2 removed lines

@@ -37,10 +37,10 @@
 
         $stream = new ThroughStream();
         $this->hub->hook(
-            function () use ($stream, $path, $subscriber, $topic) {
+            function() use ($stream, $path, $subscriber, $topic) {
                 $this->hub->getActiveSubscriptions($subscriber, $topic)
                     ->then(
-                        function (iterable $subscriptions) use ($stream, $path) {
+                        function(iterable $subscriptions) use ($stream, $path) {
                             $result = [
                                 '@context' => 'https://mercure.rocks/',
                                 'id' => $path,