functions.php ➔ setAsyncScheduler() - Code Metrics - php-api-clients/rx - Measure and Improve Code Quality continuously with Scrutinizer

functions.php ➔ setAsyncScheduler() A
last analyzed 2019-03-17 00:00 UTC

↳ Parent: Project

Complexity

Conditions	3
Paths	3

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	6
CRAP Score	3.0261

Importance

Changes

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

<?php declare(strict_types=1);

namespace ApiClients\Tools\Rx;

use Exception;
use React\EventLoop\LoopInterface;
use React\Promise\PromiseInterface;
use Rx\Observable;
use Rx\Scheduler;
use Throwable;

/**
 * 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::fromPromise($promise)->mergeAll();
}

/**
 * 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());
}

/**
 * @param  LoopInterface $loop
 * @throws Throwable
 */
function setAsyncScheduler(LoopInterface $loop): void
{
    try {
        Scheduler::setAsyncFactory(function () use ($loop) {
            return new Scheduler\EventLoopScheduler($loop);
function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
        });
    } catch (Exception $e) {
        if ($e->getMessage() === 'The async factory can not be set after the scheduler has been created') {
            return;
        }

        throw $e;
    }
}


1		<?php declare(strict_types=1);
2
3		namespace ApiClients\Tools\Rx;
4
5		use Exception;
6		use React\EventLoop\LoopInterface;
7		use React\Promise\PromiseInterface;
8		use Rx\Observable;
9		use Rx\Scheduler;
10		use Throwable;
11
12		/**
13		* Take an observable from a promise and return an new observable piping through the stream.
14		*
15		* @param PromiseInterface $promise
16		* @return Observable
17		*/
18		function unwrapObservableFromPromise(PromiseInterface $promise): Observable
19		{
20	3	return Observable::fromPromise($promise)->mergeAll();
21		}
22
23		/**
24		* Take an array and return an observable from it with an immediate scheduler for scheduling.
25		*
26		* @param array $array
27		* @return Observable
28		*/
29		function observableFromArray(array $array): Observable
30		{
31	1	return Observable::fromArray($array, Scheduler::getImmediate());
32		}
33
34		/**
35		* @param LoopInterface $loop
36		* @throws Throwable
37		*/
38		function setAsyncScheduler(LoopInterface $loop): void
39		{
40		try {
41		Scheduler::setAsyncFactory(function () use ($loop) {
42	1	return new Scheduler\EventLoopScheduler($loop);
		0 ignored issues – show Documentation introduced 2017-08-25 22:31 UTC by Report Bug Copy Issue Report `$loop` is of type `object<React\EventLoop\LoopInterface>`, but the function expects a `callable`. It seems like the type of the argument is not accepted by the function/method which you are calling. In some cases, in particular if PHP’s automatic type-juggling kicks in this might be fine. In other cases, however this might be a bug. We suggest to add an explicit type cast like in the following example: function acceptsInteger($int) { } $x = '123'; // string "123" // Instead of acceptsInteger($x); // we recommend to use acceptsInteger((integer) $x); Loading history...
43	1	});
44	1	} catch (Exception $e) {
45	1	if ($e->getMessage() === 'The async factory can not be set after the scheduler has been created') {
46	1	return;
47		}
48
49		throw $e;
50		}
51		}
52

php-api-clients / rx

GitHub Access Token became invalid

functions.php ➔ setAsyncScheduler() A last analyzed 2019-03-17 00:00 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

functions.php ➔ setAsyncScheduler() A
last analyzed 2019-03-17 00:00 UTC