ObservableWhile::get() - Code Metrics - Inspection of "Merge pull request #5 from WyriHaximus/gc_collect_..." - WyriHaximus/php-rxphp-recoilphp-looper - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( ef6151...267260 )

by Cees-Jan

created 2019-01-06 21:19 UTC

ObservableWhile::get() A

↳ Parent: ObservableWhile

Complexity

Conditions	4
Paths	3

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	7
CRAP Score	4

Importance

Changes

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

<?php declare(strict_types=1);

namespace WyriHaximus\Rx;

use React\Promise\Deferred;
use React\Promise\PromiseInterface;
use Rx\ObservableInterface;
use function React\Promise\resolve;

final class ObservableWhile
{
    /**
     * @var \SplQueue
     */
    private $queue;

    /**
     * @var Deferred
     */
    private $deferred;

    /**
     * @var bool
     */
    private $done = false;

    /**
     * @param ObservableInterface $observable
     */
    public function __construct(ObservableInterface $observable)
    {
        $this->queue = new \SplQueue();
        $observable->subscribe(function ($item): void {
            if ($this->deferred instanceof Deferred) {
                $this->deferred->resolve($item);
                $this->deferred = null;

                return;
            }

            $this->queue[] = $item;
        }, null, function (): void {
            $this->done = true;

            if ($this->deferred instanceof Deferred) {
                $this->deferred->resolve();
                $this->deferred = null;
            }
        });
    }

    public function get(): PromiseInterface
    {
        if ($this->queue->count() === 0 && $this->done === true) {
            return resolve();
        }

        if ($this->queue->count() === 0) {
            $this->deferred = new Deferred();

            return $this->deferred->promise();
        }

        return resolve($this->queue->dequeue());
    }
}


1		<?php declare(strict_types=1);
2
3		namespace WyriHaximus\Rx;
4
5		use React\Promise\Deferred;
6		use React\Promise\PromiseInterface;
7		use Rx\ObservableInterface;
8		use function React\Promise\resolve;
9
10		final class ObservableWhile
11		{
12		/**
13		* @var \SplQueue
14		*/
15		private $queue;
16
17		/**
18		* @var Deferred
19		*/
20		private $deferred;
21
22		/**
23		* @var bool
24		*/
25		private $done = false;
26
27		/**
28		* @param ObservableInterface $observable
29		*/
30	3	public function __construct(ObservableInterface $observable)
31		{
32	3	$this->queue = new \SplQueue();
33		$observable->subscribe(function ($item): void {
34	2	if ($this->deferred instanceof Deferred) {
35	1	$this->deferred->resolve($item);
36	1	$this->deferred = null;
37
38	1	return;
39		}
40
41	1	$this->queue[] = $item;
42		}, null, function (): void {
43	3	$this->done = true;
44
45	3	if ($this->deferred instanceof Deferred) {
46	2	$this->deferred->resolve();
47	2	$this->deferred = null;
48		}
49	3	});
50	3	}
51
52	3	public function get(): PromiseInterface
53		{
54	3	if ($this->queue->count() === 0 && $this->done === true) {
55	1	return resolve();
56		}
57
58	3	if ($this->queue->count() === 0) {
59	2	$this->deferred = new Deferred();
60
61	2	return $this->deferred->promise();
62		}
63
64	1	return resolve($this->queue->dequeue());
65		}
66		}
67

WyriHaximus / php-rxphp-recoilphp-looper

GitHub Access Token became invalid

Push — master ( ef6151...267260 )

ObservableWhile::get() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like