Client::channels() - Code Metrics - Inspection of "Sync client and sync reddit examples" - php-api-clients/pusher - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( 78ea24...4a847b )

by Cees-Jan

created 2016-08-23 20:28 UTC

Client::channels() A

↳ Parent: Client

Complexity

Conditions	2
Paths	2

Size

Total Lines	19
Code Lines	12

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	6

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
dl	0
loc	19
ccs	0
cts	19
cp	0
rs	9.4285
c	1
b	0
f	0
cc	2
eloc	12
nc	2
nop	2
crap	6

<?php declare(strict_types=1);

namespace ApiClients\Pusher;

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

class Client
{
    protected $loop;
    protected $client;

    public function __construct(string $app)
    {
        $this->loop = Factory::create();
        $this->client = new AsyncClient($this->loop, $app);
    }

    public function channel(string $channel, callable $listener)
    {
        $this->channels(
            [
                $channel,
            ],
            $listener
        );
    }

    public function channels(array $channels, callable $listener)
    {
        $deferred = new Deferred();
        foreach ($channels as $channel) {
            $this->client->channel($channel)->subscribe(
                new CallbackObserver(
                    $listener,
                    null,
                    function () use ($deferred) {
                        $deferred->resolve();
                    }
                )
            );
        }
        await(
            $deferred->promise(),
            $this->loop
        );
    }
}


1			<?php declare(strict_types=1);
2
3			namespace ApiClients\Pusher;
4
5			use React\EventLoop\Factory;
6			use React\Promise\Deferred;
7			use Rx\Observer\CallbackObserver;
8			use function Clue\React\Block\await;
9
10			class Client
11			{
12			protected $loop;
13			protected $client;
14
15			public function __construct(string $app)
16			{
17			$this->loop = Factory::create();
18			$this->client = new AsyncClient($this->loop, $app);
19			}
20
21			public function channel(string $channel, callable $listener)
22			{
23			$this->channels(
24			[
25			$channel,
26			],
27			$listener
28			);
29			}
30
31			public function channels(array $channels, callable $listener)
32			{
33			$deferred = new Deferred();
34			foreach ($channels as $channel) {
35			$this->client->channel($channel)->subscribe(
36			new CallbackObserver(
37			$listener,
38			null,
39			function () use ($deferred) {
40			$deferred->resolve();
41			}
42			)
43			);
44			}
45			await(
46			$deferred->promise(),
47			$this->loop
48			);
49			}
50			}
51

php-api-clients / pusher

GitHub Access Token became invalid

Push — master ( 78ea24...4a847b )

Client::channels() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like