Class NonRetryableSubAsyncRequestBody

java.lang.Object

software.amazon.awssdk.core.internal.async.NonRetryableSubAsyncRequestBody

All Implemented Interfaces:

AutoCloseable, org.reactivestreams.Publisher<ByteBuffer>, AsyncRequestBody, CloseableAsyncRequestBody, SdkPublisher<ByteBuffer>, SubAsyncRequestBody, SdkAutoCloseable

@SdkInternalApi
public final class NonRetryableSubAsyncRequestBody
extends Object
implements SubAsyncRequestBody

A SubAsyncRequestBody implementation that doesn't support resubscribe/retry

Nested Class Summary

Nested classes/interfaces inherited from interface software.amazon.awssdk.core.async.AsyncRequestBody

AsyncRequestBody.BodyType

Constructor Summary

Constructors

Constructor	Description
NonRetryableSubAsyncRequestBody(SubAsyncRequestBodyConfiguration configuration)	Creates a new NonRetryableSubAsyncRequestBody with the given configuration.

Method Summary

Modifier and Type	Method	Description
String	body()	Each AsyncRequestBody should return a well-formed name that can be used to identify the implementation.
void	complete()	Indicate that no more SubAsyncRequestBody.send(ByteBuffer) )} calls will be made, and that stream of messages is completed successfully.
Optional<Long>	contentLength()
void	error(Throwable error)	Signal that the stream has terminated with an error.
long	maxLength()	The maximum length of the content this AsyncRequestBody can hold.
int	partNumber()	The part number associated with this SubAsyncRequestBody
long	receivedBytesLength()	The length of the bytes received
void	send(ByteBuffer data)	Send a byte buffer.
void	subscribe(org.reactivestreams.Subscriber<? super ByteBuffer> s)

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

contentType, split, split, splitCloseable, splitCloseable

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

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

Methods inherited from interface software.amazon.awssdk.core.internal.async.SubAsyncRequestBody

close

Constructor Details

NonRetryableSubAsyncRequestBody

public NonRetryableSubAsyncRequestBody(SubAsyncRequestBodyConfiguration configuration)

Creates a new NonRetryableSubAsyncRequestBody with the given configuration.

Method Details

contentLength

public Optional<Long> contentLength()

Specified by:

contentLength in interface AsyncRequestBody

Returns:

The content length of the data being produced.

send

public void send(ByteBuffer data)

Description copied from interface: SubAsyncRequestBody

Send a byte buffer.

This method must not be invoked concurrently.

Specified by:

send in interface SubAsyncRequestBody

complete

public void complete()

Description copied from interface: SubAsyncRequestBody

Indicate that no more SubAsyncRequestBody.send(ByteBuffer) )} calls will be made, and that stream of messages is completed successfully.

Specified by:

complete in interface SubAsyncRequestBody

maxLength

public long maxLength()

Description copied from interface: SubAsyncRequestBody

The maximum length of the content this AsyncRequestBody can hold. If the upstream content length is known, this should be the same as receivedBytesLength

Specified by:

maxLength in interface SubAsyncRequestBody

receivedBytesLength

public long receivedBytesLength()

Description copied from interface: SubAsyncRequestBody

The length of the bytes received

Specified by:

receivedBytesLength in interface SubAsyncRequestBody

partNumber

public int partNumber()

Description copied from interface: SubAsyncRequestBody

The part number associated with this SubAsyncRequestBody

Specified by:

partNumber in interface SubAsyncRequestBody

Returns:

error

public void error(Throwable error)

Description copied from interface: SubAsyncRequestBody

Signal that the stream has terminated with an error. No more SubAsyncRequestBody.send(ByteBuffer) calls will be made.

Specified by:

error in interface SubAsyncRequestBody

subscribe

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

Specified by:

subscribe in interface org.reactivestreams.Publisher<ByteBuffer>

body

public String body()

Description copied from interface: AsyncRequestBody

Each AsyncRequestBody should return a well-formed name that can be used to identify the implementation. The body name should only include alphanumeric characters.

Specified by:

body in interface AsyncRequestBody

Returns:

String containing the identifying name of this AsyncRequestBody implementation.