Class SplittingPublisher
java.lang.Object
software.amazon.awssdk.core.internal.async.SplittingPublisher
- All Implemented Interfaces:
org.reactivestreams.Publisher<AsyncRequestBody>
,SdkPublisher<AsyncRequestBody>
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.
-
Constructor Summary
ConstructorDescriptionSplittingPublisher
(AsyncRequestBody asyncRequestBody, AsyncRequestBodySplitConfiguration splitConfiguration) -
Method Summary
Modifier and TypeMethodDescriptionvoid
subscribe
(org.reactivestreams.Subscriber<? super AsyncRequestBody> 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
-
Constructor Details
-
SplittingPublisher
public SplittingPublisher(AsyncRequestBody asyncRequestBody, AsyncRequestBodySplitConfiguration splitConfiguration)
-
-
Method Details
-
subscribe
public void subscribe(org.reactivestreams.Subscriber<? super AsyncRequestBody> downstreamSubscriber) - Specified by:
subscribe
in interfaceorg.reactivestreams.Publisher<AsyncRequestBody>
-