RxJava 2 常用操作符

1. 创建操作符

• create()：创建一个 Observable，通过回调发射数据。
• just()：创建一个发射单个项的 Observable。
• fromIterable()：从一个可迭代的集合创建 Observable。
• interval()：创建一个发射递增整数的 Observable，每隔一段时间发射一次。

2. 转换操作符

• map()：将发射的数据转换为另一种形式。

  observable.map(data -> data * 2);
  

• flatMap()：将发射的数据转换为 Observable 并合并结果。

  observable.flatMap(data -> Observable.fromArray(data.getItems()));
  

3. 过滤操作符

• filter()：根据条件过滤发射的数据。

  observable.filter(data -> data > 10);
  

• take()：只取前 N 个数据项。
• skip()：跳过前 N 个数据项。

4. 组合操作符

• merge()：合并多个 Observable 的数据。
• zip()：组合多个 Observable 的发射数据，将它们成对合并。

5. 错误处理操作符

• onErrorReturn()：在发生错误时提供一个备用数据项。
• retry()：在发生错误时重新尝试订阅。

6. 终止操作符

• subscribe()：启动 Observable 的数据流，并处理数据或错误。
• dispose()：取消订阅，释放资源。

7. 调度器

• subscribeOn()：指定 Observable 创建和发射数据的线程。
• observeOn()：指定观察者处理数据的线程。

8. 组合操作符

• combineLatest()：将多个 Observable 的最新数据合并。
• switchMap()：切换到新的 Observable，丢弃先前的发射。