@@ -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 |