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

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().take())

  .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));

巴特西

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

最新文章

热门文章