提供了编程的基础技术教程

zl程序教程

您现在的位置是：首页 >  其它

当前栏目

[RxJS] Flatten a higher order observable with concatAll in RxJS

in with order Rxjs Observable higher Flatten
2023-09-14 09:00:52 时间

Besides switch and mergeAll, RxJS also provides concatAll as a flattening operator. In this lesson we will see how concatAll handles concurrent inner Observables and how it is just mergeAll(1).

 

const clickObservable = Rx.Observable
  .fromEvent(document, 'click');

const clockObservable = clickObservable
  .map(click => Rx.Observable.interval(1000).take(5))
  .concatAll(); // the same as .mergeAll(1)

// flattening
// Observable<Observable<number>> ---> Observable<number>

/*
--------+--------------+-+----
        \        
         -0-1-2-3-4|
         
         concatAll
         
----------0-1-2-3-4-----0-1-2-3-4--0-1-2-3-4
*/

clockObservable
  .subscribe(x => console.log(x));

 

相关文章