public class SimpleSubscriber<T>
extends java.lang.Object
implements org.reactivestreams.Subscriber<T>
构造器和说明 |
---|
SimpleSubscriber() |
限定符和类型 | 方法和说明 |
---|---|
SimpleSubscriber<T> |
doOnComplete(java.lang.Runnable doOnComplete) |
SimpleSubscriber<T> |
doOnError(java.util.function.Consumer<java.lang.Throwable> doOnError) |
SimpleSubscriber<T> |
doOnNext(java.util.function.Consumer<T> doOnNext) |
SimpleSubscriber<T> |
doOnSubscribe(java.util.function.Consumer<org.reactivestreams.Subscription> doOnSubscribe) |
void |
onComplete() |
void |
onError(java.lang.Throwable throwable) |
void |
onNext(T item) |
void |
onSubscribe(org.reactivestreams.Subscription subscription) |
public SimpleSubscriber<T> doOnSubscribe(java.util.function.Consumer<org.reactivestreams.Subscription> doOnSubscribe)
public SimpleSubscriber<T> doOnNext(java.util.function.Consumer<T> doOnNext)
public SimpleSubscriber<T> doOnError(java.util.function.Consumer<java.lang.Throwable> doOnError)
public SimpleSubscriber<T> doOnComplete(java.lang.Runnable doOnComplete)
public void onSubscribe(org.reactivestreams.Subscription subscription)
onSubscribe
在接口中 org.reactivestreams.Subscriber<T>
public void onError(java.lang.Throwable throwable)
onError
在接口中 org.reactivestreams.Subscriber<T>
public void onComplete()
onComplete
在接口中 org.reactivestreams.Subscriber<T>