Client::channel() - Code Metrics - Inspection of "Merge branch 'develop'" - Innmind/AMQP - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( dfa639...ae7bb7 )

by Baptiste

created 2017-09-15 06:02 UTC

Client::channel() A

↳ Parent: Client

Complexity

Conditions	2
Paths	2

Size

Total Lines	16
Code Lines	9

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	9
CRAP Score	2

Importance

Changes

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

<?php
declare(strict_types = 1);

namespace Innmind\AMQP\Client;

use Innmind\AMQP\{
    Client as ClientInterface,
    Transport\Connection,
    Transport\Frame\Channel as Number
};
use Innmind\Immutable\Map;

final class Client implements ClientInterface
{
    private $connection;
    private $channels;
    private $channel = 1;

    public function __construct(Connection $connection)
    {
        $this->connection = $connection;
        $this->channels = new Map('int', Channel::class);
    }

    public function channel(): Channel
    {
        $pid = getmypid();

        if ($this->channels->contains($pid)) {
            return $this->channels->get($pid);
        }

        $channel = new Channel\Channel(
            $this->connection,
            new Number($this->channel++)
        );
        $this->channels = $this->channels->put($pid, $channel);

        return $channel;
    }

    public function closed(): bool
    {
        return $this->connection->closed();
    }

    public function close(): void
    {
        if ($this->closed()) {
            return;
        }

        $this->channels->foreach(static function(int $pid, Channel $channel): void {
            $channel->close();
        });
        $this->connection->close();
    }
}


1		<?php
2		declare(strict_types = 1);
3
4		namespace Innmind\AMQP\Client;
5
6		use Innmind\AMQP\{
7		Client as ClientInterface,
8		Transport\Connection,
9		Transport\Frame\Channel as Number
10		};
11		use Innmind\Immutable\Map;
12
13		final class Client implements ClientInterface
14		{
15		private $connection;
16		private $channels;
17		private $channel = 1;
18
19	3	public function __construct(Connection $connection)
20		{
21	3	$this->connection = $connection;
22	3	$this->channels = new Map('int', Channel::class);
23	3	}
24
25	2	public function channel(): Channel
26		{
27	2	$pid = getmypid();
28
29	2	if ($this->channels->contains($pid)) {
30	1	return $this->channels->get($pid);
31		}
32
33	2	$channel = new Channel\Channel(
34	2	$this->connection,
35	2	new Number($this->channel++)
36		);
37	2	$this->channels = $this->channels->put($pid, $channel);
38
39	2	return $channel;
40		}
41
42	1	public function closed(): bool
43		{
44	1	return $this->connection->closed();
45		}
46
47	1	public function close(): void
48		{
49	1	if ($this->closed()) {
50	1	return;
51		}
52
53	1	$this->channels->foreach(static function(int $pid, Channel $channel): void {
54	1	$channel->close();
55	1	});
56		$this->connection->close();
57		}
58		}
59

Innmind / AMQP

GitHub Access Token became invalid

Push — master ( dfa639...ae7bb7 )

Client::channel() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like