mpyw / co

src/AllFailedException.php

Doc Comments -1 removed lines

@@ -10,7 +10,6 @@
      * Constructor.
      * @param string   $message Dummy.
      * @param int      $code    Dummy.
-     * @param mixed    $value   Value to be retrived.
      */
     public function __construct($message, $code, $reasons)
     {

src/Co.php

Doc Comments +3 added lines, -3 removed lines

@@ -279,7 +279,7 @@ 
      * If no yieldables found, AllFailedException is thrown.
      *
      * @param  mixed $value
-     * @return mixed Resolved value.
+     * @return \Generator Resolved value.
      * @throws AllFailedException
      */
     public static function any($value)
@@ -298,7 +298,7 @@ 
      * If no yieldables found, AllFailedException is thrown.
      *
      * @param  mixed $value
-     * @return mixed Resolved value.
+     * @return \Generator Resolved value.
      * @throws \RuntimeException|AllFailedException
      */
     public static function race($value)
@@ -318,7 +318,7 @@ 
      * You should use only with Co::race() or Co::any().
      *
      * @param  mixed $value
-     * @return mixed Resolved value.
+     * @return \Generator Resolved value.
      * @throws \RuntimeException
      */
     public static function all($value)

Unused Use Statements -2 removed lines

@@ -7,8 +7,6 @@
 use mpyw\Co\Internal\CoOption;
 use mpyw\Co\Internal\GeneratorContainer;
 use mpyw\Co\Internal\Pool;
-use mpyw\Co\Internal\ControlException;
-
 use mpyw\RuntimePromise\Deferred;
 use mpyw\RuntimePromise\PromiseInterface;
 

Spacing +4 added lines, -4 removed lines

@@ -166,7 +166,7 @@ 
                 YieldableUtils::getApplier($returned, $yieldables, [$deferred, 'resolve']),
                 [$deferred, 'reject']
             )
-            ->always(function () use ($yieldables) {
+            ->always(function() use ($yieldables) {
                 $this->runners = array_diff_key($this->runners, $yieldables);
             });
             return;
@@ -189,10 +189,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;
@@ -215,7 +215,7 @@ 
         ->then(
             YieldableUtils::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);

src/Internal/ControlUtils.php

Unused Use Statements -1 removed lines

@@ -1,7 +1,6 @@
 <?php
 
 namespace mpyw\Co\Internal;
-use mpyw\RuntimePromise\Deferred;
 use mpyw\Co\AllFailedException;
 use mpyw\Co\CoInterface;
 

src/Internal/YieldableUtils.php

Spacing +2 added lines, -2 removed lines

@@ -73,7 +73,7 @@ 
      */
     public static function getApplier($yielded, array $yieldables, callable $next = null)
     {
-        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) {
@@ -94,7 +94,7 @@ 
     public static function safeDeferred(Deferred $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);