Interface AsyncRequestBody

All Superinterfaces:

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

All Known Subinterfaces:

CloseableAsyncRequestBody, SubAsyncRequestBody

All Known Implementing Classes:

AsyncRequestBodyListener.NotifyingAsyncRequestBody, BlockingInputStreamAsyncRequestBody, BlockingOutputStreamAsyncRequestBody, BufferedSplittableAsyncRequestBody, ByteBuffersAsyncRequestBody, ChecksumCalculatingAsyncRequestBody, CompressionAsyncRequestBody, CrtContentLengthOnlyAsyncFileRequestBody, FileAsyncRequestBody, InputStreamWithExecutorAsyncRequestBody, NonRetryableSubAsyncRequestBody, RetryableSubAsyncRequestBody

@SdkPublicApi
@SdkAdvancedApi(cautionWhen=IMPLEMENTED,
                guidance="This is a reactive-streams Publisher and must obey the reactive-streams specification. The SDK re-subscribes on each retry attempt, so to support retries, reproduce the full content on every subscribe; a body that cannot should fail the subscriber on a later subscribe rather than emit partial content.",
                saferAlternative="Prefer the AsyncRequestBody.fromFile/fromBytes/fromInputStream factories. If you must supply a custom Publisher, build it with an established reactive-streams library such as RxJava or Reactor rather than implementing Publisher by hand.")
public interface AsyncRequestBody
extends SdkPublisher<ByteBuffer>

Interface to allow non-blocking streaming of request content. This follows the reactive streams pattern where this interface is the Publisher of data (specifically ByteBuffer chunks) and the HTTP client is the Subscriber of the data (i.e. to write that data on the wire).

Publisher.subscribe(Subscriber) should be implemented to tie this publisher to a subscriber. Ideally each call to subscribe should reproduce the content (i.e if you are reading from a file each subscribe call should produce a Subscription that reads the file fully). This allows for automatic retries to be performed in the SDK. If the content is not reproducible, an exception may be thrown from any subsequent Publisher.subscribe(Subscriber) calls.

It is important to only send the number of chunks that the subscriber requests to avoid out of memory situations. The subscriber does it's own buffering so it's usually not needed to buffer in the publisher. Additional permits for chunks will be notified via the Subscription.request(long) method.

See Also:

• FileAsyncRequestBody
• ByteBuffersAsyncRequestBody

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static enum	AsyncRequestBody.BodyType

Method Summary

Modifier and Type	Method	Description
default String	body()	Each AsyncRequestBody should return a well-formed name that can be used to identify the implementation.
Optional<Long>	contentLength()
default String	contentType()
static AsyncRequestBody	empty()	Creates an AsyncRequestBody with no content.
static BlockingInputStreamAsyncRequestBody	forBlockingInputStream(Long contentLength)	Creates a BlockingInputStreamAsyncRequestBody to use for writing an input stream to the downstream service.
static BlockingOutputStreamAsyncRequestBody	forBlockingOutputStream(Long contentLength)	Creates a BlockingOutputStreamAsyncRequestBody to use for writing to the downstream service as if it's an output stream.
static AsyncRequestBody	fromByteBuffer(ByteBuffer byteBuffer)	Creates an AsyncRequestBody from a ByteBuffer.
static AsyncRequestBody	fromByteBuffers(ByteBuffer... byteBuffers)	Creates an AsyncRequestBody from a ByteBuffer array.
static AsyncRequestBody	fromByteBuffersUnsafe(ByteBuffer... byteBuffers)	Creates an AsyncRequestBody from a ByteBuffer array without copying the contents of each ByteBuffer.
static AsyncRequestBody	fromByteBufferUnsafe(ByteBuffer byteBuffer)	Creates an AsyncRequestBody from a ByteBuffer without copying the contents of the ByteBuffer.
static AsyncRequestBody	fromBytes(byte[] bytes)	Creates an AsyncRequestBody from a byte array.
static AsyncRequestBody	fromBytesUnsafe(byte[] bytes)	Creates an AsyncRequestBody from a byte array without copying the contents of the byte array.
static AsyncRequestBody	fromFile(File file)	Creates an AsyncRequestBody that produces data from the contents of a file.
static AsyncRequestBody	fromFile(Path path)	Creates an AsyncRequestBody that produces data from the contents of a file.
static AsyncRequestBody	fromFile(Consumer<FileRequestBodyConfiguration.Builder> configuration)	Creates an AsyncRequestBody that produces data from the contents of a file.
static AsyncRequestBody	fromFile(FileRequestBodyConfiguration configuration)	Creates an AsyncRequestBody that produces data from the contents of a file.
static AsyncRequestBody	fromInputStream(InputStream inputStream, Long contentLength)	Creates an AsyncRequestBody from an InputStream with SDK-managed executor.
static AsyncRequestBody	fromInputStream(InputStream inputStream, Long contentLength, ExecutorService executor)	Creates an AsyncRequestBody from an InputStream with a customer-provided ExecutorService.
static AsyncRequestBody	fromInputStream(Consumer<AsyncRequestBodyFromInputStreamConfiguration.Builder> configuration)	This is a convenience method that passes an instance of the AsyncRequestBodyFromInputStreamConfiguration builder, avoiding the need to create one manually via AsyncRequestBodyFromInputStreamConfiguration.builder().
static AsyncRequestBody	fromInputStream(AsyncRequestBodyFromInputStreamConfiguration configuration)	Creates an AsyncRequestBody from an InputStream with the provided AsyncRequestBodyFromInputStreamConfiguration.
static AsyncRequestBody	fromPublisher(org.reactivestreams.Publisher<ByteBuffer> publisher)	Creates an AsyncRequestBody the produces data from the input ByteBuffer publisher.
static AsyncRequestBody	fromRemainingByteBuffer(ByteBuffer byteBuffer)	Creates an AsyncRequestBody from the remaining readable bytes from a ByteBuffer.
static AsyncRequestBody	fromRemainingByteBuffers(ByteBuffer... byteBuffers)	Creates an AsyncRequestBody from a ByteBuffer array.
static AsyncRequestBody	fromRemainingByteBuffersUnsafe(ByteBuffer... byteBuffers)	Creates an AsyncRequestBody from a ByteBuffer array without copying the contents of each ByteBuffer.
static AsyncRequestBody	fromRemainingByteBufferUnsafe(ByteBuffer byteBuffer)	Creates an AsyncRequestBody from a ByteBuffer without copying the contents of the ByteBuffer.
static AsyncRequestBody	fromString(String string)	Creates an AsyncRequestBody that uses a single string as data with UTF_8 encoding.
static AsyncRequestBody	fromString(String string, Charset cs)	Creates an AsyncRequestBody that uses a single string as data.
default SdkPublisher<AsyncRequestBody>	split(Consumer<AsyncRequestBodySplitConfiguration.Builder> splitConfiguration)	Deprecated. use splitCloseable(Consumer) instead
default SdkPublisher<AsyncRequestBody>	split(AsyncRequestBodySplitConfiguration splitConfiguration)	Deprecated. use splitCloseable(AsyncRequestBodySplitConfiguration) instead.
default 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().
default 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.

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

contentLength

Optional<Long> contentLength()

Returns:

The content length of the data being produced.

contentType

default String contentType()

Returns:

The content type of the data being produced.

body

default String body()

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

Returns:

String containing the identifying name of this AsyncRequestBody implementation.

fromPublisher

