| Modifier and Type | Method and Description |
|---|---|
static <ResponseT extends SdkResponse> |
AsyncResponseTransformer.toBlockingInputStream()
Creates an
AsyncResponseTransformer that allows reading the response body content as an InputStream. |
static <ResponseT> |
AsyncResponseTransformer.toBytes()
Creates an
AsyncResponseTransformer that writes all content to a byte array. |
static <ResponseT> |
AsyncResponseTransformer.toFile(File file)
Creates an
AsyncResponseTransformer that writes all the content to the given file. |
static <ResponseT> |
AsyncResponseTransformer.toFile(File file,
Consumer<FileTransformerConfiguration.Builder> config)
This is a convenience method that creates an instance of the
FileTransformerConfiguration builder, avoiding the
need to create one manually via FileTransformerConfiguration.builder(). |
static <ResponseT> |
AsyncResponseTransformer.toFile(File file,
FileTransformerConfiguration config)
Creates an
AsyncResponseTransformer that writes all the content to the given file with the specified
FileTransformerConfiguration. |
static <ResponseT> |
AsyncResponseTransformer.toFile(Path path)
Creates an
AsyncResponseTransformer that writes all the content to the given file. |
static <ResponseT> |
AsyncResponseTransformer.toFile(Path path,
Consumer<FileTransformerConfiguration.Builder> config)
This is a convenience method that creates an instance of the
FileTransformerConfiguration builder, avoiding the
need to create one manually via FileTransformerConfiguration.builder(). |
static <ResponseT> |
AsyncResponseTransformer.toFile(Path path,
FileTransformerConfiguration config)
Creates an
AsyncResponseTransformer that writes all the content to the given file with the specified
FileTransformerConfiguration. |
static <ResponseT extends SdkResponse> |
AsyncResponseTransformer.toPublisher()
Creates an
AsyncResponseTransformer that publishes the response body content through a ResponsePublisher,
which is an SdkPublisher that also contains a reference to the SdkResponse returned by the service. |
| Modifier and Type | Method and Description |
|---|---|
SdkPublisher<AsyncResponseTransformer<ResponseT,ResponseT>> |
AsyncResponseTransformer.SplitResult.publisher()
The individual
AsyncResponseTransformer will be available through the publisher returned by this method. |
SdkPublisher<AsyncResponseTransformer<ResponseT,ResponseT>> |
AsyncResponseTransformer.SplitResult.Builder.publisher() |
static <ResponseT,ResultT> |
AsyncResponseTransformerUtils.wrapWithEndOfStreamFuture(AsyncResponseTransformer<ResponseT,ResultT> responseTransformer)
Wrap a
AsyncResponseTransformer and associate it with a future that is completed upon end-of-stream, regardless of
whether the transformer is configured to complete its future upon end-of-response or end-of-stream. |
| Modifier and Type | Method and Description |
|---|---|
static <ResponseT,ResultT> |
AsyncResponseTransformerUtils.wrapWithEndOfStreamFuture(AsyncResponseTransformer<ResponseT,ResultT> responseTransformer)
Wrap a
AsyncResponseTransformer and associate it with a future that is completed upon end-of-stream, regardless of
whether the transformer is configured to complete its future upon end-of-response or end-of-stream. |
| Modifier and Type | Method and Description |
|---|---|
AsyncResponseTransformer.SplitResult.Builder<ResponseT,ResultT> |
AsyncResponseTransformer.SplitResult.Builder.publisher(SdkPublisher<AsyncResponseTransformer<ResponseT,ResponseT>> publisher)
Sets the publisher publishing the individual
AsyncResponseTransformer |
| Modifier and Type | Class and Description |
|---|---|
static class |
AsyncResponseTransformerListener.NotifyingAsyncResponseTransformer<ResponseT,ResultT> |
| Modifier and Type | Method and Description |
|---|---|
static <ResponseT,ResultT> |
AsyncResponseTransformerListener.wrap(AsyncResponseTransformer<ResponseT,ResultT> delegate,
AsyncResponseTransformerListener<ResponseT> listener)
Wrap a
AsyncResponseTransformer with a new one that will notify a AsyncResponseTransformerListener of
important events occurring. |
| Modifier and Type | Method and Description |
|---|---|
static <ResponseT,ResultT> |
AsyncResponseTransformerListener.wrap(AsyncResponseTransformer<ResponseT,ResultT> delegate,
AsyncResponseTransformerListener<ResponseT> listener)
Wrap a
AsyncResponseTransformer with a new one that will notify a AsyncResponseTransformerListener of
important events occurring. |
| Modifier and Type | Method and Description |
|---|---|
<InputT extends SdkRequest,OutputT extends SdkResponse,ReturnT> |
AsyncClientHandler.execute(ClientExecutionParams<InputT,OutputT> executionParams,
AsyncResponseTransformer<OutputT,ReturnT> asyncResponseTransformer)
Execute's a streaming web service request.
|
| Modifier and Type | Class and Description |
|---|---|
class |
ByteArrayAsyncResponseTransformer<ResponseT>
Implementation of
AsyncResponseTransformer that dumps content into a byte array and supports further
conversions into types, like strings. |
class |
FileAsyncResponseTransformer<ResponseT>
AsyncResponseTransformer that writes the data to the specified file. |
class |
InputStreamResponseTransformer<ResponseT extends SdkResponse>
A
AsyncResponseTransformer that allows performing blocking reads on the response data. |
class |
PublisherAsyncResponseTransformer<ResponseT extends SdkResponse>
|
| Modifier and Type | Method and Description |
|---|---|
SdkPublisher<AsyncResponseTransformer<ResponseT,ResponseT>> |
DefaultAsyncResponseTransformerSplitResult.publisher()
The individual
AsyncResponseTransformer will be available through the publisher returned by this method. |
SdkPublisher<AsyncResponseTransformer<ResponseT,ResponseT>> |
DefaultAsyncResponseTransformerSplitResult.DefaultBuilder.publisher() |
| Modifier and Type | Method and Description |
|---|---|
SplittingTransformer.Builder<ResponseT,ResultT> |
SplittingTransformer.Builder.upstreamResponseTransformer(AsyncResponseTransformer<ResponseT,ResultT> upstreamResponseTransformer)
The
AsyncResponseTransformer that will receive the data from each of the individually published
IndividualTransformer, usually intended to be the one on which the
split(SplittingTransformerConfiguration))} method was called. |
| Modifier and Type | Method and Description |
|---|---|
AsyncResponseTransformer.SplitResult.Builder<ResponseT,ResultT> |
DefaultAsyncResponseTransformerSplitResult.DefaultBuilder.publisher(SdkPublisher<AsyncResponseTransformer<ResponseT,ResponseT>> publisher) |
void |
SplittingTransformer.subscribe(org.reactivestreams.Subscriber<? super AsyncResponseTransformer<ResponseT,ResponseT>> downstreamSubscriber) |
| Modifier and Type | Method and Description |
|---|---|
<InputT extends SdkRequest,OutputT extends SdkResponse,ReturnT> |
BaseAsyncClientHandler.execute(ClientExecutionParams<InputT,OutputT> executionParams,
AsyncResponseTransformer<OutputT,ReturnT> asyncResponseTransformer) |
| Constructor and Description |
|---|
AsyncStreamingResponseHandler(AsyncResponseTransformer<OutputT,ReturnT> asyncResponseTransformer) |
Copyright © 2026. All rights reserved.