ReplaySubject : 记录历史值, 缓存以当前值向前某几位值, 或某段时间前的值
AsyncSubject :全体完成后,再发送通知
操作符
声明式的函数调用(FP), 不修改原Observable...const timer$ = timer(100, 1000); // 100: 延时, 1000: 发送间隔
timer$.subscribe(data => console.log(data))...,
** 也可以只发送自己的数据留,前一个留只作为触发机制
concatMapTo: 类似 map 与 mapTo , 替换源数据值
scan: 记录上次回调执行结果
doc
// 第一参数为执行回调,...--- 6
// 其他特殊操作
from([1, 2]).scan((a, b) => [...a, b], []);
// print
[1] --- [1, 2]
// 使用数组记录每次发送的值...).subscribe(...);
// print
0 -------------- 1 -----------
0 --- 1 --- 2 --- 0 --- 1 --- 2
// 需要注意的是当上游发送频率大于下游时