RxJS/Observable 的 flatMap 可以返回 Observable 或数组

Question

请问为什么.flatMap操作符可以接受返回Observable或array的函数？

官方文档中提到：

flatMap操作符通过将您指定的函数应用于源Observable发出的每个项目来转换Observable，其中该函数返回本身发出项目的Observable。

为什么它也可以返回数组？

例如，这两种方式都是有效的：

obs$.flatMap((data) => {
    return [];
});

obs$.flatMap((data) => {
    return new Observable<string>();
});

但这并不起作用：

obs$.flatMap((data) => {
    return 1;
});

- Dolan

---

Observables可以被视为随时间分散的数组，因此展开一个数组就像展开同步的observable。1既不是数组也不是observable，所以当然不能起作用。 - cartant

flatMap是mergeMap的别名。查看文档，你会发现该函数可以返回一个observable、一个promise或类似数组的值：http://reactivex.io/rxjs/class/es6/Observable.js~Observable.html#instance-method-mergeMap - cartant

具体而言，它可以返回一个 ObservableInput：http://reactivex.io/rxjs/class/es6/MiscJSDoc.js~ObservableInputDoc.html - cartant

谢谢，这帮助我理解了很多，我没有意识到它是“ObservableInput”。那么.flatMap如何返回Observables数组呢？或者这不可能吗？ - Dolan

如果您在可观察对象数组上调用flatMap，则会得到一个可观察的嵌套可观察对象 - 称为高阶可观察对象。有运算符可以进一步展开这样的高阶可观察对象。请查看mergeAll和concatAll。此外，如果这些链接帮助您了解问题，您可能需要考虑添加自答案。 - cartant

Answer 1

官方文档不相关，因为它们是关于 RxJS 4 而不是 RxJS 5。

mergeMap 投影函数返回 不仅仅是 Observable 而是 ObservableInput 接口, 它适用于可以转换为可观察对象的杂项值：

数组可以被解释为可观察对象，按从左到右的顺序逐个发出数组中的所有值，然后立即完成。

这意味着

obs$.flatMap((data) => arr)

是基本上的缩写版本

obs$.flatMap((data) => Observable.from(arr))

- Estus Flask

---

谢谢！那帮助我更好地理解了它。 - Dolan