mpyw / co

src/Co.php

Spacing +6 added lines, -6 removed lines

@@ -163,7 +163,7 @@ 
                 self::getApplier($returned, $yieldables, [$deferred, 'resolve']),
                 [$deferred, 'reject']
             )
-            ->always(function () use ($yieldables) {
+            ->always(function() use ($yieldables) {
                 $this->runners = array_diff_key($this->runners, $yieldables);
             });
             return;
@@ -186,10 +186,10 @@ 
             $this->pool->addDelay($gc->current(), $dfd);
             $dfd
             ->promise()
-            ->then(function () use ($gc) {
+            ->then(function() use ($gc) {
                 $gc->send(null);
             })
-            ->always(function () use ($gc, $deferred) {
+            ->always(function() use ($gc, $deferred) {
                 $this->processGeneratorContainer($gc, $deferred);
             });
             return;
@@ -212,7 +212,7 @@ 
         ->then(
             self::getApplier($yielded, $yieldables, [$gc, 'send']),
             [$gc, 'throw_']
-        )->always(function () use ($gc, $deferred, $yieldables) {
+        )->always(function() use ($gc, $deferred, $yieldables) {
             // Continue
             $this->runners = array_diff_key($this->runners, $yieldables);
             $this->processGeneratorContainer($gc, $deferred);
@@ -247,7 +247,7 @@ 
      */
     private static function getApplier($yielded, $yieldables, callable $next)
     {
-        return function (array $results) use ($yielded, $yieldables, $next) {
+        return function(array $results) use ($yielded, $yieldables, $next) {
             foreach ($results as $hash => $resolved) {
                 $current = &$yielded;
                 foreach ($yieldables[$hash]['keylist'] as $key) {
@@ -299,7 +299,7 @@ 
     private static function deferredSafe($original_dfd)
     {
         $dfd = new Deferred;
-        $absorber = function ($any) use ($original_dfd) {
+        $absorber = function($any) use ($original_dfd) {
             $original_dfd->resolve($any);
         };
         $dfd->promise()->then($absorber, $absorber);