WyriHaximus\Recoil\QueueCaller::call()

Complexity

Conditions	3
Paths	1

Size

Total Lines

28

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	18
CRAP Score	3.009

Importance

Changes

0

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

        return $state;
    }
}