public class BufferingSubscriber<T> extends DelegatingSubscriber<T,List<T>>
Constructor and Description |
---|
BufferingSubscriber(org.reactivestreams.Subscriber<? super List<T>> subscriber,
int bufferSize) |
Modifier and Type | Method and Description |
---|---|
void |
onComplete() |
void |
onNext(T t) |
onError, onSubscribe
public void onNext(T t)
public void onComplete()
onComplete
in interface org.reactivestreams.Subscriber<T>
onComplete
in class DelegatingSubscriber<T,List<T>>
Copyright © 2017 Amazon Web Services, Inc. All Rights Reserved.