StreamingResponse::_subscribe() - Code Metrics - Inspection of "Merge branch 'feature-error-handling-middlware'" - php-api-clients/transport - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( 8cad20...343767 )

by Cees-Jan

created 2017-03-23 16:48 UTC

StreamingResponse::_subscribe() A

↳ Parent: StreamingResponse

Complexity

Conditions	1
Paths	1

Size

Total Lines	10
Code Lines	6

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
dl	0
loc	10
rs	9.4285
c	0
b	0
f	0
cc	1
eloc	6
nc	1
nop	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;
use Rx\SchedulerInterface;

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			use Rx\SchedulerInterface;
11
12			final class StreamingResponse extends Observable
13			{
14			/**
15			* @var ResponseInterface
16			*/
17			private $response;
18
19			/**
20			* @param ResponseInterface $response
21			*/
22			public function __construct(ResponseInterface $response)
23			{
24			$this->response = $response;
25			}
26
27			/**
28			* @return ResponseInterface
29			*/
30			public function getResponse(): ResponseInterface
31			{
32			return $this->response;
33			}
34
35			/**
36			* @param ObserverInterface $observer
37			* @return DisposableInterface
38			* @ignoreCodeCoverage
39			*/
40			// @codingStandardsIgnoreStart
41			protected function _subscribe(ObserverInterface $observer): DisposableInterface
42			{
43			// @codingStandardsIgnoreEnd
44			$body = $this->response->getBody();
45			$body->on('data', [$observer, 'onNext']);
46			$body->on('error', [$observer, 'onError']);
47			$body->on('end', [$observer, 'onCompleted']);
48
49			return new EmptyDisposable();
50			}
51			}
52

php-api-clients / transport

GitHub Access Token became invalid

Push — master ( 8cad20...343767 )

StreamingResponse::_subscribe() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like