rxjs里merge operators的用法
生活随笔
收集整理的這篇文章主要介紹了
rxjs里merge operators的用法
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
stream是lazy的,no subscription, no calculation occurs.
作用: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 三個值:
要獲取更多Jerry的原創文章,請關注公眾號"汪子熙":
總結
以上是生活随笔為你收集整理的rxjs里merge operators的用法的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: 95730是哪个银行 95730是指的什
- 下一篇: 股票l1和l2代表什么意思