在 rxjs5 文档中,它提到“为了减少多态性并从运算符中获得更好的性能,一些运算符已被拆分为多个运算符”。它的实际含义是什么以及如何使用 mergeMapTo 运算符?
来自docs http://reactivex.io/rxjs/class/es6/Observable.js~Observable.html#instance-method-mergeMapTo,合并MapTo:
就像是mergeMap
,但总是将每个值映射到同一个内部 Observable。
I see mergeMapTo
作为始终输出相同值的快捷方式。mergeMapTo
不关心源值。
也来自docs http://reactivex.io/rxjs/class/es6/Observable.js~Observable.html#instance-method-mergeMapTo:
将每个源值映射到给定的可观察的innerObservable
无论源值如何,然后合并结果
将 Observable 转化为一个 Observable,即输出
可观察到的。
你会看到mergeMap
需要一个function
while 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);
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)