org.noear.solon.rx

类 SimpleSubscriber<T>

java.lang.Object

org.noear.solon.rx.SimpleSubscriber<T>

所有已实现的接口:

org.reactivestreams.Subscriber<T>

public class SimpleSubscriber<T>
extends java.lang.Object
implements org.reactivestreams.Subscriber<T>

订阅者-简单实现

从以下版本开始:

2.9

构造器概要

构造器

构造器和说明
SimpleSubscriber()

方法概要

限定符和类型	方法和说明
void	cancel() 取消
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>	doOnNext(java.util.function.Function<T,java.lang.Boolean> 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)

从类继承的方法 java.lang.Object

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

构造器详细资料

SimpleSubscriber

public SimpleSubscriber()

方法详细资料

doOnSubscribe

public SimpleSubscriber<T> doOnSubscribe(java.util.function.Consumer<org.reactivestreams.Subscription> doOnSubscribe)

doOnNext

public SimpleSubscriber<T> doOnNext(java.util.function.Function<T,java.lang.Boolean> doOnNext)

往下时（可控制取消）

doOnNext

public SimpleSubscriber<T> doOnNext(java.util.function.Consumer<T> doOnNext)

doOnError

public SimpleSubscriber<T> doOnError(java.util.function.Consumer<java.lang.Throwable> doOnError)

doOnComplete

public SimpleSubscriber<T> doOnComplete(java.lang.Runnable doOnComplete)

cancel

public void cancel()

取消

onSubscribe

public void onSubscribe(org.reactivestreams.Subscription subscription)

指定者:

onSubscribe 在接口中 org.reactivestreams.Subscriber<T>

onNext

public void onNext(T item)

指定者:

onNext 在接口中 org.reactivestreams.Subscriber<T>

onError

public void onError(java.lang.Throwable throwable)

指定者:

onError 在接口中 org.reactivestreams.Subscriber<T>

onComplete

public void onComplete()

指定者:

onComplete 在接口中 org.reactivestreams.Subscriber<T>