Carno\Promise\Features\Race::race()

Complexity

Conditions	4
Paths	2

Size

Total Lines	28
Code Lines	13

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	1

<?php
    public static function race(Promised ...$promises) : Promised
    {
        /**
         * @var Promise $race
         */

        $race = Promise::deferred();

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

        foreach ($promises as $promise) {
            $promise->then(static function (...$args) use ($race, $sid) {
                if ($race->pended()) {
                    $race->resolve(...$args);
                    $race->rpInterrupt($sid);
                }
            }, static function (...$args) use ($race) {
                if ($race->pended()) {
                    $race->reject(...$args);
                }
            });
        }

        $race->then(null, static function (...$args) use ($race, $sid) {
            $race->rpInterrupt($sid, $race->rpException(...$args));

$args is expanded, but the parameter $test of Carno\Promise\Promise::rpException() does not expect variable arguments.

        });

        return $race;
    }