mpyw / co

src/Co.php

Unused Use Statements -1 removed lines

@@ -5,7 +5,6 @@
 use mpyw\Co\Internal\CoOption;
 use mpyw\Co\Internal\GeneratorContainer;
 use mpyw\Co\Internal\CURLPool;
-
 use React\Promise\Deferred;
 use React\Promise\PromiseInterface;
 use function React\Promise\all;

Spacing +9 added lines, -9 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.'
             );
         }
@@ -105,15 +105,15 @@ 
         $return = $exception = null;
         $deferred = new Deferred;
         $deferred->promise()->then(
-            function ($r) use (&$return) {
+            function($r) use (&$return) {
                 $return = $r;
             },
-            function ($e) use (&$exception) {
+            function($e) use (&$exception) {
                 $exception = $e;
             }
         );
         // For convenience, all values are wrapped into generator
-        $genfunc = function () use ($value) {
+        $genfunc = function() use ($value) {
             yield CoInterface::RETURN_WITH => (yield $value);
         };
         $con = Utils::normalize($genfunc, $this->options);
@@ -170,9 +170,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;
@@ -202,7 +202,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);
         });
@@ -216,7 +216,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) {
@@ -245,7 +245,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);

src/Internal/GeneratorContainer.php

Doc Comments +2 added lines, -2 removed lines

@@ -32,7 +32,7 @@ 
 
     /**
      * Constructor.
-     * @param Generator $g
+     * @param \Generator $g
      * @param CoOption  $options
      * @param mixed     $yield_key
      */
@@ -124,7 +124,7 @@ 
 
     /**
      * Throw exception into generator.
-     * @param RuntimeException $e
+     * @param \RuntimeException $e
      * @NOTE: This method returns nothing,
      *        while original generator returns something.
      */

src/Internal/CURLPool.php

Spacing +1 added lines, -1 removed lines

@@ -68,7 +68,7 @@
         }
         $errno = curl_multi_add_handle($this->mh, $ch);
         if ($errno !== CURLM_OK) {
-            $msg = curl_multi_strerror($errno) . ": $ch";
+            $msg = curl_multi_strerror($errno).": $ch";
             $deferred->reject(new \RuntimeException($msg));
             return;
         }

src/Internal/CoOption.php

Spacing +2 added lines, -2 removed lines

@@ -88,7 +88,7 @@ 
     public function offsetGet($offset)
     {
         if (!isset($this->options[$offset])) {
-            throw new \DomainException('Undefined field: ' + $offset);
+            throw new \DomainException('Undefined field: ' +$offset);
         }
         return $this->options[$offset];
     }
@@ -125,7 +125,7 @@ 
             if (!isset(self::$types[$key])) {
                 throw new \InvalidArgumentException("Unknown option: $key");
             }
-            $validator = [__CLASS__, 'validate' . self::$types[$key]];
+            $validator = [__CLASS__, 'validate'.self::$types[$key]];
             $options[$key] = $validator($key, $value);
         }
         return $options;