RxJS 系列 – Join Operators

前言

前几篇介绍过了 

Creation Operators

Filter Operators

Join Creation Operators

Error Handling Operators

Transformation Operators

这篇继续介绍Join Operators

参考

Docs – Join Operators

concatAll, mergeAll, switchAll, exhaustAll

参考: RxJS 組合類型 Operators (1) - switchAll / concatAll / mergeAll / combineAll / startWith

请先学习 concatMap, mergeMap, switchMap, exhaustMap 哦

这里只介绍 concatAll, 主要是讲那个 All 的概念, 其余的只是换成 merge ,swtich, exhaust 概念而已.

concat 的 Observables 是一开始就定义好, 知道数量的 (o1, o2, o3) 3 个 Observables

concat(o1, o2, o3)

concatMap

from([1, 2, 3]).pipe(concatMap(v => of(v)));

concatMap 是接收 value 返回 Observable, 它的数量是动态的, 可以一直增加. 每当原 source 发布, concat 的 Observables 就多一个

concatAll 和 concatMap 类似, 只是它放在后面

from([1, 2, 3]).pipe(map(v => of(v), concatAll()));

concatMap 是返回 Observable

concatAll 则是接收 Observable (必须是 Observable). 上面的例子和 concatMap 的例子实现的效果是一样的.

所以其实只是提供 Observable 的方式改变了. 它的目的主要是在管理, 因为有时候 Observable 的提供时机不容易控制. 所以 RxJS 支持前后 2 钟方式提供 Observable 就方便多了.

一句或总结

concatAll, mergeAll, switchAll, exhaustAll : concatMap 是通过返回 Observable 这个方式来提供 Observable 给 concat, concatAll 则是通过接收 Observable 来提供 Observable 给 concat. 所以只是提供 Observable 的方式不同.

.