Client::channel() - Code Metrics - Innmind/AMQP - Measure and Improve Code Quality continuously with Scrutinizer

Client::channel() A
last analyzed 2019-02-26 20:40 UTC

↳ Parent: Client

Complexity

Conditions	2
Paths	2

Size

Total Lines	15
Code Lines	8

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	9
CRAP Score	2

Importance

Changes

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

<?php
declare(strict_types = 1);

namespace Innmind\AMQP\Client;

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

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

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

    public function channel(): Channel
    {
        $pid = $this->process->id()->toInt();

        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\OperatingSystem\CurrentProcess;
12		use Innmind\Immutable\Map;
13
14		final class Client implements ClientInterface
15		{
16		private $connection;
17		private $process;
18		private $channels;
19		private $channel = 1;
20
21	8	public function __construct(Connection $connection, CurrentProcess $process)
22		{
23	8	$this->connection = $connection;
24	8	$this->process = $process;
25	8	$this->channels = new Map('int', Channel::class);
26	8	}
27
28	4	public function channel(): Channel
29		{
30	4	$pid = $this->process->id()->toInt();
31
32	4	if ($this->channels->contains($pid)) {
33	2	return $this->channels->get($pid);
34		}
35
36	4	$channel = new Channel\Channel(
37	4	$this->connection,
38	4	new Number($this->channel++)
39		);
40	4	$this->channels = $this->channels->put($pid, $channel);
41
42	4	return $channel;
43		}
44
45	2	public function closed(): bool
46		{
47	2	return $this->connection->closed();
48		}
49
50	2	public function close(): void
51		{
52	2	if ($this->closed()) {
53	2	return;
54		}
55
56		$this->channels->foreach(static function(int $pid, Channel $channel): void {
57	2	$channel->close();
58	2	});
59	2	$this->connection->close();
60	2	}
61		}
62

Innmind / AMQP

GitHub Access Token became invalid

Client::channel() A last analyzed 2019-02-26 20:40 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

Client::channel() A
last analyzed 2019-02-26 20:40 UTC