RxJS问题：订阅的Observable结束后Subject无法正常工作

这个问题的核心在于Subject的订阅行为——当你直接把Subject传给另一个Observable的subscribe()方法时，外部Observable的complete通知会直接触发Subject的complete()方法。一旦Subject进入完成状态，它就会停止接收所有后续的next()值，这就是你的代码里数值6缺失的原因。

为什么原代码会失效？ #

你写的second$.subscribe(subject$)其实等价于：

second$.subscribe({
  next: val => subject$.next(val),
  error: err => subject$.error(err),
  complete: () => subject$.complete() // 这里是关键！
});

当second$（由of(3,4,5)创建的Observable）发送完所有值后，会自动发出complete通知，这个通知会调用subject$.complete()，让Subject彻底终止，后续再调用subject$.next(6)自然不会有任何输出。

解决方案：手动控制通知传递 #

要让Subject在外部Observable结束后继续工作，我们只需要不把外部Observable的complete（和error，如果不需要的话）通知传递给Subject，只转发next值即可。

修改后的代码示例：

const subject$ = new BehaviorSubject<number>(0);
const second$ = of<number>(3, 4, 5).pipe(delay(100));

subject$.subscribe(console.log);
subject$.next(1);
subject$.next(2);

// 手动订阅，只处理next通知，忽略complete和error
const subscription$ = second$.subscribe(val => subject$.next(val));

setTimeout(() => subscription$.unsubscribe(), 200);
setTimeout(() => subject$.next(6), 300);

这段代码的输出会是：0 1 2 3 4 5 6，完全符合你的预期。

进阶：按需处理错误（可选）

如果你需要转发外部Observable的错误通知，但依然不想让Subject因外部Observable完成而终止，可以显式定义订阅对象：

const subscription$ = second$.subscribe({
  next: val => subject$.next(val),
  error: err => {
    // 在这里处理错误，比如转发给Subject或者自定义逻辑
    subject$.error(err);
  }
  // 不定义complete回调，就不会触发subject$.complete()
});

另一种写法：使用tap操作符

你也可以通过tap操作符转发next值，再订阅这个处理后的流，效果是一样的：

second$.pipe(
  tap(val => subject$.next(val))
).subscribe(); // 空订阅，只触发tap里的逻辑，不会传递complete给Subject

这样无论外部Observable是否完成，Subject都能保持活跃状态，继续接收你通过next()手动传入的数据。

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