码迷,mamicode.com
首页 > Web开发 > 详细

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

时间:2016-12-16 22:50:19      阅读:212      评论:0      收藏:0      [点我收藏+]

标签:log   number   provides   ble   val   blog   operator   nbsp   div   

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

 

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

标签:log   number   provides   ble   val   blog   operator   nbsp   div   

原文地址:http://www.cnblogs.com/Answer1215/p/6188384.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!