关于RXJS share()操作符：为何副作用仅执行一次但各订阅均获主结果

嗨，我来帮你把这个疑问掰扯明白！你观察到的现象完全符合RxJS share()的设计逻辑，咱们一步步拆解：

1. 先搞懂share()到底在干嘛 #

share()其实是publish().refCount()的语法糖，它的核心作用就是让多个订阅者共享同一个源Observable的执行实例——简单说就是，不是每个订阅都重新启动一次源的流程，而是大家共用同一个正在跑的流程。

在你的代码里，timer(1000)是那个“源”，当你把它包装进shared = example.pipe(share())后：

• 第一个订阅go1会触发源开始执行（也就是启动那个1000ms的计时）
• 第二个订阅go2会直接复用已经在跑的那个源流程，不会再重新启动一个新的timer

2. 为啥副作用只执行一次？ #

你写的tap(() => console.log("side-effect"))属于副作用操作——它是Observable执行过程中额外做的事，不影响最终发射给订阅者的值。因为share()让所有订阅共用同一个源执行流程，所以整个流程里tap里的代码只会被调用一次（就是源第一次启动、走到tap环节的时候）。

3. 那为啥每个订阅都能拿到主结果？ #

而mapTo("main-effect")是数据转换操作，它的作用是当源Observable发射值的时候，把值转换成"main-effect"再发射出去。当源流程走到“发射值”这一步时，这个转换后的值会被同时传递给所有当前存在的订阅者。

换个更直白的流程梳理：

1. go1订阅后，源开始计时1000ms
2. go2订阅时，计时已经在走了，直接加入“等待接收结果”的队列
3. 1000ms到点：
   • 先执行tap里的副作用（只跑一次，因为流程只有这一轮）
   • 然后mapTo把timer发射的0转换成"main-effect"，把这个值同时推给go1和go2的订阅回调
   • 于是两个订阅都打印出了"main-effect"

一句话总结 #

share()共享的是源Observable的整个执行流程，所以副作用只会在流程里跑一次；而流程中发射的每一个值，都会分发给所有订阅者，所以每个订阅都能拿到主结果。副作用是执行过程中的“附加动作”，主结果是过程中产生的“数据流”，两者在Observable的逻辑里是完全分开的环节~

内容的提问来源于stack exchange，提问作者Konrad Viltersten