Interface SubAsyncRequestBody

All Superinterfaces:

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

All Known Implementing Classes:

NonRetryableSubAsyncRequestBody, RetryableSubAsyncRequestBody

public interface SubAsyncRequestBody
extends CloseableAsyncRequestBody

Represent a sub AsyncRequestBody that publishes a portion of the source AsyncRequestBody

Nested Class Summary

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

AsyncRequestBody.BodyType

Method Summary

Modifier and Type	Method	Description
default void	close()
void	complete()	Indicate that no more send(ByteBuffer) )} calls will be made, and that stream of messages is completed successfully.
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 byteBuffer)	Send a byte buffer.

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

body, contentLength, contentType, split, split, splitCloseable, splitCloseable

Methods inherited from interface org.reactivestreams.Publisher

subscribe

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

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

Method Details

send

void send(ByteBuffer byteBuffer)

Send a byte buffer.

This method must not be invoked concurrently.

complete

void complete()

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

maxLength

long maxLength()

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

receivedBytesLength

long receivedBytesLength()

The length of the bytes received

close

default void close()

Description copied from interface: SdkAutoCloseable

Specified by:

close in interface AutoCloseable

Specified by:

close in interface SdkAutoCloseable

partNumber

int partNumber()

The part number associated with this SubAsyncRequestBody

Returns: