public interface StreamingHttpClient extends HttpClient
HttpClient that supports streaming responses.DEFAULT_ERROR_TYPE| Modifier and Type | Method and Description |
|---|---|
<I> Publisher<ByteBuffer<?>> |
dataStream(HttpRequest<I> request)
Request a stream of data where each emitted item is a
ByteBuffer instance. |
<I> Publisher<HttpResponse<ByteBuffer<?>>> |
exchangeStream(HttpRequest<I> request)
Requests a stream data where each emitted item is a
ByteBuffer wrapped in the HttpResponse object
(which remains the same for each emitted item). |
<I> Publisher<Map<String,Object>> |
jsonStream(HttpRequest<I> request)
Perform an HTTP request and receive data as a stream of JSON objects as they become available without blocking.
|
<I,O> Publisher<O> |
jsonStream(HttpRequest<I> request,
Argument<O> type)
Perform an HTTP request and receive data as a stream of JSON objects as they become available without blocking.
|
default <I,O> Publisher<O> |
jsonStream(HttpRequest<I> request,
Class<O> type)
Perform an HTTP request and receive data as a stream of JSON objects as they become available without blocking.
|
<I> Publisher<ByteBuffer<?>> dataStream(HttpRequest<I> request)
ByteBuffer instance.I - The request body typerequest - The requestPublisher that emits a stream of ByteBuffer instances<I> Publisher<HttpResponse<ByteBuffer<?>>> exchangeStream(HttpRequest<I> request)
ByteBuffer wrapped in the HttpResponse object
(which remains the same for each emitted item).I - The request body typerequest - The HttpRequestPublisher that emits a stream of ByteBuffer instances wrapped by a HttpResponse<I> Publisher<Map<String,Object>> jsonStream(HttpRequest<I> request)
Perform an HTTP request and receive data as a stream of JSON objects as they become available without blocking.
The downstream Subscriber can regulate demand via the subscription
I - The request body typerequest - The HttpRequest to executePublisher that emits the full HttpResponse object<I,O> Publisher<O> jsonStream(HttpRequest<I> request, Argument<O> type)
Perform an HTTP request and receive data as a stream of JSON objects as they become available without blocking.
The downstream Subscriber can regulate demand via the subscription. Incoming data
is buffered.
I - The request body typeO - The response typerequest - The HttpRequest to executetype - The type of object to convert the JSON intoPublisher that emits the full HttpResponse objectdefault <I,O> Publisher<O> jsonStream(HttpRequest<I> request, Class<O> type)
Perform an HTTP request and receive data as a stream of JSON objects as they become available without blocking.
The downstream Subscriber can regulate demand via the subscription
I - The request body typeO - The response typerequest - The HttpRequest to executetype - The type of object to convert the JSON intoPublisher that emits the full HttpResponse object