StreamingResponse::_subscribe() - Code Metrics - php-api-clients/transport - Measure and Improve Code Quality continuously with Scrutinizer

StreamingResponse::_subscribe() A
last analyzed 2019-03-03 10:40 UTC

↳ Parent: StreamingResponse

Complexity

Conditions	1
Paths	1

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	6
CRAP Score	1

Importance

Changes

Metric	Value
dl	0
loc	10
ccs	6
cts	6
cp	1
rs	9.9332
c	0
b	0
f	0
cc	1
nc	1
nop	1
crap	1

<?php declare(strict_types=1);

namespace ApiClients\Foundation\Transport;

use Psr\Http\Message\ResponseInterface;
use Rx\Disposable\EmptyDisposable;
use Rx\DisposableInterface;
use Rx\Observable;
use Rx\ObserverInterface;

final class StreamingResponse extends Observable
{
    /**
     * @var ResponseInterface
     */
    private $response;

    /**
     * @param ResponseInterface $response
     */
    public function __construct(ResponseInterface $response)
    {
        $this->response = $response;
    }

    /**
     * @return ResponseInterface
     */
    public function getResponse(): ResponseInterface
    {
        return $this->response;
    }

    /**
     * @param  ObserverInterface   $observer
     * @return DisposableInterface
     * @ignoreCodeCoverage
     */
    // @codingStandardsIgnoreStart
    protected function _subscribe(ObserverInterface $observer): DisposableInterface
    {
        // @codingStandardsIgnoreEnd
        $body = $this->response->getBody();
        $body->on('data', [$observer, 'onNext']);
        $body->on('error', [$observer, 'onError']);
        $body->on('end', [$observer, 'onCompleted']);

        return new EmptyDisposable();
    }
}


1		<?php declare(strict_types=1);
2
3		namespace ApiClients\Foundation\Transport;
4
5		use Psr\Http\Message\ResponseInterface;
6		use Rx\Disposable\EmptyDisposable;
7		use Rx\DisposableInterface;
8		use Rx\Observable;
9		use Rx\ObserverInterface;
10
11		final class StreamingResponse extends Observable
12		{
13		/**
14		* @var ResponseInterface
15		*/
16		private $response;
17
18		/**
19		* @param ResponseInterface $response
20		*/
21	3	public function __construct(ResponseInterface $response)
22		{
23	3	$this->response = $response;
24	3	}
25
26		/**
27		* @return ResponseInterface
28		*/
29	2	public function getResponse(): ResponseInterface
30		{
31	2	return $this->response;
32		}
33
34		/**
35		* @param ObserverInterface $observer
36		* @return DisposableInterface
37		* @ignoreCodeCoverage
38		*/
39		// @codingStandardsIgnoreStart
40	2	protected function _subscribe(ObserverInterface $observer): DisposableInterface
41		{
42		// @codingStandardsIgnoreEnd
43	2	$body = $this->response->getBody();
44	2	$body->on('data', [$observer, 'onNext']);
45	2	$body->on('error', [$observer, 'onError']);
46	2	$body->on('end', [$observer, 'onCompleted']);
47
48	2	return new EmptyDisposable();
49		}
50		}
51

php-api-clients / transport

GitHub Access Token became invalid

StreamingResponse::_subscribe() A last analyzed 2019-03-03 10:40 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

StreamingResponse::_subscribe() A
last analyzed 2019-03-03 10:40 UTC