Class ByteArraySplittingTransformer<ResponseT>
java.lang.Object
software.amazon.awssdk.core.internal.async.ByteArraySplittingTransformer<ResponseT>
- All Implemented Interfaces:
org.reactivestreams.Publisher<AsyncResponseTransformer<ResponseT,
,ResponseT>> SdkPublisher<AsyncResponseTransformer<ResponseT,
ResponseT>>
public class ByteArraySplittingTransformer<ResponseT>
extends Object
implements SdkPublisher<AsyncResponseTransformer<ResponseT,ResponseT>>
A splitting transformer that creates individual
ByteArrayAsyncResponseTransformer
instances for each part of a
multipart download. This is necessary to support retries of individual part downloads.
This class is created by ByteArrayAsyncResponseTransformer.split(software.amazon.awssdk.core.SplittingTransformerConfiguration)
and used internally by the multipart
download logic.
-
Constructor Summary
ConstructorsConstructorDescriptionByteArraySplittingTransformer
(AsyncResponseTransformer<ResponseT, ResponseBytes<ResponseT>> upstreamResponseTransformer, CompletableFuture<ResponseBytes<ResponseT>> resultFuture) -
Method Summary
Modifier and TypeMethodDescriptionvoid
subscribe
(org.reactivestreams.Subscriber<? super AsyncResponseTransformer<ResponseT, ResponseT>> subscriber) Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface software.amazon.awssdk.core.async.SdkPublisher
addTrailingData, buffer, doAfterOnCancel, doAfterOnComplete, doAfterOnError, filter, filter, flatMapIterable, limit, map, subscribe
-
Constructor Details
-
ByteArraySplittingTransformer
public ByteArraySplittingTransformer(AsyncResponseTransformer<ResponseT, ResponseBytes<ResponseT>> upstreamResponseTransformer, CompletableFuture<ResponseBytes<ResponseT>> resultFuture)
-
-
Method Details
-
subscribe
public void subscribe(org.reactivestreams.Subscriber<? super AsyncResponseTransformer<ResponseT, ResponseT>> subscriber) - Specified by:
subscribe
in interfaceorg.reactivestreams.Publisher<ResponseT>
-