gyselroth / mongodb-php-task-scheduler

src/Queue.php

Spacing +2 added lines, -2 removed lines

@@ -286,7 +286,7 @@ 
                     break;
                 }
 
-                $this->jobs->next($cursor, function () {
+                $this->jobs->next($cursor, function() {
                     $this->main();
                 });
 
@@ -294,7 +294,7 @@ 
             }
 
             $job = $cursor->current();
-            $this->jobs->next($cursor, function () {
+            $this->jobs->next($cursor, function() {
                 $this->main();
             });
 

src/Scheduler.php

Spacing +2 added lines, -2 removed lines

@@ -373,7 +373,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);
                 });
 
@@ -381,7 +381,7 @@ 
             }
 
             $result = $cursor->current();
-            $this->events->next($cursor, function () use ($callback, $query) {
+            $this->events->next($cursor, function() use ($callback, $query) {
                 $this->listen($callback, $query);
             });
 

src/Worker.php

Spacing +2 added lines, -2 removed lines

@@ -134,7 +134,7 @@ 
                     break;
                 }
 
-                $this->jobs->next($cursor, function () {
+                $this->jobs->next($cursor, function() {
                     $this->main();
                 });
 
@@ -142,7 +142,7 @@ 
             }
 
             $job = $cursor->current();
-            $this->jobs->next($cursor, function () {
+            $this->jobs->next($cursor, function() {
                 $this->main();
             });
 

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();
             });