Carno\Promise\Features\All::all()

Complexity

Conditions	7
Paths	3

Size

Total Lines	29
Code Lines	13

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	1

<?php
    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;
    }