rxjs5 - mergeMap 和 mergeMapTo 有什么区别？

Question

在 rxjs5 文档中，它提到“为了减少多态性并从运算符中获得更好的性能，一些运算符已被拆分为多个运算符”。它的实际含义是什么以及如何使用 mergeMapTo 运算符？

Answer 1

来自docs ，mergeMapTo:

It's like mergeMap, but maps each value always to the same inner Observable.

我将 mergeMapTo 视为始终输出相同值的快捷方式。 mergeMapTo 不关心源值。

同样来自docs :

Maps each source value to the given Observable innerObservable regardless of the source value, and then merges those resulting Observables into one single Observable, which is the output Observable.

您会看到 mergeMap 接受一个 function 而 mergeMapTo 接受一个 value:

mergeMap 的示例(我们正在转换值):

Rx.Observable.of(1, 2, 3).mergeMap(x =>
  Rx.Observable.interval(1000).map(i => x+i)
);

使用 mergeMapTo 时，我们可以从流中获取值并始终输出相同的值(也进行转换，但始终输出相同的值):

Rx.Observable.of(1, 2, 3).mergeMapTo(10);