哪些操作符会触发Observable的求值？（RxJS与ReactiveX通用场景）

嘿，这个问题抓得很准！毕竟ReactiveX里Observable的惰性求值是核心特性，很多人刚开始都只知道subscribe()能触发它，其实还有不少操作符会间接启动这个求值过程，我给你捋捋常见的几类：

1. 转成非Observable类型的终端操作符 #

这类操作符的目标是把Observable转换成普通值或者Promise，所以必须触发订阅才能拿到结果：

• toPromise()：把Observable包装成Promise，底层会自动订阅原Observable，当流完成时resolve对应的结果。只要你调用这个方法，求值就开始了。
• firstValueFrom()/lastValueFrom()：这是RxJS 7之后替代toPromise()的官方推荐API，作用类似——订阅Observable，拿到第一个或最后一个值后结束，自然也会触发求值。

2. 多Observable组合类操作符 #

很多组合多个流的操作符，为了生成组合后的结果，必须订阅所有传入的Observable：

• forkJoin()：它会订阅所有传入的Observable，等每个都完成后，把最后一个值组合成数组返回，所以调用它的时候，所有内部Observable的求值都会被触发。
• combineLatest()：会订阅所有传入的Observable，等每个都至少发出一次值后，开始输出组合结果，所以也会启动各个流的求值。
• merge()/concat()：这俩分别是合并、串联多个流，调用它们之后，只要你处理组合后的流（比如后续接subscribe()或者其他终端操作），就会触发所有源Observable的订阅；如果只是把组合后的流赋给变量没处理，那还不会，但一旦要消费结果，就会触发求值。

3. 其他终端消费操作符 #

还有一些和subscribe()类似，直接消费流的操作：

• forEach()：RxJS里的这个方法会订阅Observable，对每个发出的值执行回调函数，本质和subscribe()的效果一致，当然会触发求值。

补充个小知识点 #

其实本质上，所有“终端操作符”（也就是最终消费流里的值的操作）都会触发订阅，那些像map()、filter()这类“中间操作符”只是转换流的形态，不会启动求值，必须等到有终端操作来按下“启动开关”。

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