php-api-clients / transport

        $this->client = $client;

    }

    public function handle(RequestCommandInterface $command): PromiseInterface

    {

        return $this->client->request(

            $command->getRequest(),

            $command->getOptions()

        )->then(function (ResponseInterface $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));

        });

    }

}