rxjs里merge operators的用法
生活随笔
收集整理的這篇文章主要介紹了
rxjs里merge operators的用法
小編覺(jué)得挺不錯(cuò)的,現(xiàn)在分享給大家,幫大家做個(gè)參考.
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));測(cè)試結(jié)果:每隔1秒鐘Observable emit一個(gè)值遞增的整數(shù)。然后如果我點(diǎn)擊UI,會(huì)顯示一個(gè)[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));每秒同時(shí)emit 三個(gè)值:
要獲取更多Jerry的原創(chuàng)文章,請(qǐng)關(guān)注公眾號(hào)"汪子熙":
總結(jié)
以上是生活随笔為你收集整理的rxjs里merge operators的用法的全部?jī)?nèi)容,希望文章能夠幫你解決所遇到的問(wèn)題。
- 上一篇: 95730是哪个银行 95730是指的什
- 下一篇: rxjs里mapTo operators