@SdkAdvancedApi(cautionWhen=CALLED,
                guidance="The returned AsyncRequestBody passes each subscribe straight through to the supplied publisher, so the publisher must itself meet the AsyncRequestBody contract: obey the reactive-streams specification, and since the SDK re-subscribes on each retry attempt, reproduce the full content on every subscribe to support retries; a publisher that cannot should fail the subscriber on a later subscribe rather than emit partial content.",
                saferAlternative="Prefer the AsyncRequestBody.fromFile/fromBytes/fromInputStream factories, which do not require the caller to supply a contract-compliant publisher. If you must supply one, build it with an established reactive-streams library such as RxJava or Reactor rather than by hand.")
static AsyncRequestBody fromPublisher(org.reactivestreams.Publisher<ByteBuffer> publisher)

Creates an AsyncRequestBody the produces data from the input ByteBuffer publisher. The data is delivered when the publisher publishes the data.

Parameters:

publisher - Publisher of source data

Returns:

Implementation of AsyncRequestBody that produces data send by the publisher

fromFile

static AsyncRequestBody fromFile(Path path)

Creates an AsyncRequestBody that produces data from the contents of a file. See FileAsyncRequestBody.builder() to create a customized body implementation.

Parameters:

path - Path to file to read from.

Returns:

Implementation of AsyncRequestBody that reads data from the specified file.

See Also:

• FileAsyncRequestBody

fromFile

static AsyncRequestBody fromFile(File file)

Creates an AsyncRequestBody that produces data from the contents of a file. See fromFile(FileRequestBodyConfiguration) to create a customized body implementation.

Parameters:

file - The file to read from.

Returns:

Implementation of AsyncRequestBody that reads data from the specified file.

fromFile

static AsyncRequestBody fromFile(FileRequestBodyConfiguration configuration)

Creates an AsyncRequestBody that produces data from the contents of a file.

Parameters:

configuration - configuration for how the SDK should read the file

Returns:

Implementation of AsyncRequestBody that reads data from the specified file.

fromFile

static AsyncRequestBody fromFile(Consumer<FileRequestBodyConfiguration.Builder> configuration)

Creates an AsyncRequestBody that produces data from the contents of a file.

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

Parameters:

configuration - configuration for how the SDK should read the file

Returns:

Implementation of AsyncRequestBody that reads data from the specified file.

fromString

static AsyncRequestBody fromString(String string,
 Charset cs)

Creates an AsyncRequestBody that uses a single string as data.

Parameters:

string - The string to provide.

cs - The Charset to use.

Returns:

Implementation of AsyncRequestBody that uses the specified string.

See Also:

• ByteBuffersAsyncRequestBody

fromString

static AsyncRequestBody fromString(String string)

Creates an AsyncRequestBody that uses a single string as data with UTF_8 encoding.

Parameters:

string - The string to send.

Returns:

Implementation of AsyncRequestBody that uses the specified string.

See Also:

• fromString(String, Charset)

fromBytes

static AsyncRequestBody fromBytes(byte[] bytes)

Creates an AsyncRequestBody from a byte array. This will copy the contents of the byte array to prevent modifications to the provided byte array from being reflected in the AsyncRequestBody.

Parameters:

bytes - The bytes to send to the service.

Returns:

AsyncRequestBody instance.

fromBytesUnsafe

static AsyncRequestBody fromBytesUnsafe(byte[] bytes)

Creates an AsyncRequestBody from a byte array without copying the contents of the byte array. This introduces concurrency risks, allowing: (1) the caller to modify the byte array stored in this AsyncRequestBody implementation AND (2) any users of fromBytesUnsafe(byte[]) to modify the byte array passed into this AsyncRequestBody implementation.

As the method name implies, this is unsafe. Use fromBytes(byte[]) unless you're sure you know the risks.

Parameters:

bytes - The bytes to send to the service.

Returns:

AsyncRequestBody instance.

fromByteBuffer

static AsyncRequestBody fromByteBuffer(ByteBuffer byteBuffer)

Creates an AsyncRequestBody from a ByteBuffer. This will copy the contents of the ByteBuffer to prevent modifications to the provided ByteBuffer from being reflected in the AsyncRequestBody.

