carno-php / channel

src/Worker.php

Spacing +5 added lines, -5 removed lines

@@ -59,16 +59,16 @@ 
         $this->chan = $chan;
         $this->program = $program;
 
-        $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 () {
-            $this->running --;
+        $this->done = function() {
+            $this->running--;
             $this->execute();
         };
 
-        $this->close = function () {
+        $this->close = function() {
             $this->closing = true;
         };
 
@@ -92,7 +92,7 @@ 
                 return;
             }
 
-            $this->running ++;
+            $this->running++;
 
             ($recv = $this->chan->recv())->then($this->processor, $this->close);