Package software.amazon.awssdk.utils.async

Class FlatteningSubscriber<U>

java.lang.Object

software.amazon.awssdk.utils.async.DelegatingSubscriber<Iterable<U>,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>>

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	onNext(Iterable<U> item)

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

onComplete, onError, onSubscribe

Methods inherited from class java.lang.Object

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

Constructor Details

FlatteningSubscriber

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

Method Details

onNext

public void onNext(Iterable<U> item)

Specified by:

onNext in interface org.reactivestreams.Subscriber<U>

Overrides:

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