php-api-clients / transport

     * @param array $options

     * @return CancellablePromiseInterface

     */

    public function post(ResponseInterface $response, array $options = []): CancellablePromiseInterface

    {

        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));

        });

    }

}

     * @param array $options

     * @return CancellablePromiseInterface

     */

    public function pre(RequestInterface $request, array $options = []): CancellablePromiseInterface

    {

        if (!($request->getBody() instanceof JsonStream)) {

            return resolve($request);

        }

        return $this->jsonEncodeService->handle($request->getBody()->getJson())->then(function ($json) use ($request) {

            $body = new BufferStream(strlen($json));

            $body->write($json);

            return resolve($request->withBody($body));

        });

    }

}