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 to calculate checksum as it reads data and append Checksum as trailer at the end.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> Subscription which can emitsignals to a subscriber, based on the demand received with theinvalid reference
Subscriber#onNext(T)Subscription.request(long).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.FileAsyncResponseTransformerPublisher<T extends SdkResponse>A publisher ofFileAsyncResponseTransformerthat uses the Content-Range header of aSdkResponseto write to the offset defined in the range of the Content-Range.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.