Class SplittingPublisher
java.lang.Object
software.amazon.awssdk.core.internal.async.SplittingPublisher
- All Implemented Interfaces:
org.reactivestreams.Publisher<CloseableAsyncRequestBody>
,SdkPublisher<CloseableAsyncRequestBody>
Splits an
AsyncRequestBody
to multiple smaller AsyncRequestBody
s, each of which publishes a specific portion of
the original data.
If content length is known, each AsyncRequestBody
is sent to the subscriber right after it's initialized.
Otherwise, it is sent after the entire content for that chunk is buffered. This is required to get content length.
-
Nested Class Summary
Nested Classes -
Method Summary
Modifier and TypeMethodDescriptionstatic SplittingPublisher.Builder
builder()
Returns a newly initialized builder object for aSplittingPublisher
void
subscribe
(org.reactivestreams.Subscriber<? super CloseableAsyncRequestBody> downstreamSubscriber) 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.SdkPublisher
addTrailingData, buffer, doAfterOnCancel, doAfterOnComplete, doAfterOnError, filter, filter, flatMapIterable, limit, map, subscribe
-
Method Details
-
builder
Returns a newly initialized builder object for aSplittingPublisher
-
subscribe
public void subscribe(org.reactivestreams.Subscriber<? super CloseableAsyncRequestBody> downstreamSubscriber) - Specified by:
subscribe
in interfaceorg.reactivestreams.Publisher<CloseableAsyncRequestBody>
-