Package software.amazon.awssdk.core.async.listener

Class AsyncRequestBodyListener.NotifyingAsyncRequestBody

java.lang.Object

software.amazon.awssdk.core.async.listener.AsyncRequestBodyListener.NotifyingAsyncRequestBody

All Implemented Interfaces:

org.reactivestreams.Publisher<ByteBuffer>, AsyncRequestBody, SdkPublisher<ByteBuffer>

Enclosing interface:

AsyncRequestBodyListener

@SdkInternalApi
public static final class AsyncRequestBodyListener.NotifyingAsyncRequestBody
extends Object
implements 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
Optional<Long>	contentLength()
String	contentType()
SdkPublisher<AsyncRequestBody>	split(Consumer<AsyncRequestBodySplitConfiguration.Builder> splitConfiguration)	This is a convenience method that passes an instance of the AsyncRequestBodySplitConfiguration builder, avoiding the need to create one manually via AsyncRequestBodySplitConfiguration.builder().
SdkPublisher<AsyncRequestBody>	split(AsyncRequestBodySplitConfiguration splitConfiguration)	Converts this AsyncRequestBody to a publisher of AsyncRequestBodys, each of which publishes a specific portion of the original data, based on the provided AsyncRequestBodySplitConfiguration.
SdkPublisher<CloseableAsyncRequestBody>	splitCloseable(Consumer<AsyncRequestBodySplitConfiguration.Builder> splitConfiguration)	This is a convenience method that passes an instance of the AsyncRequestBodySplitConfiguration builder, avoiding the need to create one manually via AsyncRequestBodySplitConfiguration.builder().
SdkPublisher<CloseableAsyncRequestBody>	splitCloseable(AsyncRequestBodySplitConfiguration splitConfiguration)	Converts this AsyncRequestBody to a publisher of CloseableAsyncRequestBodys, each of which publishes specific portion of the original data, based on the provided AsyncRequestBodySplitConfiguration.
void	subscribe(org.reactivestreams.Subscriber<? super ByteBuffer> 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.AsyncRequestBody

body

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

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

Method Details

contentLength

public Optional<Long> contentLength()

Specified by:

contentLength in interface AsyncRequestBody

Returns:

The content length of the data being produced.

contentType

public String contentType()

Specified by:

contentType in interface AsyncRequestBody

Returns:

The content type of the data being produced.

split

public SdkPublisher<AsyncRequestBody> split(AsyncRequestBodySplitConfiguration splitConfiguration)

Description copied from interface: AsyncRequestBody

Converts this AsyncRequestBody to a publisher of AsyncRequestBodys, each of which publishes a specific portion of the original data, based on the provided AsyncRequestBodySplitConfiguration. The default chunk size is 2MB and the default buffer size is 8MB.

By default, if content length of this AsyncRequestBody is present, each divided AsyncRequestBody is delivered to the subscriber right after it's initialized. On the other hand, if content length is null, it is sent after the entire content for that chunk is buffered. In this case, the configured maxMemoryUsageInBytes must be larger than or equal to chunkSizeInBytes. Note that this behavior may be different if a specific implementation of this interface overrides this method.

Specified by:

split in interface AsyncRequestBody

split

public SdkPublisher<AsyncRequestBody> split(Consumer<AsyncRequestBodySplitConfiguration.Builder> splitConfiguration)

Description copied from interface: AsyncRequestBody

This is a convenience method that passes an instance of the AsyncRequestBodySplitConfiguration builder, avoiding the need to create one manually via AsyncRequestBodySplitConfiguration.builder().

Specified by:

split in interface AsyncRequestBody

See Also:

• AsyncRequestBody.split(AsyncRequestBodySplitConfiguration)

splitCloseable

public SdkPublisher<CloseableAsyncRequestBody> splitCloseable(AsyncRequestBodySplitConfiguration splitConfiguration)

Description copied from interface: AsyncRequestBody

Converts this AsyncRequestBody to a publisher of CloseableAsyncRequestBodys, each of which publishes specific portion of the original data, based on the provided AsyncRequestBodySplitConfiguration. The default chunk size is 2MB and the default buffer size is 8MB.

The default implementation behaves the same as AsyncRequestBody.split(AsyncRequestBodySplitConfiguration). This behavior may vary in different implementations.

Caller is responsible for closing CloseableAsyncRequestBody when it is ready to be disposed to release any resources.

Note: This method is primarily intended for use by AWS SDK high-level libraries and internal components. SDK customers should typically use higher-level APIs provided by service clients rather than calling this method directly.

Specified by:

splitCloseable in interface AsyncRequestBody

See Also:

• AsyncRequestBody.splitCloseable(Consumer)
• AsyncRequestBodySplitConfiguration

splitCloseable

public SdkPublisher<CloseableAsyncRequestBody> splitCloseable(Consumer<AsyncRequestBodySplitConfiguration.Builder> splitConfiguration)

Description copied from interface: AsyncRequestBody

This is a convenience method that passes an instance of the AsyncRequestBodySplitConfiguration builder, avoiding the need to create one manually via AsyncRequestBodySplitConfiguration.builder().

Note: This method is primarily intended for use by AWS SDK high-level libraries and internal components. SDK customers should typically use higher-level APIs provided by service clients rather than calling this method directly.

Specified by:

splitCloseable in interface AsyncRequestBody

See Also:

• AsyncRequestBody.splitCloseable(AsyncRequestBodySplitConfiguration)

subscribe

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

Specified by:

subscribe in interface org.reactivestreams.Publisher<ByteBuffer>