rxjs里merge operators的用法

时间:2022-07-28
本文章向大家介绍rxjs里merge operators的用法，主要内容包括其使用实例、应用技巧、基本知识点总结和需要注意事项，具有一定的参考价值，需要的朋友可以参考一下。

作用：Flattens multiple Observables together by blending their values into one Observable.

例子：

 const clicks = fromEvent(document, 'click');
    const timer = interval(1000);
    const clicksOrTimer = merge(clicks, timer);
    clicksOrTimer.subscribe(x => console.log('jerry: ' + x));

测试结果：每隔1秒钟Observable emit一个值递增的整数。然后如果我点击UI，会显示一个[object MouseEvent]的事件：

const timer1 = interval(1000).pipe(take(10));
const timer2 = interval(1000).pipe(take(10));
const timer3 = interval(1000).pipe(take(10));
const concurrent = 3; // the argument
const merged = merge(timer1, timer2, timer3, concurrent);
merged.subscribe(x => console.log('diablo: '
 + x));

每秒同时emit 三个值：

随机文章
Javascript知识点必读
最近更新