@@ -114,7 +114,7 @@ |
||
114 | 114 | $topicSelector, |
115 | 115 | fn(string $topic, Message $message) => $this->sendIfAllowed($topic, $message, $request, $stream) |
116 | 116 | ) |
117 | - ->then(function (string $topic) use ($request) { |
|
117 | + ->then(function(string $topic) use ($request) { |
|
118 | 118 | $clientId = $request->getAttribute('clientId'); |
119 | 119 | $this->logger()->debug("Client {$clientId} subscribed to {$topic}"); |
120 | 120 | }); |
@@ -51,7 +51,7 @@ |
||
51 | 51 | |
52 | 52 | $this->transport |
53 | 53 | ->publish($input['topic'], $message) |
54 | - ->then(fn () => $this->storage->storeMessage($input['topic'], $message)); |
|
54 | + ->then(fn() => $this->storage->storeMessage($input['topic'], $message)); |
|
55 | 55 | |
56 | 56 | $this->logger()->debug( |
57 | 57 | \sprintf( |
@@ -13,7 +13,7 @@ |
||
13 | 13 | /** @phpstan-ignore-next-line */ |
14 | 14 | $client->get('foo')->then( |
15 | 15 | null, |
16 | - function (\Exception $e) use ($loop, $logger) { |
|
16 | + function(\Exception $e) use ($loop, $logger) { |
|
17 | 17 | $logger->error(\sprintf('Redis error: %s', $e->getMessage())); |
18 | 18 | $loop->stop(); |
19 | 19 | } |
@@ -46,7 +46,7 @@ discard block |
||
46 | 46 | $this->subscriber->subscribe($topicSelector); |
47 | 47 | $this->subscriber->on( |
48 | 48 | 'message', |
49 | - function (string $topic, string $payload) use ($topicSelector, $callback) { |
|
49 | + function(string $topic, string $payload) use ($topicSelector, $callback) { |
|
50 | 50 | $this->dispatch($topic, $payload, $topicSelector, $callback); |
51 | 51 | } |
52 | 52 | ); |
@@ -74,7 +74,7 @@ discard block |
||
74 | 74 | $this->subscriber->psubscribe($channel); |
75 | 75 | $this->subscriber->on( |
76 | 76 | 'pmessage', |
77 | - function (string $pattern, string $topic, string $payload) use ($topicSelector, $callback) { |
|
77 | + function(string $pattern, string $topic, string $payload) use ($topicSelector, $callback) { |
|
78 | 78 | $this->dispatch($topic, $payload, $topicSelector, $callback); |
79 | 79 | } |
80 | 80 | ); |
@@ -28,7 +28,7 @@ |
||
28 | 28 | |
29 | 29 | public function subscribe(string $subscribedTopic, callable $callback): PromiseInterface |
30 | 30 | { |
31 | - $this->emitter->on('message', function (string $topic, Message $message) use ($callback, $subscribedTopic) { |
|
31 | + $this->emitter->on('message', function(string $topic, Message $message) use ($callback, $subscribedTopic) { |
|
32 | 32 | if (!TopicMatcher::matchesTopicSelectors($topic, [$subscribedTopic])) { |
33 | 33 | return; |
34 | 34 | } |
@@ -43,13 +43,13 @@ |
||
43 | 43 | /** @phpstan-ignore-next-line */ |
44 | 44 | return $this->client->keys('users:*') |
45 | 45 | ->then( |
46 | - function (array $keys) { |
|
46 | + function(array $keys) { |
|
47 | 47 | $promises = []; |
48 | 48 | foreach ($keys as $key) { |
49 | 49 | $promises[] = $this->client->get($key); /** @phpstan-ignore-line */ |
50 | 50 | } |
51 | 51 | |
52 | - return all($promises)->then(fn (array $results): int => \array_sum($results)); |
|
52 | + return all($promises)->then(fn(array $results): int => \array_sum($results)); |
|
53 | 53 | } |
54 | 54 | ); |
55 | 55 | } |
@@ -63,7 +63,7 @@ |
||
63 | 63 | $url = $url->withQuery($qs); |
64 | 64 | $nbSubscribers = (int) $input->getOption('subscribers'); |
65 | 65 | |
66 | - $requests = function (HttpClientInterface $client, string $url) use ($nbSubscribers) { |
|
66 | + $requests = function(HttpClientInterface $client, string $url) use ($nbSubscribers) { |
|
67 | 67 | for ($i = 0; $i < $nbSubscribers; $i++) { |
68 | 68 | yield $client->request('GET', $url); |
69 | 69 | } |
@@ -38,10 +38,10 @@ discard block |
||
38 | 38 | $promises = [ |
39 | 39 | 'async' => $factory->createClient($dsn) |
40 | 40 | ->then( |
41 | - function (AsynchronousClient $client) { |
|
41 | + function(AsynchronousClient $client) { |
|
42 | 42 | $client->on( |
43 | 43 | 'close', |
44 | - function () { |
|
44 | + function() { |
|
45 | 45 | $this->logger()->error('Connection closed.'); |
46 | 46 | $this->loop->stop(); |
47 | 47 | } |
@@ -49,7 +49,7 @@ discard block |
||
49 | 49 | |
50 | 50 | return $client; |
51 | 51 | }, |
52 | - function (\Exception $exception) { |
|
52 | + function(\Exception $exception) { |
|
53 | 53 | $this->loop->stop(); |
54 | 54 | $this->logger()->error($exception->getMessage()); |
55 | 55 | } |
@@ -59,7 +59,7 @@ discard block |
||
59 | 59 | |
60 | 60 | return all($promises) |
61 | 61 | ->then( |
62 | - function (iterable $results): array { |
|
62 | + function(iterable $results): array { |
|
63 | 63 | $clients = []; |
64 | 64 | foreach ($results as $key => $client) { |
65 | 65 | $clients[$key] = $client; |
@@ -72,7 +72,7 @@ discard block |
||
72 | 72 | } |
73 | 73 | ) |
74 | 74 | ->then( |
75 | - fn (array $clients): RedisStorage => new RedisStorage( |
|
75 | + fn(array $clients): RedisStorage => new RedisStorage( |
|
76 | 76 | $clients['async'], |
77 | 77 | $clients['sync'], |
78 | 78 | ) |
@@ -47,13 +47,13 @@ discard block |
||
47 | 47 | $localAddress = $this->config[Configuration::ADDR]; |
48 | 48 | $this->shutdownSignal = null; |
49 | 49 | $this->metricsHandler->resetUsers($localAddress); |
50 | - $loop->addSignal(SIGINT, function ($signal) use ($loop) { |
|
50 | + $loop->addSignal(SIGINT, function($signal) use ($loop) { |
|
51 | 51 | $this->stop($signal, $loop); |
52 | 52 | }); |
53 | 53 | $loop->addPeriodicTimer( |
54 | 54 | 15, |
55 | 55 | fn() => $this->metricsHandler->getNbUsers()->then( |
56 | - function (int $nbUsers) { |
|
56 | + function(int $nbUsers) { |
|
57 | 57 | $memory = \memory_get_usage(true) / 1024 / 1024; |
58 | 58 | $this->logger()->debug("Users: {$nbUsers} - Memory: {$memory}MB"); |
59 | 59 | } |
@@ -80,7 +80,7 @@ discard block |
||
80 | 80 | private function createSocketConnection(string $localAddress, LoopInterface $loop): Socket\Server |
81 | 81 | { |
82 | 82 | $socket = new Socket\Server($localAddress, $loop); |
83 | - $socket->on('connection', function (ConnectionInterface $connection) use ($localAddress) { |
|
83 | + $socket->on('connection', function(ConnectionInterface $connection) use ($localAddress) { |
|
84 | 84 | $this->metricsHandler->incrementUsers($localAddress); |
85 | 85 | $connection->on('close', fn() => $this->metricsHandler->decrementUsers($localAddress)); |
86 | 86 | }); |
@@ -105,7 +105,7 @@ discard block |
||
105 | 105 | private function stop(int $signal, LoopInterface $loop): void |
106 | 106 | { |
107 | 107 | $this->shutdownSignal = $signal; |
108 | - $loop->futureTick(function () use ($loop) { |
|
108 | + $loop->futureTick(function() use ($loop) { |
|
109 | 109 | $loop->stop(); |
110 | 110 | }); |
111 | 111 | } |