Connections::watch() - Code Metrics - carno-php/log - Measure and Improve Code Quality continuously with Scrutinizer

Connections::watch() A
last analyzed 2019-07-29 03:19 UTC

↳ Parent: Connections

Complexity

Conditions	1
Paths	1

Size

Total Lines	7
Code Lines	3

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	1

Metric	Value
cc	1
eloc	3
c	1
b	0
f	1
nc	1
nop	2
dl	0
loc	7
rs	10

<?php
/**
 * Log connections manager
 * User: moyo
 * Date: 22/11/2017
 * Time: 10:38 AM
 */

namespace Carno\Log;

use Carno\Log\Contracts\Closeable;
use Carno\Log\Contracts\Outputter;
use Carno\Net\Address;
use Carno\Promise\Promise;
use Carno\Promise\Promised;
use Closure;

class Connections
{
    /**
     * @var Closeable[]
     */
    private $connected = [];

    /**
     * @param Address $address
     * @param Closure $connector
     * @return Outputter
     */
    public function hosting(Address $address, Closure $connector) : Outputter
    {
        return

            $this->connected[$cid = (string)$address] ??
            $this->connected[$cid] = $this->watch($cid, $connector($address))
        ;
    }

    /**
     * @param string $cid
     * @param Closeable $conn
     * @return Closeable|Outputter
     */
    private function watch(string $cid, Closeable $conn) : Closeable
    {
        $conn->closed()->then(function () use ($cid) {
            unset($this->connected[$cid]);
        });

        return $conn;
    }

    /**
     * @param Address $address
     * @return Promised
     */
    public function close(Address $address) : Promised
    {
        return ($c = $this->connected[(string)$address] ?? null) ? $c->close() : Promise::resolved();
    }

    /**
     * @return Promised
     */
    public function release() : Promised
    {
        $pending = [];

        foreach ($this->connected as $closeable) {
            $pending[] = $closeable->close();
        }

        return Promise::all(...$pending);
    }
}


1			<?php
2			/**
3			* Log connections manager
4			* User: moyo
5			* Date: 22/11/2017
6			* Time: 10:38 AM
7			*/
8
9			namespace Carno\Log;
10
11			use Carno\Log\Contracts\Closeable;
12			use Carno\Log\Contracts\Outputter;
13			use Carno\Net\Address;
14			use Carno\Promise\Promise;
15			use Carno\Promise\Promised;
16			use Closure;
17
18			class Connections
19			{
20			/**
21			* @var Closeable[]
22			*/
23			private $connected = [];
24
25			/**
26			* @param Address $address
27			* @param Closure $connector
28			* @return Outputter
29			*/
30			public function hosting(Address $address, Closure $connector) : Outputter
31			{
32			return
			0 ignored issues – show Bug Best Practice introduced 2019-04-04 11:12 UTC by Report Bug Copy Issue Report The expression `return $this->connected[..., $connector($address))` returns the type `Carno\Log\Contracts\Closeable` which is incompatible with the type-hinted return `Carno\Log\Contracts\Outputter`. Loading history...
33			$this->connected[$cid = (string)$address] ??
34			$this->connected[$cid] = $this->watch($cid, $connector($address))
35			;
36			}
37
38			/**
39			* @param string $cid
40			* @param Closeable $conn
41			* @return Closeable\|Outputter
42			*/
43			private function watch(string $cid, Closeable $conn) : Closeable
44			{
45			$conn->closed()->then(function () use ($cid) {
46			unset($this->connected[$cid]);
47			});
48
49			return $conn;
50			}
51
52			/**
53			* @param Address $address
54			* @return Promised
55			*/
56			public function close(Address $address) : Promised
57			{
58			return ($c = $this->connected[(string)$address] ?? null) ? $c->close() : Promise::resolved();
59			}
60
61			/**
62			* @return Promised
63			*/
64			public function release() : Promised
65			{
66			$pending = [];
67
68			foreach ($this->connected as $closeable) {
69			$pending[] = $closeable->close();
70			}
71
72			return Promise::all(...$pending);
73			}
74			}
75

carno-php / log

Connections::watch() A last analyzed 2019-07-29 03:19 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

Connections::watch() A
last analyzed 2019-07-29 03:19 UTC