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

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

时间:2016-12-16 22:36:37      阅读:166      评论:0      收藏:0      [点我收藏+]

标签: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

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