framework/ReactiveXjava/RXJava名词

RXjava名词

Observable

是一个类
public class Observable<T> {

    //一个被观察者

}

Subscriber

消费者

public abstract class Subscriber<T> implements Observer<T>, Subscription {
    
    
}

Observer

/*
提供接收基于推送的通知的机制。
*/
public interface Observer<T> {
    
     /**
     * 通知观察者{@link Observable}已完成发送基于推送的通知。
     * 如果{@link Observable}调用{@link#onError}，它将不会调用此方法。
     */
    void onCompleted();

    /**
     * 通知观察者{@link Observable}遇到错误情况。
     * <p>
     * 如果{@link Observable}调用此方法，则此后它将不会调用{@link#onNext}或{@link{onCompleted}。
     *
     * @param e 被观察对象遇到的异常
     */
    void onError(Throwable e);

    /**
     * 为观察者提供了一个要观察的新项目。
     * <p>
     *{@linkobservable}可以调用此方法0次或多次。
     * <p>
     *{@code observable}在调用{@link onCompleted}或{@link onError}后将不再调用此方法。
     *
     * @param t 被观察者发射的物品
     */
    void onNext(T t);
}

Subscription

Subscription从Observable#subscribe（Subscriber）返回以允许取消订阅。
public interface Subscription {

    /**
     * 停止在接收此订阅时注册的{@link Subscriber}上接收通知。
     * 这允许在{@link Subscriber}完成接收所有事件之前（即调用onCompleted之前）注销它。
     */
    void unsubscribe();

    /**
     *指示此{@code Subscription}当前是否已取消订阅。
     * @return {@code true}如果此{@code Subscription}当前未订阅，否则为{@code false}
     */
    boolean isUnsubscribed();

}

赏

谢谢你请我吃糖果

支付宝

微信

• 本文作者： 忘忧症
• 本文链接： https://NepenthesZGW.github.io/2020/08/16/framework/ReactiveXjava/RXJava名词/
• 版权声明： 本博客所有文章除特别声明外，均采用 MIT 许可协议。转载请注明出处！