@@ -28,7 +28,7 @@ discard block |
||
| 28 | 28 | |
| 29 | 29 | public function run(int $idleTimeout = 1): void |
| 30 | 30 | { |
| 31 | - Loop::setErrorHandler(function (\Throwable $e) { |
|
| 31 | + Loop::setErrorHandler(function(\Throwable $e) { |
|
| 32 | 32 | $this->logger->critical($e->getMessage()); |
| 33 | 33 | throw $e; |
| 34 | 34 | }); |
@@ -36,7 +36,7 @@ discard block |
||
| 36 | 36 | Loop::run(function() use ($idleTimeout) { |
| 37 | 37 | $pool = new DefaultPool(); |
| 38 | 38 | |
| 39 | - Loop::repeat(100, function () use ($pool, $idleTimeout) { |
|
| 39 | + Loop::repeat(100, function() use ($pool, $idleTimeout) { |
|
| 40 | 40 | if (!$queueTask = $this->queue->take($idleTimeout)) { |
| 41 | 41 | $this->logger->debug('Idling...'); |
| 42 | 42 | |