com.ibm.cos.v2.utils.async

Class FlatteningSubscriber<U>

java.lang.Object

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

com.ibm.cos.v2.utils.async.BaseSubscriberAdapter<Iterable<U>,U>

com.ibm.cos.v2.utils.async.FlatteningSubscriber<U>

All Implemented Interfaces:

org.reactivestreams.Subscriber<Iterable<U>>

public class FlatteningSubscriber<U>
extends BaseSubscriberAdapter<Iterable<U>,U>

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

Constructor and Description
FlatteningSubscriber(org.reactivestreams.Subscriber<? super U> subscriber)

Method Summary

Modifier and Type	Method and Description
protected void	fulfillDownstreamDemand() This method is called when demand from the downstream subscriber needs to be fulfilled.
void	onNext(Iterable<U> item)

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

handleStateUpdate, onComplete, onError, onSubscribe

Methods inherited from class java.lang.Object

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

Constructor Detail

FlatteningSubscriber

public FlatteningSubscriber(org.reactivestreams.Subscriber<? super U> subscriber)

Method Detail

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<Iterable<U>,U>

onNext

public void onNext(Iterable<U> item)

Specified by:

onNext in interface org.reactivestreams.Subscriber<Iterable<U>>

Overrides:

onNext in class BaseSubscriberAdapter<Iterable<U>,U>