tarantool-php / jobqueue

src/Runner/Amp/ParallelRunner.php

Spacing +2 added lines, -2 removed lines

@@ -28,7 +28,7 @@ 
 
     public function run(int $idleTimeout = 1): void
     {
-        Loop::setErrorHandler(function (\Throwable $e) {
+        Loop::setErrorHandler(function(\Throwable $e) {
             $this->logger->critical($e->getMessage());
             throw $e;
         });
@@ -37,7 +37,7 @@ 
             $pool = new DefaultPool();
             $pool->start();
 
-            Loop::repeat(100, function () use ($pool, $idleTimeout) {
+            Loop::repeat(100, function() use ($pool, $idleTimeout) {
                 if (!$queueTask = $this->queue->take($idleTimeout)) {
                     $this->logger->debug('Idling...');
 

examples/executors.php

Spacing +1 added lines, -1 removed lines

@@ -8,7 +8,7 @@
 
 $container = require __DIR__.'/container.php';
 
-$callback = function ($payload) use ($container) {
+$callback = function($payload) use ($container) {
     $container['logger']->info(strrev($payload));
 };
 

examples/container.php

Spacing +4 added lines, -4 removed lines

@@ -10,8 +10,8 @@ 
     'logger.file' => __DIR__.'/worker.log',
 ]);
 
-$container['job.greet'] = function ($c) {
-    return function (string $name, Logger $logger) use ($c) {
+$container['job.greet'] = function($c) {
+    return function(string $name, Logger $logger) use ($c) {
         $text = $name ? 'Hello '.$name : 'Hello';
 
         if ($c['job.greet.yell']) {
@@ -22,11 +22,11 @@ 
     };
 };
 
-$container['logger'] = function ($c) {
+$container['logger'] = function($c) {
     return new MonologLogger('worker', [new StreamHandler($c['logger.file'])]);
 };
 
-$container['autowired_job_args'] = function ($c) {
+$container['autowired_job_args'] = function($c) {
     return [
         'logger' => $c['logger'],
     ];