美文网首页Rxjava以及Retrofit笔记
Rxjava2.0笔记-002-创建操作符

Rxjava2.0笔记-002-创建操作符

作者: ccccccal | 来源:发表于2018-01-09 20:40 被阅读20次

    文章同步于我的个人站:http://guojian.site

    1.observer的subscribe()具备多个重载的方法

    public final Disposable subscribe() {}
     // 表示观察者不对被观察者发送的事件作出任何响应(但被观察者还是可以继续发送事件)
    
    public final Disposable subscribe(Consumer<? super T> onNext) {}
    // 表示观察者只对被观察者发送的Next事件作出响应
    
    public final Disposable subscribe(Consumer<? super T> onNext, Consumer<? super Throwable> onError) {} 
    // 表示观察者只对被观察者发送的Next事件 & Error事件作出响应
    
    public final Disposable subscribe(Consumer<? super T> onNext, Consumer<? super Throwable> onError, Action onComplete) {}
    // 表示观察者只对被观察者发送的Next事件、Error事件 & Complete事件作出响应
    
    public final Disposable subscribe(Consumer<? super T> onNext, Consumer<? super Throwable> onError, Action onComplete, Consumer<? super Disposable> onSubscribe) {}
    // 表示观察者只对被观察者发送的Next事件、Error事件 、Complete事件 & onSubscribe事件作出响应
    
    public final void subscribe(Observer<? super T> observer) {}
    // 表示观察者对被观察者发送的任何事件都作出响应
    
    

    2.切断连接采用Disposable.dispose(),观察者 无法继续 接收 被观察者的事件,但被观察者还是可以继续发送事件

     mDisposable.dispose();
    

    3.创建操作符分类如下:

    • 基本创建 create()

    • 快速创建,

      • just():最多发送十个参数

      • fromArray():传入一个数组,长度不限制,传入集合必须转为数组,否则当成一个事件

      • fromIterable():传入list集合

      • never():不发送任何事件

      • empty():仅发送Complete事件,直接通知Observable observable = Observable.empty();

      • error():该方法创建的被观察者对象仅发送Error事件,直接通知异常,可以自定义Observable observable2=Observable.error(new RuntimeException())即观察者接收后会直接调用onError()

    • 延迟创建

      1.定时操作:经过X秒后,自动执行Y操作
      2.周期性操作:每隔X秒后,自动执行Y操作

      • defer():直到有观察者订阅时,才会动态创建被观察者,发送事件

        1. 通过 Observable工厂方法创建被观察者对象(Observable)
        2. 每次订阅后,都会得到一个刚创建的最新的Observable对象,这可以确保Observable对象里的数据是最新的
        ```
        // 注:此时被观察者对象还没创建
        Observable<Integer> observable = Observable.defer(new Callable<ObservableSource<? extends Integer>>() {
            @Override
            public ObservableSource<? extends Integer> call() throws Exception {
                return Observable.just(i);
            }
        });
        ```
        
      • timer()

        1. 快速创建一个被观察者对象(Observable)
        2. 发送事件的特点:延迟指定时间后,发送1个数值0(long了类型)
        3. 延迟指定时间后,调用一次onnext(0),一般用于检测
      • interval()

        1. 快速创建1个被观察者对象(Observable)
        2. 发送事件的特点:每隔指定时间 就发送 事件
      • intervalRange()

        1. 每隔指定时间 就发送 事件,可指定发送的数据的数量
      • range()

        1. 连续发送 1个事件序列,可指定范围

    相关文章

      网友评论

        本文标题:Rxjava2.0笔记-002-创建操作符

        本文链接:https://www.haomeiwen.com/subject/ckpgnxtx.html