| Modifier and Type | Method and Description |
|---|---|
<InputT extends SdkRequest,OutputT extends SdkResponse,ReturnT> |
AwsAsyncClientHandler.execute(ClientExecutionParams<InputT,OutputT> executionParams,
AsyncResponseTransformer<OutputT,ReturnT> asyncResponseTransformer) |
| Modifier and Type | Class and Description |
|---|---|
class |
EventStreamAsyncResponseTransformer<ResponseT,EventT>
Unmarshalling layer on top of the
AsyncResponseTransformer to decode event stream messages and deliver them to the
subscriber. |
class |
RestEventStreamAsyncResponseTransformer<ResponseT extends SdkResponse,EventT>
Adapter transformer meant for eventstream responses from REST services (REST-XML, REST-JSON).
|
| 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) |
| Modifier and Type | Method and Description |
|---|---|
default <ReturnT> CompletableFuture<ReturnT> |
S3AsyncClient.getObject(Consumer<GetObjectRequest.Builder> getObjectRequest,
AsyncResponseTransformer<GetObjectResponse,ReturnT> asyncResponseTransformer)
Retrieves an object from Amazon S3.
|
default <ReturnT> CompletableFuture<ReturnT> |
S3AsyncClient.getObject(GetObjectRequest getObjectRequest,
AsyncResponseTransformer<GetObjectResponse,ReturnT> asyncResponseTransformer)
Retrieves an object from Amazon S3.
|
<ReturnT> CompletableFuture<ReturnT> |
DelegatingS3AsyncClient.getObject(GetObjectRequest getObjectRequest,
AsyncResponseTransformer<GetObjectResponse,ReturnT> asyncResponseTransformer)
Retrieves an object from Amazon S3.
|
default <ReturnT> CompletableFuture<ReturnT> |
S3AsyncClient.getObjectTorrent(Consumer<GetObjectTorrentRequest.Builder> getObjectTorrentRequest,
AsyncResponseTransformer<GetObjectTorrentResponse,ReturnT> asyncResponseTransformer)
|
default <ReturnT> CompletableFuture<ReturnT> |
S3AsyncClient.getObjectTorrent(GetObjectTorrentRequest getObjectTorrentRequest,
AsyncResponseTransformer<GetObjectTorrentResponse,ReturnT> asyncResponseTransformer)
|
<ReturnT> CompletableFuture<ReturnT> |
DelegatingS3AsyncClient.getObjectTorrent(GetObjectTorrentRequest getObjectTorrentRequest,
AsyncResponseTransformer<GetObjectTorrentResponse,ReturnT> asyncResponseTransformer)
|
| Modifier and Type | Method and Description |
|---|---|
<T> CompletableFuture<T> |
DownloadObjectHelper.downloadObject(GetObjectRequest getObjectRequest,
AsyncResponseTransformer<GetObjectResponse,T> asyncResponseTransformer) |
<ReturnT> CompletableFuture<ReturnT> |
MultipartS3AsyncClient.getObject(GetObjectRequest getObjectRequest,
AsyncResponseTransformer<GetObjectResponse,ReturnT> asyncResponseTransformer) |
void |
MultipartDownloaderSubscriber.onNext(AsyncResponseTransformer<GetObjectResponse,GetObjectResponse> asyncResponseTransformer) |
| Modifier and Type | Method and Description |
|---|---|
<ResultT> AsyncResponseTransformer<GetObjectResponse,ResultT> |
TransferProgressUpdater.wrapResponseTransformer(AsyncResponseTransformer<GetObjectResponse,ResultT> responseTransformer) |
<ResultT> AsyncResponseTransformer<GetObjectResponse,ResultT> |
TransferProgressUpdater.wrapResponseTransformerForMultipartDownload(AsyncResponseTransformer<GetObjectResponse,ResultT> responseTransformer,
GetObjectRequest request) |
| Modifier and Type | Method and Description |
|---|---|
<ResultT> AsyncResponseTransformer<GetObjectResponse,ResultT> |
TransferProgressUpdater.wrapResponseTransformer(AsyncResponseTransformer<GetObjectResponse,ResultT> responseTransformer) |
<ResultT> AsyncResponseTransformer<GetObjectResponse,ResultT> |
TransferProgressUpdater.wrapResponseTransformerForMultipartDownload(AsyncResponseTransformer<GetObjectResponse,ResultT> responseTransformer,
GetObjectRequest request) |
| Modifier and Type | Method and Description |
|---|---|
static Pair<DownloadFileRequest,AsyncResponseTransformer<GetObjectResponse,GetObjectResponse>> |
ResumableRequestConverter.toDownloadFileRequestAndTransformer(ResumableFileDownload resumableFileDownload,
HeadObjectResponse headObjectResponse,
DownloadFileRequest originalDownloadRequest)
|
| Modifier and Type | Method and Description |
|---|---|
AsyncResponseTransformer<GetObjectResponse,ReturnT> |
DownloadRequest.responseTransformer()
The
Path to file that response contents will be written to. |
| Modifier and Type | Method and Description |
|---|---|
DownloadRequest.TypedBuilder<T> |
DownloadRequest.TypedBuilder.responseTransformer(AsyncResponseTransformer<GetObjectResponse,T> responseTransformer)
Specifies the
AsyncResponseTransformer that should be used for the download. |
<T> DownloadRequest.TypedBuilder<T> |
DownloadRequest.UntypedBuilder.responseTransformer(AsyncResponseTransformer<GetObjectResponse,T> responseTransformer)
Specifies the
AsyncResponseTransformer that should be used for the download. |
Copyright © 2026. All rights reserved.