NOTE: This method ignores the current read position. Use fromRemainingByteBuffer(ByteBuffer) if you need it to copy only the remaining readable bytes.

Parameters:

byteBuffer - ByteBuffer to send to the service.

Returns:

AsyncRequestBody instance.

fromRemainingByteBuffer

static AsyncRequestBody fromRemainingByteBuffer(ByteBuffer byteBuffer)

Creates an AsyncRequestBody from the remaining readable bytes from a ByteBuffer. This will copy the remaining contents of the ByteBuffer to prevent modifications to the provided ByteBuffer from being reflected in the AsyncRequestBody.

Unlike fromByteBuffer(ByteBuffer), this method respects the current read position of the buffer and reads only the remaining bytes.

Parameters:

byteBuffer - ByteBuffer to send to the service.

Returns:

AsyncRequestBody instance.

fromByteBufferUnsafe

static AsyncRequestBody fromByteBufferUnsafe(ByteBuffer byteBuffer)

Creates an AsyncRequestBody from a ByteBuffer without copying the contents of the ByteBuffer. This introduces concurrency risks, allowing the caller to modify the ByteBuffer stored in this AsyncRequestBody implementation.

NOTE: This method ignores the current read position. Use fromRemainingByteBufferUnsafe(ByteBuffer) if you need it to copy only the remaining readable bytes.

As the method name implies, this is unsafe. Use fromByteBuffer(ByteBuffer)} unless you're sure you know the risks.

Parameters:

byteBuffer - ByteBuffer to send to the service.

Returns:

AsyncRequestBody instance.

fromRemainingByteBufferUnsafe

static AsyncRequestBody fromRemainingByteBufferUnsafe(ByteBuffer byteBuffer)

Creates an AsyncRequestBody from a ByteBuffer without copying the contents of the ByteBuffer. This introduces concurrency risks, allowing the caller to modify the ByteBuffer stored in this AsyncRequestBody implementation.

Unlike fromByteBufferUnsafe(ByteBuffer), this method respects the current read position of the buffer and reads only the remaining bytes.

As the method name implies, this is unsafe. Use fromByteBuffer(ByteBuffer)} unless you're sure you know the risks.

Parameters:

byteBuffer - ByteBuffer to send to the service.

Returns:

AsyncRequestBody instance.

fromByteBuffers

static AsyncRequestBody fromByteBuffers(ByteBuffer... byteBuffers)

Creates an AsyncRequestBody from a ByteBuffer array. This will copy the contents of each ByteBuffer to prevent modifications to any provided ByteBuffer from being reflected in the AsyncRequestBody.

NOTE: This method ignores the current read position of each ByteBuffer. Use fromRemainingByteBuffers(ByteBuffer...) if you need it to copy only the remaining readable bytes.

Parameters:

byteBuffers - ByteBuffer array to send to the service.

Returns:

AsyncRequestBody instance.

fromRemainingByteBuffers

static AsyncRequestBody fromRemainingByteBuffers(ByteBuffer... byteBuffers)

Creates an AsyncRequestBody from a ByteBuffer array. This will copy the remaining contents of each ByteBuffer to prevent modifications to any provided ByteBuffer from being reflected in the AsyncRequestBody.

Unlike fromByteBufferUnsafe(ByteBuffer), this method respects the current read position of each buffer and reads only the remaining bytes.

Parameters:

byteBuffers - ByteBuffer array to send to the service.

Returns:

AsyncRequestBody instance.

fromByteBuffersUnsafe

static AsyncRequestBody fromByteBuffersUnsafe(ByteBuffer... byteBuffers)

Creates an AsyncRequestBody from a ByteBuffer array without copying the contents of each ByteBuffer. This introduces concurrency risks, allowing the caller to modify any ByteBuffer stored in this AsyncRequestBody implementation.

NOTE: This method ignores the current read position of each ByteBuffer. Use fromRemainingByteBuffers(ByteBuffer...) if you need it to copy only the remaining readable bytes.

