carno-php / channel

src/Worker.php

Spacing +5 added lines, -5 removed lines

@@ -67,12 +67,12 @@ 
         $this->program = $program;
         $this->failure = $failure;
 
-        $this->processor = function ($data, Context $ctx = null) {
+        $this->processor = function($data, Context $ctx = null) {
             async($this->program, $ctx ?? new Context(), $data)->then($this->done, $this->done);
         };
 
-        $this->done = function ($e = null) {
-            $this->running --;
+        $this->done = function($e = null) {
+            $this->running--;
 
             if ($this->failure && $e instanceof Throwable) {
                 ($this->failure)($e);
@@ -81,7 +81,7 @@ 
             $this->execute();
         };
 
-        $this->close = function () {
+        $this->close = function() {
             $this->closing = true;
         };
 
@@ -105,7 +105,7 @@ 
                 return;
             }
 
-            $this->running ++;
+            $this->running++;
 
             ($recv = $this->chan->recv())->then($this->processor, $this->close);