[RxJS] Flatten a higher order observable with concatAll in RxJS
Posted Answer1215
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了[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(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的主要内容,如果未能解决你的问题,请参考以下文章
在 RxJS Observable 中“展平”数组的最佳方法
[LeetCode] 374. Guess Number Higher or Lower
[RxJS] Combination operator: withLatestFrom