Class InputStreamWithExecutorAsyncRequestBody
java.lang.Object
software.amazon.awssdk.core.internal.async.InputStreamWithExecutorAsyncRequestBody
- All Implemented Interfaces:
org.reactivestreams.Publisher<ByteBuffer>
,AsyncRequestBody
,SdkPublisher<ByteBuffer>
A
AsyncRequestBody
that allows reading data off of an InputStream
using a background
ExecutorService
.
Created via AsyncRequestBody.fromInputStream(InputStream, Long, ExecutorService)
.
-
Constructor Summary
ConstructorDescription -
Method Summary
Modifier and TypeMethodDescriptionFuture
<?> 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
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
- Specified by:
contentLength
in interfaceAsyncRequestBody
- Returns:
- The content length of the data being produced.
-
subscribe
- Specified by:
subscribe
in interfaceorg.reactivestreams.Publisher<ByteBuffer>
-
activeWriteFuture
-