RxJava2 源码解析（四）：变幻莫测的变换操作符

2023-12-10 18:37:29

在上一篇中，我们探讨了 RxJava2 的线程池原理，而今天，我们将把目光转向 RxJava2 的另一个关键功能：变换。变换和线程切换并称为 RxJava2 最核心的两大功能。

在 RxJava2 中，变换操作符是一组强大的工具，允许我们对数据流进行各种各样的操作，从简单的映射到复杂的数据转换。在本文中，我们将重点关注两个最常用的变换操作符：map() 和 flatMap()。

map() 操作符

map() 操作符用于将数据流中的每一个元素映射到一个新的元素。这个操作符非常灵活，可以用于各种各样的场景，例如：

将字符串转换为整数
将对象转换为 JSON 字符串
将数据流中的元素过滤掉

以下是一个简单的示例，展示了如何使用 map() 操作符将字符串流转换为整数流：

Observable<String> observable = Observable.just("1", "2", "3");

Observable<Integer> integerObservable = observable.map(Integer::parseInt);

integerObservable.subscribe(System.out::println);

输出：

1
2
3

flatMap() 操作符

flatMap() 操作符用于将数据流中的每一个元素转换为一个新的数据流。这个操作符与 map() 操作符非常相似，但它允许我们对每个元素进行更复杂的操作。

以下是一个简单的示例，展示了如何使用 flatMap() 操作符将字符串流转换为一个单词流：

Observable<String> observable = Observable.just("Hello", "World");

Observable<String> wordObservable = observable.flatMap(s -> Observable.fromArray(s.split(" ")));

wordObservable.subscribe(System.out::println);

输出：