com.ibm.cos.v2.utils.async

Class DelegatingBufferingSubscriber

java.lang.Object

com.ibm.cos.v2.utils.async.DelegatingSubscriber<T,U>

com.ibm.cos.v2.utils.async.BaseSubscriberAdapter<ByteBuffer,ByteBuffer>

com.ibm.cos.v2.utils.async.DelegatingBufferingSubscriber

All Implemented Interfaces:

org.reactivestreams.Subscriber<ByteBuffer>

public class DelegatingBufferingSubscriber
extends BaseSubscriberAdapter<ByteBuffer,ByteBuffer>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DelegatingBufferingSubscriber.Builder

Field Summary

Fields inherited from class com.ibm.cos.v2.utils.async.BaseSubscriberAdapter

downstreamDemand, handlingStateUpdate, onCompleteCalledByUpstream, onErrorFromUpstream, terminalCallMadeDownstream, upstreamDemand, upstreamSubscription

Fields inherited from class com.ibm.cos.v2.utils.async.DelegatingSubscriber

subscriber

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	DelegatingBufferingSubscriber(Long maximumBufferInBytes, org.reactivestreams.Subscriber<? super ByteBuffer> delegate)

Method Summary

Modifier and Type	Method and Description
static DelegatingBufferingSubscriber.Builder	builder()
protected void	fulfillDownstreamDemand() This method is called when demand from the downstream subscriber needs to be fulfilled.
void	onSubscribe(org.reactivestreams.Subscription subscription)

Methods inherited from class com.ibm.cos.v2.utils.async.BaseSubscriberAdapter

handleStateUpdate, onComplete, onError, onNext

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DelegatingBufferingSubscriber

protected DelegatingBufferingSubscriber(Long maximumBufferInBytes,
                                        org.reactivestreams.Subscriber<? super ByteBuffer> delegate)

Method Detail

onSubscribe

public void onSubscribe(org.reactivestreams.Subscription subscription)

Specified by:

onSubscribe in interface org.reactivestreams.Subscriber<ByteBuffer>

Overrides:

onSubscribe in class BaseSubscriberAdapter<ByteBuffer,ByteBuffer>

fulfillDownstreamDemand

protected void fulfillDownstreamDemand()

Description copied from class: BaseSubscriberAdapter

This method is called when demand from the downstream subscriber needs to be fulfilled. Called in a loop until downstreamDemand is no longer needed. Implementations are responsible for decrementing the downstreamDemand accordingly as demand gets fulfilled.

Specified by:

fulfillDownstreamDemand in class BaseSubscriberAdapter<ByteBuffer,ByteBuffer>

builder

public static DelegatingBufferingSubscriber.Builder builder()