Package software.amazon.awssdk.core.internal.async

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>>

@SdkInternalApi
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

Constructors

Constructor	Description
ByteArraySplittingTransformer(AsyncResponseTransformer<ResponseT,ResponseBytes<ResponseT>> upstreamResponseTransformer, CompletableFuture<ResponseBytes<ResponseT>> resultFuture)

Method Summary

Modifier and Type	Method	Description
void	subscribe(org.reactivestreams.Subscriber<? super AsyncResponseTransformer<ResponseT,ResponseT>> subscriber)

Methods inherited from class java.lang.Object

clone, equals, finalize, 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 interface org.reactivestreams.Publisher<ResponseT>