RxJS中combineLatest的subscribe回调未触发的原因是什么？

算力阿峰

2026-5-1

为什么你的combineLatest订阅没有输出？

嘿，我来帮你揪出问题所在！你的代码里combineLatest(sa, sz)的订阅回调完全没触发，核心原因很简单：你定义的sz这个ReplaySubject，自始至终从来没有调用过next()发射任何值。

关键原理：combineLatest的触发条件

combineLatest的工作逻辑是硬性要求的：只有当它接收的每一个源Observable都至少发出过一次值之后，它才会开始把所有源的最新值组合起来，发射给订阅者。你看你的代码，sa一直在循环里不断调用next()发射数字和字母，但sz从创建到循环结束，一次next()都没调用过——相当于它是个"沉默"的Observable，combineLatest一直在等它的第一个值，自然永远不会触发你的订阅回调。

快速修复方案

要让订阅开始输出，只需要给sz至少发射一次值就行。比如你可以在循环开始前加一行：

sz.next('init'); // 给sz一个初始值，随便什么内容都行

或者你也可以在循环里同步给sz发射值，比如和sa对应：

while(i < 10) {
  console.log(`i: ${i}`);
  sa.next(getNumber(i));
  sz.next(getLetter(i)); // 这里给sz也发一个值
  if(b) {
    sa.next(getLetter(i));
  }
  i++;
  b = !b;
}

这样修改后，combineLatest就能拿到两个Observable的最新值，你的console.log(s: ${a}-${z})就会正常输出啦。