Client::channel() - Code Metrics - Inspection of "add client" - Innmind/AMQP - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — develop ( a0d7f6...1c3e27 )

by Baptiste

created 2017-09-11 18:08 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;
    private $closed;

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

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

        $this->channels->foreach(static function(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		private $closed;
19
20	3	public function __construct(Connection $connection)
21		{
22	3	$this->connection = $connection;
23	3	$this->channels = new Map('int', Channel::class);
24	3	}
25
26	1	public function channel(): Channel
27		{
28	1	$pid = getmypid();
29
30	1	if ($this->channels->contains($pid)) {
31	1	return $this->channels->get($pid);
32		}
33
34	1	$channel = new Channel\Channel(
35	1	$this->connection,
36	1	new Number($this->channel++)
37		);
38	1	$this->channels = $this->channels->put($pid, $channel);
39
40	1	return $channel;
41		}
42
43	1	public function closed(): bool
44		{
45	1	return !$this->connection->opened();
46		}
47
48	1	public function close(): void
49		{
50	1	if ($this->closed()) {
51	1	return;
52		}
53
54	1	$this->channels->foreach(static function(Channel $channel): void {
55		$channel->close();
56	1	});
57		$this->connection->close();
58		}
59		}
60

Innmind / AMQP

GitHub Access Token became invalid

Push — develop ( a0d7f6...1c3e27 )

Client::channel() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like