WebSocket::_subscribe() - Code Metrics - Inspection of "Refactored AsyncClient so that it's more declarati..." - php-api-clients/pusher - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Pull Request — master (#7)

by David

created 2017-09-05 22:03 UTC

WebSocket::_subscribe() A

↳ Parent: WebSocket

Complexity

Conditions	1
Paths	1

Size

Total Lines	17
Code Lines	9

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
dl	0
loc	17
rs	9.4285
c	0
b	0
f	0
cc	1
eloc	9
nc	1
nop	1

<?php declare(strict_types=1);

namespace ApiClients\Client\Pusher;

use React\Dns\Resolver\Resolver;
use React\EventLoop\LoopInterface;
use Rx\DisposableInterface;
use Rx\ObserverInterface;
use Rx\Subject\ReplaySubject;
use Rx\Subject\Subject;
use Rx\Websocket\Client;
.
|-- OtherDir
|   |-- Bar.php
|   `-- Foo.php
`-- SomeDir
    `-- Foo.php

/**
 * Class WebSocket - WebSocket wrapper that queues messages while the connection is being established.
 */
final class WebSocket extends Subject
{
    private $ws;
    private $sendSubject;

    public function __construct(string $url, bool $useMessageObject = false, array $subProtocols = [], LoopInterface $loop = null, Resolver $dnsResolver = null)
    {
        $this->sendSubject = new ReplaySubject();
        $this->ws = new Client($url, $useMessageObject, $subProtocols, $loop, $dnsResolver);
    }

    public function onNext($value)
    {
        $this->sendSubject->onNext($value);
    }

    protected function _subscribe(ObserverInterface $observer): DisposableInterface
    {
        return $this->ws
            ->do(function ($ms) {
                // Replay buffered messages onto the MessageSubject
                $this->sendSubject->subscribe($ms);

                // Now that the connection has been established, use the message subject directly.
                $this->sendSubject = $ms;
            })
            ->finally(function () {
                // The connection has closed, so start buffering messages util it reconnects.
                $this->sendSubject = new ReplaySubject();
            })
            ->mergeAll()
            ->subscribe($observer);
function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
    }
}


1			<?php declare(strict_types=1);
2
3			namespace ApiClients\Client\Pusher;
4
5			use React\Dns\Resolver\Resolver;
6			use React\EventLoop\LoopInterface;
7			use Rx\DisposableInterface;
8			use Rx\ObserverInterface;
9			use Rx\Subject\ReplaySubject;
10			use Rx\Subject\Subject;
11			use Rx\Websocket\Client;
			0 ignored issues – show Bug introduced 2017-09-05 22:12 UTC by Report Bug Copy Issue Report This use statement conflicts with another class in this namespace, `ApiClients\Client\Pusher\Client`. Let’s assume that you have a directory layout like this: . \|-- OtherDir \| \|-- Bar.php \| `-- Foo.php `-- SomeDir `-- Foo.php and let’s assume the following content of `Bar.php`: // Bar.php namespace OtherDir; use SomeDir\Foo; // This now conflicts the class OtherDir\Foo If both files `OtherDir/Foo.php` and `SomeDir/Foo.php` are loaded in the same runtime, you will see a PHP error such as the following: PHP Fatal error: Cannot use SomeDir\Foo as Foo because the name is already in use in OtherDir/Foo.php However, as `OtherDir/Foo.php` does not necessarily have to be loaded and the error is only triggered if it is loaded before `OtherDir/Bar.php`, this problem might go unnoticed for a while. In order to prevent this error from surfacing, you must import the namespace with a different alias: // Bar.php namespace OtherDir; use SomeDir\Foo as SomeDirFoo; // There is no conflict anymore. Loading history...
12
13			/**
14			* Class WebSocket - WebSocket wrapper that queues messages while the connection is being established.
15			*/
16			final class WebSocket extends Subject
17			{
18			private $ws;
19			private $sendSubject;
20
21			public function __construct(string $url, bool $useMessageObject = false, array $subProtocols = [], LoopInterface $loop = null, Resolver $dnsResolver = null)
22			{
23			$this->sendSubject = new ReplaySubject();
24			$this->ws = new Client($url, $useMessageObject, $subProtocols, $loop, $dnsResolver);
25			}
26
27			public function onNext($value)
28			{
29			$this->sendSubject->onNext($value);
30			}
31
32			protected function _subscribe(ObserverInterface $observer): DisposableInterface
33			{
34			return $this->ws
35			->do(function ($ms) {
36			// Replay buffered messages onto the MessageSubject
37			$this->sendSubject->subscribe($ms);
38
39			// Now that the connection has been established, use the message subject directly.
40			$this->sendSubject = $ms;
41			})
42			->finally(function () {
43			// The connection has closed, so start buffering messages util it reconnects.
44			$this->sendSubject = new ReplaySubject();
45			})
46			->mergeAll()
47			->subscribe($observer);
			0 ignored issues – show Documentation introduced 2017-09-05 22:12 UTC by Report Bug Copy Issue Report `$observer` is of type `object<Rx\ObserverInterface>`, but the function expects a `callable\|null`. It seems like the type of the argument is not accepted by the function/method which you are calling. In some cases, in particular if PHP’s automatic type-juggling kicks in this might be fine. In other cases, however this might be a bug. We suggest to add an explicit type cast like in the following example: function acceptsInteger($int) { } $x = '123'; // string "123" // Instead of acceptsInteger($x); // we recommend to use acceptsInteger((integer) $x); Loading history...
48			}
49			}
50

php-api-clients / pusher

GitHub Access Token became invalid

Pull Request — master (#7)

WebSocket::_subscribe() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like