As the method name implies, this is unsafe. Use fromByteBuffers(ByteBuffer...) unless you're sure you know the risks.

Parameters:

byteBuffers - ByteBuffer array to send to the service.

Returns:

AsyncRequestBody instance.

fromRemainingByteBuffersUnsafe

static AsyncRequestBody fromRemainingByteBuffersUnsafe(ByteBuffer... byteBuffers)

Creates an AsyncRequestBody from a ByteBuffer array without copying the contents of each ByteBuffer. This introduces concurrency risks, allowing the caller to modify any ByteBuffer stored in this AsyncRequestBody implementation.

Unlike fromByteBuffersUnsafe(ByteBuffer...), this method respects the current read position of each buffer and reads only the remaining bytes.

As the method name implies, this is unsafe. Use fromByteBuffers(ByteBuffer...) unless you're sure you know the risks.

Parameters:

byteBuffers - ByteBuffer array to send to the service.

Returns:

AsyncRequestBody instance.

fromInputStream

static AsyncRequestBody fromInputStream(InputStream inputStream,
 Long contentLength,
 ExecutorService executor)

Creates an AsyncRequestBody from an InputStream with a customer-provided ExecutorService.

An ExecutorService is required in order to perform the blocking data reads, to prevent blocking the non-blocking event loop threads owned by the SDK. Consider using fromInputStream(InputStream, Long) instead, which lets the SDK manage threading internally.

Executor Guidance: The provided executor is used to run a blocking task that reads from the input stream and pushes data to the HTTP connection. If the executor has fewer threads than the number of concurrent requests using it, tasks are serialized — one slow or failing request may block other requests from writing data in a timely manner, leading to idle HTTP connections that the server may close before data can be written. This may result in degraded performance or request timeouts.

To avoid this:

• Use a dedicated executor for SDK input stream requests — do not share it with other blocking work in your application, as competing tasks may delay data writes and cause the same issue.
• Size the executor's thread pool to at least the maximum number of concurrent requests.

It is also recommended to configure an API call timeout via ClientOverrideConfiguration.builder().apiCallTimeout() to bound the total time spent on retries.

Parameters:

inputStream - The input stream containing the data to be sent

contentLength - The content length. If a content length smaller than the actual size of the object is set, the client will truncate the stream to the specified content length and only send exactly the number of bytes equal to the content length.

executor - The executor

Returns:

An AsyncRequestBody instance for the input stream

See Also:

• fromInputStream(InputStream, Long)

fromInputStream

static AsyncRequestBody fromInputStream(InputStream inputStream,
 Long contentLength)

Creates an AsyncRequestBody from an InputStream with SDK-managed executor.

The SDK manages the threading required to perform blocking reads from the input stream without blocking the non-blocking event loop threads.

Parameters:

inputStream - The input stream containing the data to be sent

contentLength - The content length. If a content length smaller than the actual size of the object is set, the client will truncate the stream to the specified content length and only send exactly the number of bytes equal to the content length.

Returns:

An AsyncRequestBody instance for the input stream

See Also:

• fromInputStream(InputStream, Long, ExecutorService)

fromInputStream

static AsyncRequestBody fromInputStream(AsyncRequestBodyFromInputStreamConfiguration configuration)

Creates an AsyncRequestBody from an InputStream with the provided AsyncRequestBodyFromInputStreamConfiguration.

See fromInputStream(InputStream, Long, ExecutorService) for guidance on executor.

fromInputStream

static AsyncRequestBody fromInputStream(Consumer<AsyncRequestBodyFromInputStreamConfiguration.Builder> configuration)

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

See Also:

• fromInputStream(AsyncRequestBodyFromInputStreamConfiguration)

forBlockingInputStream

static BlockingInputStreamAsyncRequestBody forBlockingInputStream(Long contentLength)

