mpyw / co

src/Internal/Utils.php

Unused Use Statements -1 removed lines

@@ -2,7 +2,6 @@
 
 namespace mpyw\Co\Internal;
 
-use mpyw\Co\CoInterface;
 use mpyw\Co\Internal\GeneratorContainer;
 
 class Utils {

src/Co.php

Spacing +7 added lines, -7 removed lines

@@ -82,7 +82,7 @@ 
     {
         if (!self::$self) {
             throw new \BadMethodCallException(
-                'Co::async() must be called along with Co::wait(). ' .
+                'Co::async() must be called along with Co::wait(). '.
                 'This method is mainly expected to be used in CURLOPT_WRITEFUNCTION callback.'
             );
         }
@@ -104,7 +104,7 @@ 
     {
         $deferred = new Deferred;
         // For convenience, all values are wrapped into generator
-        $genfunc = function () use ($value, &$return) {
+        $genfunc = function() use ($value, &$return) {
             try {
                 $return = (yield $value);
             } catch (\RuntimeException $e) {
@@ -155,9 +155,9 @@ 
         if ($gc->key() === CoInterface::DELAY) {
             $dfd = new Deferred;
             $this->pool->addDelay($gc->current(), $dfd);
-            $dfd->promise()->then(function () use ($gc) {
+            $dfd->promise()->then(function() use ($gc) {
                 $gc->send(null);
-            })->always(function () use ($gc, $deferred) {
+            })->always(function() use ($gc, $deferred) {
                 $this->processGeneratorContainer($gc, $deferred);
             });
             return;
@@ -178,7 +178,7 @@ 
         $this->promiseAll($yieldables, $gc->throwAcceptable())->then(
             self::getApplier($yielded, $yieldables, [$gc, 'send']),
             [$gc, 'throw_']
-        )->always(function () use ($gc, $deferred) {
+        )->always(function() use ($gc, $deferred) {
             // Continue
             $this->processGeneratorContainer($gc, $deferred);
         });
@@ -192,7 +192,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) {
@@ -222,7 +222,7 @@ 
             if (!$throw_acceptable) {
                 $original_dfd = $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);