QueueCaller::__construct() - Code Metrics - WyriHaximus/recoilphp-queue-caller - Measure and Improve Code Quality continuously with Scrutinizer

QueueCaller::__construct() A
last analyzed 2020-01-01 19:45 UTC

↳ Parent: QueueCaller

Complexity

Conditions	1
Paths	1

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	3
CRAP Score	1

Importance

Changes

Metric	Value
dl	0
loc	4
ccs	3
cts	3
cp	1
rs	10
c	0
b	0
f	0
cc	1
nc	1
nop	1
crap	1

<?php declare(strict_types=1);

namespace WyriHaximus\Recoil;

use Recoil\Kernel;
use Rx\ObservableInterface;
use function WyriHaximus\Rx\observableWhile;

final class QueueCaller implements QueueCallerInterface
{
    /**
     * @var Kernel
     */
    private $kernel;

    /**
     * @param Kernel $kernel
     */
    public function __construct(Kernel $kernel)
    {
        $this->kernel = $kernel;
    }

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


1		<?php declare(strict_types=1);
2
3		namespace WyriHaximus\Recoil;
4
5		use Recoil\Kernel;
6		use Rx\ObservableInterface;
7		use function WyriHaximus\Rx\observableWhile;
8
9		final class QueueCaller implements QueueCallerInterface
10		{
11		/**
12		* @var Kernel
13		*/
14		private $kernel;
15
16		/**
17		* @param Kernel $kernel
18		*/
19	1	public function __construct(Kernel $kernel)
20		{
21	1	$this->kernel = $kernel;
22	1	}
23
24	1	public function call(ObservableInterface $observable): State
25		{
26	1	$state = new State();
27		$this->kernel->execute(function () use ($observable, $state) {
28	1	$state->onNext(State::STARTED);
29	1	yield;
30	1	$observableWhile = observableWhile($observable);
31	1	$state->onNext(State::WAITING);
32		/** @var Call $call */
33	1	while ($call = (yield $observableWhile->get())) {
34		try {
35	1	$state->onNext(State::BUSY);
36	1	$callable = $call->getCallable();
37	1	$arguments = $call->getArguments();
38	1	$value = yield $callable(...$arguments);
39	1	$call->resolve($value);
40		} catch (\Throwable $et) {
41		$call->reject($et);
42	1	} finally {
43	1	unset($callable, $arguments, $call);
44	1	$state->onNext(State::WAITING);
45		}
46		}
47	1	$state->onNext(State::DONE);
48	1	});
49
50	1	return $state;
51		}
52		}
53

WyriHaximus / recoilphp-queue-caller

GitHub Access Token became invalid

QueueCaller::__construct() A last analyzed 2020-01-01 19:45 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

QueueCaller::__construct() A
last analyzed 2020-01-01 19:45 UTC