Package software.amazon.awssdk.core.internal.async
package software.amazon.awssdk.core.internal.async
-
ClassDescriptionByteArrayAsyncResponseTransformer<ResponseT>Implementation of
AsyncResponseTransformerthat dumps content into a byte array and supports further conversions into types, like strings.ByteArraySplittingTransformer<ResponseT>A splitting transformer that creates individualByteArrayAsyncResponseTransformerinstances for each part of a multipart download.An implementation ofAsyncRequestBodyfor providing data from the suppliedByteBufferarray.Wrapper class to wrap an AsyncRequestBody.Publisher to update the checksum as it reads the data and finally compares the computed checksum with expected Checksum.Class that will buffer incoming BufferBytes to chunks of bufferSize.Wrapper class to wrap an AsyncRequestBody.DefaultAsyncResponseTransformerSplitResult<ResponseT,ResultT> DefaultAsyncResponseTransformerSplitResult.DefaultBuilder<ResponseT,ResultT> Publisher implementation that wraps the content of another publisher in an envelope with an optional prefix (or header) and suffix (or footer).Implementation ofAsyncRequestBodythat reads data from a file.A builder forFileAsyncRequestBody.A helper class to split aFileAsyncRequestBodyto multiple smaller async request bodies.FileAsyncResponseTransformer<ResponseT>AsyncResponseTransformerthat writes the data to the specified file.InputStreamResponseTransformer<ResponseT extends SdkResponse>AAsyncResponseTransformerthat allows performing blocking reads on the response data.AAsyncRequestBodythat allows reading data off of anInputStreamusing a backgroundExecutorService.ASubAsyncRequestBodyimplementation that doesn't support resubscribe/retryPublisherAsyncResponseTransformer<ResponseT extends SdkResponse>Transforms aPublisherAsyncResponseTransformerandByteBufferSdkPublisherinto aResponsePublisher.ASubAsyncRequestBodyimplementation that supports resubscribe/retry once all data has been published to the first subscriberCommon implementations ofSdkPublisherthat are provided for convenience when building asynchronous interceptors to be used with specific clients.Splits anAsyncRequestBodyto multiple smallerAsyncRequestBodys, each of which publishes a specific portion of the original data.SplittingTransformer<ResponseT,ResultT> Split aAsyncResponseTransformerinto multiple ones, publishing them as aSdkPublisher.SplittingTransformer.Builder<ResponseT,ResultT> Represent a subAsyncRequestBodythat publishes a portion of the sourceAsyncRequestBodyConfiguration class containing shared properties for SubAsyncRequestBody implementations.