Creates a BlockingInputStreamAsyncRequestBody to use for writing an input stream to the downstream service.

By default, it will time out if streaming hasn't started within 10 seconds, and use application/octet-stream as content type. You can configure it via BlockingInputStreamAsyncRequestBody.builder()

Example Usage

    S3AsyncClient s3 = S3AsyncClient.create(); // Use one client for your whole application!

    byte[] dataToSend = "Hello".getBytes(StandardCharsets.UTF_8);
    InputStream streamToSend = new ByteArrayInputStream(dataToSend);
    long streamToSendLength = dataToSend.length;

    // Start the operation
    BlockingInputStreamAsyncRequestBody body =
        AsyncRequestBody.forBlockingInputStream(streamToSendLength);
    CompletableFuture<PutObjectResponse> responseFuture =
        s3.putObject(r -> r.bucket("bucketName").key("key"), body);

    // Write the input stream to the running operation
    body.writeInputStream(streamToSend);

    // Wait for the service to respond.
    PutObjectResponse response = responseFuture.join();

Parameters:

contentLength - The content length. If a content length smaller than the actual size of the object is set, the client will truncate the stream to the specified content length and only send exactly the number of bytes equal to the content length.

Returns:

The created BlockingInputStreamAsyncRequestBody.

forBlockingOutputStream

static BlockingOutputStreamAsyncRequestBody forBlockingOutputStream(Long contentLength)

Creates a BlockingOutputStreamAsyncRequestBody to use for writing to the downstream service as if it's an output stream. Retries are not supported for this request body.

The caller is responsible for calling OutputStream.close() on the BlockingOutputStreamAsyncRequestBody.outputStream() when writing is complete.

By default, it will time out if streaming hasn't started within 10 seconds, and you can configure the timeout via BlockingOutputStreamAsyncRequestBody.builder()

Example Usage

    S3AsyncClient s3 = S3AsyncClient.create(); // Use one client for your whole application!

    byte[] dataToSend = "Hello".getBytes(StandardCharsets.UTF_8);
    long lengthOfDataToSend = dataToSend.length();

    // Start the operation
    BlockingOutputStreamAsyncRequestBody body =
        AsyncRequestBody.forBlockingOutputStream(lengthOfDataToSend);
    CompletableFuture<PutObjectResponse> responseFuture =
        s3.putObject(r -> r.bucket("bucketName").key("key"), body);

    // Write the input stream to the running operation
    try (CancellableOutputStream outputStream = body.outputStream()) {
        outputStream.write(dataToSend);
    }

    // Wait for the service to respond.
    PutObjectResponse response = responseFuture.join();

Parameters:

contentLength - The content length. If a content length smaller than the actual size of the object is set, the client will truncate the stream to the specified content length and only send exactly the number of bytes equal to the content length.

Returns:

The created BlockingOutputStreamAsyncRequestBody.

See Also:

• BlockingOutputStreamAsyncRequestBody

empty

static AsyncRequestBody empty()

Creates an AsyncRequestBody with no content.

Returns:

AsyncRequestBody instance.

split

@Deprecated
default SdkPublisher<AsyncRequestBody> split(AsyncRequestBodySplitConfiguration splitConfiguration)

Deprecated.

use splitCloseable(AsyncRequestBodySplitConfiguration) instead.

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.

splitCloseable

default 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. The default chunk size is 2MB and the default buffer size is 8MB.

The default implementation behaves the same as 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.

See Also:

• splitCloseable(Consumer)
• AsyncRequestBodySplitConfiguration

split

@Deprecated
default SdkPublisher<AsyncRequestBody> split(Consumer<AsyncRequestBodySplitConfiguration.Builder> splitConfiguration)

Deprecated.

use splitCloseable(Consumer) instead

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

See Also:

• split(AsyncRequestBodySplitConfiguration)

splitCloseable

default 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().

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.

See Also:

• splitCloseable(AsyncRequestBodySplitConfiguration)