teodoroleckie / async

src/Task.php

Spacing +1 added lines, -1 removed lines

@@ -71,7 +71,7 @@
         return $this;
     }
 
-    public function catch(callable $callback): self
+    public function catch (callable $callback): self
     {
         $this->error[] = $callback;
 

src/Async.php

Spacing +3 added lines, -3 removed lines

@@ -50,7 +50,7 @@ 
     )
     {
         $this->taskFactory = $taskFactory ?? new TaskFactory();
-        $this->encoder = $encoder?? new Encoder();
+        $this->encoder = $encoder ?? new Encoder();
         $this->sleep = $sleep;
 
         $this->listener();
@@ -60,9 +60,9 @@ 
     {
         pcntl_async_signals(true);
 
-        pcntl_signal(SIGCHLD, function ($signo, $status) {
+        pcntl_signal(SIGCHLD, function($signo, $status) {
             while (true) {
-                $pid = pcntl_waitpid(-1, $processState, WNOHANG | WUNTRACED);
+                $pid = pcntl_waitpid(-1, $processState, WNOHANG|WUNTRACED);
                 if ($pid <= 0) {
                     break;
                 }

src/TaskFactory.php

Spacing +2 added lines, -2 removed lines

@@ -45,7 +45,7 @@ 
                 __DIR__ . '/../../../vendor/autoload.php',
                 __DIR__ . '/../../vendor/autoload.php',
                 __DIR__ . '/../vendor/autoload.php',
-            ], static function (string $path) {
+            ], static function(string $path) {
                 return file_exists($path);
             });
             $this->autoloader = reset($paths);
@@ -67,7 +67,7 @@ 
                 __DIR__ . '/../bin/child',
                 __DIR__ . '/bin/child',
 
-            ], static function (string $path) {
+            ], static function(string $path) {
                 return file_exists($path);
             });
             $this->script = reset($paths);

src/TaskInterface.php

Spacing +1 added lines, -1 removed lines

@@ -41,7 +41,7 @@
      * @param callable $callback
      * @return mixed
      */
-    public function catch(callable $callback): self;
+    public function catch (callable $callback): self;
 
     /**
      * @return $this