Client::channels() - Code Metrics - Inspection of "Updated the namespace to include Client in it" - php-api-clients/pusher - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( 1f83af...994fb5 )

by Cees-Jan

created 2016-12-03 09:10 UTC

Client::channels() A

↳ Parent: Client

Complexity

Conditions	2
Paths	2

Size

Total Lines	22
Code Lines	14

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	6

Importance

Changes

Metric	Value
dl	0
loc	22
ccs	0
cts	0
cp	0
rs	9.2
c	0
b	0
f	0
cc	2
eloc	14
nc	2
nop	2
crap	6

<?php declare(strict_types=1);

namespace ApiClients\Client\Pusher;

use React\EventLoop\Factory;
use React\EventLoop\LoopInterface;
use React\Promise\Deferred;
use Rx\Observer\CallbackObserver;
use function Clue\React\Block\await;
use function React\Promise\all;

final class Client
{
    /**
     * @var LoopInterface
     */
    protected $loop;

    /**
     * @var AsyncClient
     */
    protected $client;

    /**
     * @param string $app Application ID
     */
    public function __construct(string $app)
    {
        $this->loop = Factory::create();
        $this->client = new AsyncClient($this->loop, $app);
    }

    /**
     * @param string $channel Channel to listen on
     * @param callable $listener Listener to call on new messages
     */
    public function channel(string $channel, callable $listener)
    {
        $this->channels(
            [
                $channel,
            ],
            $listener
        );
    }

    /**
     * @param string[] $channels Channels to listen on
     * @param callable $listener Listener to call on new messages
     */
    public function channels(array $channels, callable $listener)
    {
        $promises = [];
        foreach ($channels as $channel) {
            $deferred = new Deferred();
            $this->client->channel($channel)->subscribe(
                new CallbackObserver(
                    $listener,
                    null,
                    function () use ($deferred) {
                        $deferred->resolve();
                    }
                )
            );
            $promises[] = $deferred->promise();
        }

        await(
            all($promises),
            $this->loop
        );
    }
}


1			<?php declare(strict_types=1);
2
3			namespace ApiClients\Client\Pusher;
4
5			use React\EventLoop\Factory;
6			use React\EventLoop\LoopInterface;
7			use React\Promise\Deferred;
8			use Rx\Observer\CallbackObserver;
9			use function Clue\React\Block\await;
10			use function React\Promise\all;
11
12			final class Client
13			{
14			/**
15			* @var LoopInterface
16			*/
17			protected $loop;
18
19			/**
20			* @var AsyncClient
21			*/
22			protected $client;
23
24			/**
25			* @param string $app Application ID
26			*/
27			public function __construct(string $app)
28			{
29			$this->loop = Factory::create();
30			$this->client = new AsyncClient($this->loop, $app);
31			}
32
33			/**
34			* @param string $channel Channel to listen on
35			* @param callable $listener Listener to call on new messages
36			*/
37			public function channel(string $channel, callable $listener)
38			{
39			$this->channels(
40			[
41			$channel,
42			],
43			$listener
44			);
45			}
46
47			/**
48			* @param string[] $channels Channels to listen on
49			* @param callable $listener Listener to call on new messages
50			*/
51			public function channels(array $channels, callable $listener)
52			{
53			$promises = [];
54			foreach ($channels as $channel) {
55			$deferred = new Deferred();
56			$this->client->channel($channel)->subscribe(
57			new CallbackObserver(
58			$listener,
59			null,
60			function () use ($deferred) {
61			$deferred->resolve();
62			}
63			)
64			);
65			$promises[] = $deferred->promise();
66			}
67
68			await(
69			all($promises),
70			$this->loop
71			);
72			}
73			}
74

php-api-clients / pusher

GitHub Access Token became invalid

Push — master ( 1f83af...994fb5 )

Client::channels() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like