RxJS中未订阅的空闲Observable底层工作机制探究

问题描述 #

我在使用Angular和RxJS开发项目时产生了几个疑问：

• 当以响应式方式定义并串联Observable（示例代码如下）但未对任何流进行订阅时，RxJS底层会做哪些操作？
• 这类未订阅的Observable会存储多少数据？
• 接收事件不多的这类Observable是否性能友好？
• 最后一次事件发射后会发生什么？

我是响应式编程和RxJS的新手。

示例代码：

clickEventA = new Subject();

clickEventB = new Subject();

a$ = this.clickEventA.asObservable().pipe(tap(_ => console.log('you clicked A')));
b$ = this.clickEventB.asObservable().pipe(tap(_ => console.log('you clicked B')));

c$ = combineLatest([this.a$,this.b$]).pipe(
   tap( v => console.log(v))
)

解答 #

1. 未订阅时的底层操作

RxJS遵循惰性执行核心原则：只有当Observable存在订阅者时，其内部的数据流处理逻辑才会被激活。

• 你定义的a$、b$、c$只是构建了"数据处理蓝图"，没有订阅的情况下，所有pipe里的操作（比如tap、combineLatest）完全不会执行。
• Subject实例会存在于内存中，但调用clickEventA.next()或clickEventB.next()时，因为没有订阅者，事件会直接被忽略，不会触发任何后续逻辑。

2. 数据存储情况

• 普通Subject默认不会存储任何事件数据，未订阅时发送的事件会直接被丢弃，不会占用额外内存。（只有BehaviorSubject、ReplaySubject这类特殊Subject才会缓存事件）
• a$、b$、c$这些Observable本身只是封装处理逻辑的对象，内存占用仅为自身实例的大小，几乎可以忽略。

3. 性能友好性

• 无订阅状态下，这类Observable的性能开销极低：仅为几个对象实例占用的内存，没有任何数据处理或事件分发的CPU消耗。
• 即使后续订阅，因为事件量少，tap、combineLatest这类轻量操作的性能开销也完全可以忽略，属于性能友好的实现方式。

4. 最后一次事件发射后的情况

• 未订阅时，无论发送多少次事件（包括最后一次），都不会触发任何管道逻辑，事件直接被丢弃。Subject会保持活跃状态，直到其被垃圾回收（比如Angular组件销毁时，若Subject是组件属性，会随组件实例一起被回收）。
• 如果后续订阅c$，combineLatest需要每个源Observable在订阅后至少发送一次事件才会输出合并结果——订阅前发送的事件不会被回溯处理。

内容的提问来源于stack exchange，提问作者Mohammed Housseyn Taleb