Class InputStreamWithExecutorAsyncRequestBody

java.lang.Object

software.amazon.awssdk.core.internal.async.InputStreamWithExecutorAsyncRequestBody

All Implemented Interfaces:

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

@SdkInternalApi
public class InputStreamWithExecutorAsyncRequestBody
extends Object
implements AsyncRequestBody

A AsyncRequestBody that allows reading data off of an InputStream using a background ExecutorService.

Created via AsyncRequestBody.fromInputStream(InputStream, Long, ExecutorService).

Nested Class Summary

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

AsyncRequestBody.BodyType

Constructor Summary

Constructors

Constructor	Description
InputStreamWithExecutorAsyncRequestBody(AsyncRequestBodyFromInputStreamConfiguration configuration)

Method Summary

Modifier and Type	Method	Description
Future<?>	activeWriteFuture()
String	body()	Each AsyncRequestBody should return a well-formed name that can be used to identify the implementation.
Optional<Long>	contentLength()
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

Constructor Details

InputStreamWithExecutorAsyncRequestBody

public InputStreamWithExecutorAsyncRequestBody(AsyncRequestBodyFromInputStreamConfiguration configuration)

Method Details

contentLength

public Optional<Long> contentLength()

Specified by:

contentLength in interface AsyncRequestBody

Returns:

The content length of the data being produced.

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.

activeWriteFuture

@SdkTestInternalApi
public Future<?> activeWriteFuture()