WyriHaximus\Recoil\QueueCaller::call()

Complexity

Conditions	3
Paths	1

Size

Total Lines

20

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	12
CRAP Score	3.0261

Importance

Changes

0

<?php declare(strict_types=1);
    public function call(ObservableInterface $observable)
    {
        $this->kernel->execute(function () use ($observable) {
            yield;
            $observableWhile = observableWhile($observable);
            /** @var Call $call */
            while ($call = (yield $observableWhile->get())) {
                try {
                    $callable = $call->getCallable();
                    $arguments = $call->getArguments();
                    $value = yield $callable(...$arguments);
                    $call->resolve($value);
                } catch (\Throwable $et) {
                    $call->reject($et);
                } finally {
                    unset($callable, $arguments, $call);
                }
            }
        });
    }
}