ObservableWhile::__construct() - Code Metrics - Inspection of "each => while" - WyriHaximus/php-rxphp-recoilphp-looper - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( b04c59...4ec6fa )

by Cees-Jan

created 2018-07-14 17:46 UTC

ObservableWhile::__construct() A

↳ Parent: ObservableWhile

Complexity

Conditions	2
Paths	1

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	6
CRAP Score	2.1481

Importance

Changes

Metric	Value
cc	2
nc	1
nop	1
dl	0
loc	15
ccs	6
cts	9
cp	0.6667
crap	2.1481
rs	9.7666
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 array
     */
    private $queue = [];

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

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

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

                return;
            }

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

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

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

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

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


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 array
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		public function __construct(ObservableInterface $observable)
31		{
32	1	$observable->subscribe(function ($item) {
33	1	if ($this->deferred instanceof Deferred) {
34		$this->deferred->resolve($item);
35		$this->deferred = null;
36
37		return;
38		}
39
40	1	$this->queue[] = $item;
41		}, null, function () {
42	1	$this->done = true;
43	1	});
44	1	}
45
46	1	public function get(): PromiseInterface
47		{
48	1	if (count($this->queue) === 0 && $this->done === true) {
49	1	return resolve();
50		}
51
52	1	if (count($this->queue) === 0) {
53		$this->deferred = new Deferred();
54
55		return $this->deferred->promise();
56		}
57
58	1	return resolve(array_shift($this->queue));
59		}
60		}
61

WyriHaximus / php-rxphp-recoilphp-looper

GitHub Access Token became invalid

Push — master ( b04c59...4ec6fa )

ObservableWhile::__construct() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like