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

Complexity

Conditions	2
Paths	2

Size

Total Lines	21
Code Lines	14

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	11
CRAP Score	2

Importance

Changes

0

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