gyselroth / mongodb-php-task-scheduler

src/Process.php

Spacing +2 added lines, -2 removed lines

@@ -119,7 +119,7 @@ 
                     return $this->wait();
                 }
 
-                $this->events->next($cursor, function () {
+                $this->events->next($cursor, function() {
                     $this->wait();
                 });
 
@@ -127,7 +127,7 @@ 
             }
 
             $event = $cursor->current();
-            $this->events->next($cursor, function () {
+            $this->events->next($cursor, function() {
                 $this->wait();
             });
 

src/Worker.php

Indentation +1 added lines, -1 removed lines

@@ -288,7 +288,7 @@
     protected function collectJob(array $job, int $status, $from_status = JobInterface::STATUS_WAITING): bool
     {
         $set = [
-             'status' => $status,
+                'status' => $status,
         ];
 
         if (JobInterface::STATUS_PROCESSING === $status) {

Spacing +2 added lines, -2 removed lines

@@ -207,7 +207,7 @@ 
                     break;
                 }
 
-                $this->jobs->next($cursor, function () {
+                $this->jobs->next($cursor, function() {
                     $this->processAll();
                 });
 
@@ -220,7 +220,7 @@ 
                 'category' => get_class($this),
             ]);
 
-            $this->jobs->next($cursor, function () {
+            $this->jobs->next($cursor, function() {
                 $this->processAll();
             });
 

src/Queue.php

Spacing +5 added lines, -5 removed lines

@@ -189,17 +189,17 @@ 
                         break;
                     }
 
-                    $this->events->next($cursor_events, function () {
+                    $this->events->next($cursor_events, function() {
                         $this->main();
                     });
                 }
 
                 $event = $cursor_events->current();
-                $this->events->next($cursor_events, function () {
+                $this->events->next($cursor_events, function() {
                     $this->main();
                 });
 
-                if($event === null) {
+                if ($event === null) {
                     break;
                 }
 
@@ -218,7 +218,7 @@ 
                     break;
                 }
 
-                $this->jobs->next($cursor_jobs, function () {
+                $this->jobs->next($cursor_jobs, function() {
                     $this->main();
                 });
 
@@ -227,7 +227,7 @@ 
 
             $job = $cursor_jobs->current();
 
-            $this->jobs->next($cursor_jobs, function () {
+            $this->jobs->next($cursor_jobs, function() {
                 $this->main();
             });
 

src/Scheduler.php

Spacing +7 added lines, -7 removed lines

@@ -394,10 +394,10 @@ 
      *
      * @param Process[] $stack
      */
-    public function waitFor(array $stack, int $options=0): Scheduler
+    public function waitFor(array $stack, int $options = 0): Scheduler
     {
         $jobs = array_map(function($job) {
-            if(!($job instanceof Process)) {
+            if (!($job instanceof Process)) {
                 throw new InvalidArgumentException('waitFor() requires a stack of Process[]');
             }
 
@@ -420,7 +420,7 @@ 
                     return $this->waitFor($stack, $options);
                 }
 
-                $this->events->next($cursor, function () use($stack, $options) {
+                $this->events->next($cursor, function() use($stack, $options) {
                     $this->waitFor($stack, $options);
                 });
 
@@ -428,7 +428,7 @@ 
             }
 
             $event = $cursor->current();
-            $this->events->next($cursor, function () use($stack, $options) {
+            $this->events->next($cursor, function() use($stack, $options) {
                 $this->waitFor($stack, $options);
             });
 
@@ -441,7 +441,7 @@ 
 
             $done++;
 
-            if($done >= $expected) {
+            if ($done >= $expected) {
                 return $this;
             }
         }
@@ -472,7 +472,7 @@ 
                     return $this->listen($callback, $query);
                 }
 
-                $this->events->next($cursor, function () use ($callback, $query) {
+                $this->events->next($cursor, function() use ($callback, $query) {
                     return $this->listen($callback, $query);
                 });
 
@@ -480,7 +480,7 @@ 
             }
 
             $result = $cursor->current();
-            $this->events->next($cursor, function () use ($callback, $query) {
+            $this->events->next($cursor, function() use ($callback, $query) {
                 $this->listen($callback, $query);
             });