=> console.error(err),
complete: () => console.log('end')
}
// 执行订阅
observable.subscribe(observer...=> console.error(err),
complete: () => console.log('end')
});
// 发送通知
subject.nect(1);
//...next: (v) => console.log('observerB: ' + v)
});
// 开始执行, 在底层使用了 `source.subscribe(subject)`:
multicasted.conne...多播变体
BehaviorSubject : 缓存当前已发送值
ReplaySubject : 记录历史值, 缓存以当前值向前某几位值, 或某段时间前的值
AsyncSubject ：全体完成后，再发送通知...1 ---- 3 ---- 6
// 其他特殊操作
from([1, 2]).scan((a, b) => [...a, b], []);
// print
[1] --- [1, 2]
// 使用数组记录每次发送的值
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
