Angular中BehaviorSubject订阅异常：foo$.subscribe(bar$)偶尔失效求助

先搞清楚：foo$.subscribe(bar$)这种写法，本质是把bar$当作Observer传入，而BehaviorSubject作为Observer时，会把源Observable的next/error/complete事件直接映射到自身的对应方法上——这是RxJS的设计逻辑，不是Angular的bug。

核心失效场景 #

• 源Observable触发complete事件：如果foo$在某些偶然场景下被调用了complete()（比如上游Observable完成、操作符触发了完成逻辑），bar$作为Observer会自动执行自身的complete()，导致bar$进入终止状态，后续再调用bar$.next()也发不出值。而换成foo$.subscribe(foo => bar$.next(foo))时，你只处理了next事件，没绑定complete回调，foo$的完成不会影响bar$的状态，它依然能接收值。
• 源Observable触发error事件：同理，如果foo$抛出错误，bar$作为Observer会执行自身的error()，让bar$进入错误状态，后续无法再接收值。而显式只处理next的订阅，错误只会触发订阅的错误回调（没写的话就冒泡到全局处理器），不会影响bar$。
• 重复订阅的状态残留：如果多次调用foo$.subscribe(bar$)，每次都会创建新订阅。要是第一次订阅时foo$已经完成/出错，新订阅会立即触发bar$的complete/error，直接让bar$终止，后续自然失效。而显式next的方式，只要bar$没被终止，每次订阅都能正常传值。

关于Angular与ZoneJS #

这个问题和Angular无关，移除ZoneJS没用也正常——它本质是RxJS的预期行为，不是框架bug。RxJS的文档里明确说明了：Subject实现了Observer接口，传入subscribe时会把源的所有生命周期事件（包括complete和error）转发到自身的对应方法。

实用解决方案 #

如果只想让bar$转发foo$的next事件，不受foo$的complete/error影响，除了显式写next回调，还可以用操作符过滤掉非next事件：

// 忽略complete和error事件
foo$.pipe(ignoreElements(), catchError(() => EMPTY)).subscribe(bar$);
// 或者用tap更直观
foo$.pipe(tap(foo => bar$.next(foo))).subscribe();

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