Package software.amazon.encryption.s3.internal

Class NoRetriesAsyncRequestBody

java.lang.Object

software.amazon.encryption.s3.internal.NoRetriesAsyncRequestBody

All Implemented Interfaces:

org.reactivestreams.Publisher<ByteBuffer>, software.amazon.awssdk.core.async.AsyncRequestBody, software.amazon.awssdk.core.async.SdkPublisher<ByteBuffer>

public class NoRetriesAsyncRequestBody
extends Object
implements software.amazon.awssdk.core.async.AsyncRequestBody

AsyncRequestBody which blocks re-subscription. This is useful when retrying is problematic, such as when uploading parts of a multipart upload.

Constructor Summary

Constructors

Constructor	Description
NoRetriesAsyncRequestBody(software.amazon.awssdk.core.async.AsyncRequestBody wrappedAsyncRequestBody)

Method Summary

Modifier and Type	Method	Description
Optional<Long>	contentLength()
void	subscribe(org.reactivestreams.Subscriber<? super ByteBuffer> 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.AsyncRequestBody

contentType, split, split

Methods inherited from interface software.amazon.awssdk.core.async.SdkPublisher

addTrailingData, buffer, doAfterOnCancel, doAfterOnComplete, doAfterOnError, filter, filter, flatMapIterable, limit, map, subscribe

Constructor Detail

NoRetriesAsyncRequestBody

public NoRetriesAsyncRequestBody(software.amazon.awssdk.core.async.AsyncRequestBody wrappedAsyncRequestBody)

Method Detail

contentLength

public Optional<Long> contentLength()

Specified by:

contentLength in interface software.amazon.awssdk.core.async.AsyncRequestBody

subscribe

public void subscribe(org.reactivestreams.Subscriber<? super ByteBuffer> subscriber)

Specified by:

subscribe in interface org.reactivestreams.Publisher<ByteBuffer>