@@ -50,13 +50,13 @@ discard block |
||
| 50 | 50 | $localAddress = $this->config[Configuration::ADDR]; |
| 51 | 51 | $this->shutdownSignal = null; |
| 52 | 52 | $this->metricsHandler->resetUsers($localAddress); |
| 53 | - $this->loop->addSignal(SIGINT, function ($signal) { |
|
| 53 | + $this->loop->addSignal(SIGINT, function($signal) { |
|
| 54 | 54 | $this->stop($signal, $this->loop); |
| 55 | 55 | }); |
| 56 | 56 | $this->loop->addPeriodicTimer( |
| 57 | 57 | 15, |
| 58 | 58 | fn() => $this->metricsHandler->getNbUsers()->then( |
| 59 | - function (int $nbUsers) { |
|
| 59 | + function(int $nbUsers) { |
|
| 60 | 60 | $memory = \memory_get_usage(true) / 1024 / 1024; |
| 61 | 61 | $this->logger()->debug("Users: {$nbUsers} - Memory: {$memory}MB"); |
| 62 | 62 | } |
@@ -83,7 +83,7 @@ discard block |
||
| 83 | 83 | private function createSocketConnection(string $localAddress, LoopInterface $loop): Socket\Server |
| 84 | 84 | { |
| 85 | 85 | $socket = new Socket\Server($localAddress, $loop); |
| 86 | - $socket->on('connection', function (ConnectionInterface $connection) use ($localAddress) { |
|
| 86 | + $socket->on('connection', function(ConnectionInterface $connection) use ($localAddress) { |
|
| 87 | 87 | $this->metricsHandler->incrementUsers($localAddress); |
| 88 | 88 | $connection->on('close', fn() => $this->metricsHandler->decrementUsers($localAddress)); |
| 89 | 89 | }); |
@@ -108,7 +108,7 @@ discard block |
||
| 108 | 108 | private function stop(int $signal, LoopInterface $loop): void |
| 109 | 109 | { |
| 110 | 110 | $this->shutdownSignal = $signal; |
| 111 | - $loop->futureTick(function () use ($loop) { |
|
| 111 | + $loop->futureTick(function() use ($loop) { |
|
| 112 | 112 | $loop->stop(); |
| 113 | 113 | }); |
| 114 | 114 | } |