Package software.amazon.awssdk.utils.async

Class FlatteningSubscriber<U>

java.lang.Object

software.amazon.awssdk.utils.async.DelegatingSubscriber<T,U>

software.amazon.awssdk.utils.async.BaseSubscriberAdapter<Iterable<U>,U>

software.amazon.awssdk.utils.async.FlatteningSubscriber<U>

All Implemented Interfaces:

org.reactivestreams.Subscriber<Iterable<U>>

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

Field Summary

Fields inherited from class software.amazon.awssdk.utils.async.BaseSubscriberAdapter

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

Fields inherited from class software.amazon.awssdk.utils.async.DelegatingSubscriber

subscriber

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	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 software.amazon.awssdk.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 Details

FlatteningSubscriber

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

Method Details

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

Overrides:

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