BufferedSinkMiddleware::__construct() - Code Metrics - Inspection of "Merge pull request #12 from php-api-clients/pause-..." - php-api-clients/transport - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( 2b5546...bdc854 )

by Cees-Jan

created 2017-07-22 20:55 UTC

BufferedSinkMiddleware::__construct() A

↳ Parent: BufferedSinkMiddleware

Complexity

Conditions	1
Paths	1

Size

Total Lines	4
Code Lines	2

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	3
CRAP Score	1

Importance

Changes

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

<?php declare(strict_types=1);

namespace ApiClients\Foundation\Transport\Middleware;

use ApiClients\Foundation\Middleware\ErrorTrait;
use ApiClients\Foundation\Middleware\MiddlewareInterface;
use ApiClients\Foundation\Middleware\PreTrait;
use Psr\Http\Message\ResponseInterface;
use React\EventLoop\LoopInterface;
use React\Promise\CancellablePromiseInterface;
use React\Stream\ReadableStreamInterface;
use RingCentral\Psr7\BufferStream;
use function React\Promise\resolve;
use function React\Promise\Stream\buffer;

class BufferedSinkMiddleware implements MiddlewareInterface
{
    use PreTrait;
    use ErrorTrait;

    /**
     * @var LoopInterface
     */
    private $loop;

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

    /**
     * @param  ResponseInterface           $response
     * @param  array                       $options
     * @return CancellablePromiseInterface
     */
    public function post(
        ResponseInterface $response,
        string $transactionId,
        array $options = []
    ): CancellablePromiseInterface {
        if (!($response->getBody() instanceof ReadableStreamInterface)) {
            return resolve($response);
        }

        $body = $response->getBody();
        $this->loop->futureTick(function () use ($body) {
            $body->resume();
        });

        return buffer($response->getBody())->then(function (string $body) use ($response) {
            $stream = new BufferStream(strlen($body));
            $stream->write($body);

            return resolve($response->withBody($stream));
        });
    }
}


1		<?php declare(strict_types=1);
2
3		namespace ApiClients\Foundation\Transport\Middleware;
4
5		use ApiClients\Foundation\Middleware\ErrorTrait;
6		use ApiClients\Foundation\Middleware\MiddlewareInterface;
7		use ApiClients\Foundation\Middleware\PreTrait;
8		use Psr\Http\Message\ResponseInterface;
9		use React\EventLoop\LoopInterface;
10		use React\Promise\CancellablePromiseInterface;
11		use React\Stream\ReadableStreamInterface;
12		use RingCentral\Psr7\BufferStream;
13		use function React\Promise\resolve;
14		use function React\Promise\Stream\buffer;
15
16		class BufferedSinkMiddleware implements MiddlewareInterface
17		{
18		use PreTrait;
19		use ErrorTrait;
20
21		/**
22		* @var LoopInterface
23		*/
24		private $loop;
25
26		/**
27		* @param LoopInterface $loop
28		*/
29	2	public function __construct(LoopInterface $loop)
30		{
31	2	$this->loop = $loop;
32	2	}
33
34		/**
35		* @param ResponseInterface $response
36		* @param array $options
37		* @return CancellablePromiseInterface
38		*/
39	2	public function post(
40		ResponseInterface $response,
41		string $transactionId,
42		array $options = []
43		): CancellablePromiseInterface {
44	2	if (!($response->getBody() instanceof ReadableStreamInterface)) {
45	1	return resolve($response);
46		}
47
48	1	$body = $response->getBody();
49		$this->loop->futureTick(function () use ($body) {
50	1	$body->resume();
51	1	});
52
53	1	return buffer($response->getBody())->then(function (string $body) use ($response) {
54	1	$stream = new BufferStream(strlen($body));
55	1	$stream->write($body);
56
57	1	return resolve($response->withBody($stream));
58	1	});
59		}
60		}
61

php-api-clients / transport

GitHub Access Token became invalid

Push — master ( 2b5546...bdc854 )

BufferedSinkMiddleware::__construct() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like