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

Class FileAsyncResponseTransformerPublisher<T extends SdkResponse>

java.lang.Object

software.amazon.awssdk.core.internal.async.FileAsyncResponseTransformerPublisher<T>

All Implemented Interfaces:

org.reactivestreams.Publisher<AsyncResponseTransformer<T,T>>, SdkPublisher<AsyncResponseTransformer<T,T>>

@SdkInternalApi
public class FileAsyncResponseTransformerPublisher<T extends SdkResponse>
extends Object
implements SdkPublisher<AsyncResponseTransformer<T,T>>

A publisher of FileAsyncResponseTransformer that uses the Content-Range header of a SdkResponse to write to the offset defined in the range of the Content-Range. Correspond to the SplittingTransformer for non-linear write cases.

Constructor Summary

Constructors

Constructor	Description
FileAsyncResponseTransformerPublisher(FileAsyncResponseTransformer<?> responseTransformer)

Method Summary

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

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

FileAsyncResponseTransformerPublisher

public FileAsyncResponseTransformerPublisher(FileAsyncResponseTransformer<?> responseTransformer)

Method Details

subscribe

public void subscribe(org.reactivestreams.Subscriber<? super AsyncResponseTransformer<T,T>> s)

Specified by:

subscribe in interface org.reactivestreams.Publisher<T extends SdkResponse>