ApiClients\Foundation\Transport\Middleware\BufferedSinkMiddleware

Complexity

Total Complexity

2

Size/Duplication

Total Lines	23
Duplicated Lines	52.17 %

Coupling/Cohesion

Components	0
Dependencies	6

Importance

Changes

0

1 Method

Rating	Name	Duplication	Size	Complexity
A	post()	12	12	2

<?php declare(strict_types=1);

namespace ApiClients\Foundation\Transport\Middleware;

use ApiClients\Foundation\Middleware\DefaultPriorityTrait;
use ApiClients\Foundation\Middleware\MiddlewareInterface;
use ApiClients\Foundation\Middleware\PreTrait;
use Psr\Http\Message\ResponseInterface;
use React\Promise\CancellablePromiseInterface;
use function React\Promise\resolve;
use React\Stream\BufferedSink;
use React\Stream\ReadableStreamInterface;
use RingCentral\Psr7\BufferStream;

class BufferedSinkMiddleware implements MiddlewareInterface
{
    use DefaultPriorityTrait;
    use PreTrait;

    /**
     * @param ResponseInterface $response
     * @param array $options
     * @return CancellablePromiseInterface
     */
    public function post(ResponseInterface $response, array $options = []): CancellablePromiseInterface

This method seems to be duplicated in your project.

    {
        if (!($response->getBody() instanceof ReadableStreamInterface)) {
            return resolve($response);
        }

        return BufferedSink::createPromise($response->getBody())->then(function (string $body) use ($response) {
            $stream = new BufferStream(strlen($body));
            $stream->write($body);
            return resolve($response->withBody($stream));
        });
    }
}