RxJava2（三）：操作符的巧妙运用，你不可错过的强大用法

Android

2024-01-08 22:12:30

终于到了操作符了，我认为 RxJava2 如此好用，绝对少不了操作符的功劳。先简单扫一眼下方图片，别慌，我们慢慢了解。

上一篇讲了，RxJava2 有五种观察者创建模式，其中 Observable 和 Flowable 差不多，只是 Flowable 支持背压，而其他三种，都是简化版的 Observable。

操作符是 RxJava2 的核心，它提供了丰富的功能来处理数据流。操作符可以分为三大类：

创建操作符：用于创建观察者。
变换操作符：用于对数据流进行变换。
组合操作符：用于将多个数据流组合成一个新的数据流。

操作符的使用非常灵活，可以组合使用以实现各种复杂的功能。

例如，我们可以使用 map 操作符将数据流中的每个元素都乘以 2，也可以使用 filter 操作符将数据流中的偶数元素过滤掉，还可以使用 flatMap 操作符将数据流中的每个元素都展开成一个新的数据流。

操作符的妙用无穷，只有充分理解和掌握操作符，才能真正发挥 RxJava2 的强大威力。

本文将介绍一些常用的操作符，并通过示例展示其用法。

map 操作符

map 操作符用于将数据流中的每个元素都应用一个函数，并返回一个新的数据流。

Observable.just(1, 2, 3)
        .map(integer -> integer * 2)
        .subscribe(integer -> System.out.println(integer));

上面的代码将创建一个观察者，并向其中发射 3 个数字（1、2、3）。然后，使用 map 操作符将这 3 个数字都乘以 2，并得到一个新的数据流。最后，使用 subscribe 操作符订阅这个新的数据流，并在其中打印出每个数字。

filter 操作符

filter 操作符用于将数据流中的元素都应用一个谓词，并只返回满足该谓词的元素。

Observable.just(1, 2, 3, 4, 5)
        .filter(integer -> integer % 2 == 0)
        .subscribe(integer -> System.out.println(integer));

上面的代码将创建一个观察者，并向其中发射 5 个数字（1、2、3、4、5）。然后，使用 filter 操作符将这 5 个数字都应用一个谓词，即判断数字是否为偶数。只有满足该谓词的数字才会被返回到新的数据流中。最后，使用 subscribe 操作符订阅这个新的数据流，并在其中打印出每个数字。

flatMap 操作符

flatMap 操作符用于将数据流中的每个元素都展开成一个新的数据流，并最终将所有这些新的数据流合并成一个新的数据流。

Observable.just(1, 2, 3)
        .flatMap(integer -> Observable.range(integer, 3))
        .subscribe(integer -> System.out.println(integer));

上面的代码将创建一个观察者，并向其中发射 3 个数字（1、2、3）。然后，使用 flatMap 操作符将这 3 个数字都展开成一个新的数据流。每个新的数据流都包含 3 个数字（分别为 1、2、3、2、3、4、3、4、5）。最后，使用 subscribe 操作符订阅这个新的数据流，并在其中打印出每个数字。