Class DelegatingBufferingSubscriber
java.lang.Object
software.amazon.awssdk.utils.async.DelegatingSubscriber<T,U>
software.amazon.awssdk.utils.async.BaseSubscriberAdapter<ByteBuffer,ByteBuffer>
software.amazon.awssdk.utils.async.DelegatingBufferingSubscriber
- All Implemented Interfaces:
org.reactivestreams.Subscriber<ByteBuffer>
@SdkProtectedApi
public class DelegatingBufferingSubscriber
extends BaseSubscriberAdapter<ByteBuffer,ByteBuffer>
-
Nested Class Summary
Nested Classes -
Field Summary
Fields inherited from class software.amazon.awssdk.utils.async.BaseSubscriberAdapter
downstreamDemand, handlingStateUpdate, onCompleteCalledByUpstream, onErrorFromUpstream, terminalCallMadeDownstream, upstreamDemand, upstreamSubscriptionFields inherited from class software.amazon.awssdk.utils.async.DelegatingSubscriber
subscriber -
Constructor Summary
ConstructorsModifierConstructorDescriptionprotectedDelegatingBufferingSubscriber(Long maximumBufferInBytes, org.reactivestreams.Subscriber<? super ByteBuffer> delegate) -
Method Summary
Modifier and TypeMethodDescriptionbuilder()protected voidThis method is called when demand from the downstream subscriber needs to be fulfilled.voidonSubscribe(org.reactivestreams.Subscription subscription) Methods inherited from class software.amazon.awssdk.utils.async.BaseSubscriberAdapter
handleStateUpdate, onComplete, onError, onNext
-
Constructor Details
-
DelegatingBufferingSubscriber
protected DelegatingBufferingSubscriber(Long maximumBufferInBytes, org.reactivestreams.Subscriber<? super ByteBuffer> delegate)
-
-
Method Details
-
onSubscribe
public void onSubscribe(org.reactivestreams.Subscription subscription) - Specified by:
onSubscribein interfaceorg.reactivestreams.Subscriber<ByteBuffer>- Overrides:
onSubscribein classBaseSubscriberAdapter<ByteBuffer,ByteBuffer>
-
fulfillDownstreamDemand
protected void fulfillDownstreamDemand()Description copied from class:BaseSubscriberAdapterThis method is called when demand from the downstream subscriber needs to be fulfilled. Called in a loop untildownstreamDemandis no longer needed. Implementations are responsible for decrementing thedownstreamDemandaccordingly as demand gets fulfilled.- Specified by:
fulfillDownstreamDemandin classBaseSubscriberAdapter<ByteBuffer,ByteBuffer>
-
builder
-