RxJS返回来自mergeMap的值数组

Question

我有一条可以观察到的溪流。第一个运算符是一个mergeMap，它返回一个可观察的数组。然后，我必须有第二个mergeMap从第一个mergeMap的返回中获取最终值。我觉得这第二个合并映射应该是不必要的，但找不到绕过它的方法。

例子：

source$.pipe(
  mergeMap(() => [of(1), of(2), of(3)]),
  mergeMap((val) => val)
)

这最终是我所拥有的。第二个mergeMap只存在于订阅第一个的输出。没有它，我的输出是可观察的（即（1）的而不是实际值1）。有没有办法实现第二次合并映射？




Answer 1

原因是第一个mergeMap应用于数组，不管是什么数组。

换句话说

source$.pipe(
  mergeMap(() => ['a', 'b', 'c']),
)

发出第一个a然后b然后c然后完成。

因此，在您的情况下，您需要第二个mergeMap来平坦发出的可观测数据。

作为一种替代方法，如果对您的情况有意义，您可以使用forkJoin而不是mergeMap。像这样的

source$.pipe(
  forkJoin([of(1), of(2), of(3)]),
)
.subscribe(console.log) // '1' '2' '3'

Answer 2

您可以在mergeMap操作符中使用merge函数，将观察值数组中的所有观察值合并为一个单独的观察值，该观察值将在任何基础观察值发出时发出。

这方面的代码片段如下：

source$.pipe(
  mergeMap(() => merge(...[of(1), of(2), of(3)])),
)