functions.php ➔ observableFromArray() - Code Metrics - Inspection of "Simple Observable::fromArray that injects an immed..." - php-api-clients/rx - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( 616b6e...e5fc41 )

by Cees-Jan

created 2017-05-07 16:23 UTC

functions.php ➔ observableFromArray() A

↳ Parent: Project

Complexity

Conditions	1
Paths	1

Size

Total Lines	4
Code Lines	2

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	1
eloc	2
nc	1
nop	1
dl	0
loc	4
rs	10
c	0
b	0
f	0

<?php declare(strict_types=1);

namespace ApiClients\Tools\Rx;

use React\Promise\PromiseInterface;
use Rx\Observable;
use Rx\ObserverInterface;
use Rx\Scheduler;
use function React\Promise\resolve;

/**
 * Take an observable from a promise and return an new observable piping through the stream.
 *
 * @param PromiseInterface $promise
 * @return Observable
 */
function unwrapObservableFromPromise(PromiseInterface $promise): Observable
{
    return Observable::create(
        function (
            ObserverInterface $observer
        ) use ($promise) {
            resolve($promise)->done(function (Observable $observable) use ($observer) {
                $observable->subscribe(
                    function ($next) use ($observer) {
                        $observer->onNext($next);
                    },
                    function ($error) use ($observer) {
                        $observer->onError($error);
                    },
                    function () use ($observer) {
                        $observer->onCompleted();
                    }
                );
            });
        }
    );
}

/**
 * Take an array and return an observable from it with an immediate scheduler for scheduling
 *
 * @param array $array
 * @return Observable
 */
function observableFromArray(array $array): Observable
{
    return Observable::fromArray($array, Scheduler::getImmediate());
}


1			<?php declare(strict_types=1);
2
3			namespace ApiClients\Tools\Rx;
4
5			use React\Promise\PromiseInterface;
6			use Rx\Observable;
7			use Rx\ObserverInterface;
8			use Rx\Scheduler;
9			use function React\Promise\resolve;
10
11			/**
12			* Take an observable from a promise and return an new observable piping through the stream.
13			*
14			* @param PromiseInterface $promise
15			* @return Observable
16			*/
17			function unwrapObservableFromPromise(PromiseInterface $promise): Observable
18			{
19			return Observable::create(
20			function (
21			ObserverInterface $observer
22			) use ($promise) {
23			resolve($promise)->done(function (Observable $observable) use ($observer) {
24			$observable->subscribe(
25			function ($next) use ($observer) {
26			$observer->onNext($next);
27			},
28			function ($error) use ($observer) {
29			$observer->onError($error);
30			},
31			function () use ($observer) {
32			$observer->onCompleted();
33			}
34			);
35			});
36			}
37			);
38			}
39
40			/**
41			* Take an array and return an observable from it with an immediate scheduler for scheduling
42			*
43			* @param array $array
44			* @return Observable
45			*/
46			function observableFromArray(array $array): Observable
47			{
48			return Observable::fromArray($array, Scheduler::getImmediate());
49			}
50

php-api-clients / rx

GitHub Access Token became invalid

Push — master ( 616b6e...e5fc41 )

functions.php ➔ observableFromArray() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like