ackintosh / snidel

src/Snidel.php

Spacing +6 added lines, -6 removed lines

@@ -39,7 +39,7 @@ 
         $this->coordinator = new Coordinator($this->config, $this->log);
         $this->coordinator->forkMaster();
         $this->registerSignalHandler($this->coordinator, $this->log);
-        $this->log->info('parent pid: ' . $this->config->get('ownerPid'));
+        $this->log->info('parent pid: '.$this->config->get('ownerPid'));
     }
 
     /**
@@ -52,11 +52,11 @@ 
         try {
             $this->coordinator->enqueue(new Task($callable, $args, $tag));
         } catch (RuntimeException $e) {
-            $this->log->error('failed to enqueue the task: ' . $e->getMessage());
+            $this->log->error('failed to enqueue the task: '.$e->getMessage());
             throw $e;
         }
 
-        $this->log->info('queued task #' . $this->coordinator->queuedCount());
+        $this->log->info('queued task #'.$this->coordinator->queuedCount());
     }
 
     /**
@@ -72,7 +72,7 @@ 
      */
     public function results(): \Generator
     {
-        foreach($this->coordinator->results() as $r) {
+        foreach ($this->coordinator->results() as $r) {
             pcntl_signal_dispatch();
             yield $r;
         }
@@ -98,8 +98,8 @@ 
         foreach ($this->signals as $sig) {
             $pcntl->signal(
                 $sig,
-                function ($sig) use ($log, $coordinator) {
-                    $log->info('received signal. signo: ' . $sig);
+                function($sig) use ($log, $coordinator) {
+                    $log->info('received signal. signo: '.$sig);
                     $log->info('--> sending a signal " to children.');
                     $coordinator->sendSignalToMaster($sig);
                     $log->info('<-- signal handling has been completed successfully.');