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

发表于

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个事件序列，可指定范围