标签:ever nbsp this int blog div sso ted important
Among RxJS flattening operators, switch is the most commonly used operator. However, it is important to get acquainted with mergeAll, another flattening operator which allows multiple concurrent inner observables. In this lesson we will explore mergeAll in detail.
const clickObservable = Rx.Observable .fromEvent(document, ‘click‘); const clockObservable = clickObservable .map(click => Rx.Observable.interval(1000)) .mergeAll(3); // allow 3 inner observables // flattening // Observable<Observable<number>> ---> Observable<number> /* --------+--------+------------------------ \ -0-1-2-3 -0-1-2-3-4-5-6 mergeAll ----------0-1-2-3-405162738495... */ clockObservable .subscribe(x => console.log(x));
[RxJS] Flatten a higher order observable with mergeAll in RxJS
标签:ever nbsp this int blog div sso ted important
原文地址:http://www.cnblogs.com/Answer1215/p/6188371.html