flatMap() 怎么使用

`flatMap()` 是 ReactiveX 库（包括 RxJava）中的一个操作符，用于处理 Observable 对象。它的全名是 "flatMapping"，主要用于将一个 Observable 的每个元素扁平化并转换为另一个 Observable，然后将这些新的 Observable 结果串联起来。

当你有一个 Observable 发出一系列值（可能是其他 Observable），而你想对每个值应用一个转换函数，并将结果作为一个整体 Observable 输出时，可以使用 `flatMap()`。这在处理嵌套的异步操作，如网络请求或事件流处理链时非常有用。

基本语法如下：

observable.flatMap(functionThatReturnsObservable)

这里的 `functionThatReturnsObservable` 是一个函数，接收原始 Observable 的值作为输入，返回一个新的 Observable。

举个例子：

List<String> words = ...; // 假设这是个 Observable
List<Observable<String>> wordObservables = words.stream()
    .map(word -> Observable.just(word))
    .collect(Collectors.toList());

// 使用 flatMap 将所有单词的 Observable 合并
Observable<String> flatMapped = Observable.fromIterable(wordObservables)
    .flatMap(wordObservable -> wordObservable);

在这个例子中，`flatMap`会生成一个新 Observable，其中包含所有单词的序列。