ApiClients\Foundation\Transport\Middleware\BufferedSinkMiddleware::post()

Complexity

Conditions	2
Paths	2

Size

Total Lines	12
Code Lines	7

Duplication

Lines	12
Ratio	100 %

Importance

Changes

0

<?php declare(strict_types=1);
    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));
        });
    }
}