carno-php / coroutine

benchmark.php

Spacing +3 added lines, -3 removed lines

@@ -8,10 +8,10 @@
 
 $begin = microtime(true);
 
-for ($r = 0; $r < 102400; $r ++) {
-    new Job((function () {
+for ($r = 0; $r < 102400; $r++) {
+    new Job((function() {
         yield 111;
-        yield (function () {
+        yield (function() {
             yield 'hello';
             return 'world';
         })();

src/Job.php

Spacing +3 added lines, -3 removed lines

@@ -103,7 +103,7 @@ 
 
         $this->chain = new SplStack;
 
-        ($this->ender = Promise::deferred())->catch(function (...$args) {
+        ($this->ender = Promise::deferred())->catch(function(...$args) {
             $this->killed(...$args);
         });
 
@@ -224,9 +224,9 @@ 
     {
         $this->sleep = $await;
 
-        $await->then(function ($r = null) {
+        $await->then(function($r = null) {
             $this->wakeup($r);
-        }, function (Throwable $e = null) {
+        }, function(Throwable $e = null) {
             $this->wakeup($e ?? new RejectedException);
         });
 

src/Job/IDGen.php

Spacing +1 added lines, -1 removed lines

@@ -20,6 +20,6 @@
      */
     public static function next() : int
     {
-        return self::$current ++ >= PHP_INT_MAX ? self::$current = 1 : self::$current;
+        return self::$current++ >= PHP_INT_MAX ? self::$current = 1 : self::$current;
     }
 }

src/Job/Creator.php

Spacing +1 added lines, -1 removed lines

@@ -43,7 +43,7 @@
      */
     public static function promises(array $programs, Context $ctx = null) : array
     {
-        return array_map(static function ($program) use ($ctx) {
+        return array_map(static function($program) use ($ctx) {
             return self::promised($program, [], $ctx);
         }, $programs);
     }

src/Stats.php

Spacing +2 added lines, -2 removed lines

@@ -27,13 +27,13 @@
      */
     public static function created() : void
     {
-        self::$running ++;
+        self::$running++;
     }
 
     /**
      */
     public static function finished() : void
     {
-        self::$running --;
+        self::$running--;
     }
 }

src/cmds.php

Spacing +11 added lines, -11 removed lines

@@ -29,10 +29,10 @@ 
 ) : Promised {
     $racer = Promise::deferred();
     if ($ms > 0) {
-        $timer = Timer::after($ms, static function () use ($racer, $ec, $em) {
+        $timer = Timer::after($ms, static function() use ($racer, $ec, $em) {
             $racer->throw(new $ec($em));
         });
-        $racer->catch(static function () use ($timer) {
+        $racer->catch(static function() use ($timer) {
             Timer::clear($timer);
         });
     }
@@ -49,11 +49,11 @@ 
     int $ms,
     Closure $do = null
 ) : Promised {
-    return new Promise(static function (Promised $promised) use ($ms, $do) {
-        $tick = Timer::after($ms, static function () use ($promised, $do) {
+    return new Promise(static function(Promised $promised) use ($ms, $do) {
+        $tick = Timer::after($ms, static function() use ($promised, $do) {
             $promised->resolve($do ? $do() : null);
         });
-        $promised->catch(static function () use ($tick) {
+        $promised->catch(static function() use ($tick) {
             Timer::clear($tick);
         });
     });
@@ -77,7 +77,7 @@ 
  */
 function co($program, Context $ctx = null) : Closure
 {
-    return static function (...$args) use ($program, $ctx) {
+    return static function(...$args) use ($program, $ctx) {
         return async($program, $ctx, ...$args)->fusion();
     };
 }
@@ -111,8 +111,8 @@ 
     string $message = ''
 ) : Promised {
     return race(
-        new Promise(static function (Promised $await) use ($dial, $awake) {
-            $dial(static function (...$args) use ($await, $awake) {
+        new Promise(static function(Promised $await) use ($dial, $awake) {
+            $dial(static function(...$args) use ($await, $awake) {
                 try {
                     $await->pended() && $out = $awake(...$args);
                     $await->pended() && $await->resolve($out ?? null);
@@ -130,7 +130,7 @@ 
  */
 function ctx() : Syscall
 {
-    return new Syscall(static function (Job $job) {
+    return new Syscall(static function(Job $job) {
         return $job->ctx();
     });
 }
@@ -141,8 +141,8 @@ 
  */
 function defer(Closure $program) : Syscall
 {
-    return new Syscall(static function (Job $job) use ($program) {
-        $job->roll()->then(static function ($stage) use ($job, $program) {
+    return new Syscall(static function(Job $job) use ($program) {
+        $job->roll()->then(static function($stage) use ($job, $program) {
             co($program, $job->ctx())($stage);
         });
     });