All::apResolving() - Code Metrics - carno-php/promise - Measure and Improve Code Quality continuously with Scrutinizer

All::apResolving() A
last analyzed 2019-07-26 02:30 UTC

↳ Parent: All

Complexity

Conditions	4
Paths	6

Size

Total Lines	6
Code Lines	3

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	1

Metric	Value
cc	4
eloc	3
c	1
b	0
f	1
nc	6
nop	3
dl	0
loc	6
rs	10

<?php
/**
 * All
 * User: moyo
 * Date: 04/08/2017
 * Time: 11:04 AM
 */

namespace Carno\Promise\Features;

use Carno\Promise\Promise;
use Carno\Promise\Promised;
use Carno\Promise\Stacked;

trait All
{
    /**
     * @var array
     */
    private $resolved = [];

    /**
     * @param Promised ...$promises
     * @return Promised
     */
    public static function all(Promised ...$promises) : Promised
    {
        if (empty($promises)) {
            return Promise::resolved();
        }

        /**
         * @var Promise $all
         */

        $all = Promise::deferred();

        $sid = Stacked::in(...$promises);

        foreach ($promises as $pid => $promise) {
            $promise->then(static function (...$args) use ($all, $sid, $pid) {
                $all->pended() && $all->apResolving($sid, $pid, ...$args);
            }, static function (...$args) use ($all) {
                $all->pended() && $all->reject(...$args);
            });
        }

        $all->then(null, static function (...$args) use ($sid) {
            foreach (Stacked::out($sid) as $promise) {
                $promise->pended() && $promise->reject(...$args);
            }
        });

        return $all;
    }

    /**
     * @param int $sid
     * @param int $pid
     * @param mixed ...$args
     */
    private function apResolving(int $sid, int $pid, ...$args)
    {
        $this->resolved[$pid] = count($args) > 1 ? $args : current($args);

        if (count($this->resolved) === Stacked::num($sid)) {
            Stacked::out($sid) && $this->resolve($this->resolved);
            Stacked::out($sid) && $this->/** @scrutinizer ignore-call */ resolve($this->resolved);
        }
    }
}


carno-php / promise

All::apResolving() A last analyzed 2019-07-26 02:30 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

All::apResolving() A
last analyzed 2019-07-26 02:30 UTC