如何让已有订阅重新接收BehaviourSubject的最后一个值？

嘿，我明白你遇到的问题了——你想用last()、publishLast()这些方法让已有订阅重新收到BehaviourSubject的最新值，但这些方法根本不是干这个的，难怪没效果！

先给你理清楚为什么这些方法没用：

• last()：它的作用是等待源Observable完成后，才会发射最后一个值，而BehaviourSubject除非你手动调用complete()，否则一直处于活跃状态，所以这个方法对你的场景完全不适用。
• publishLast()：它是把源Observable的最后一个值多播给订阅者，但只有当源完成时才会发射，而且发射一次就结束了，没法主动触发重发。
• share()/refCount()：这俩是用来管理多播Observable的订阅生命周期的，核心是让多个订阅共享同一个源，和主动重发最新值完全不沾边。

那正确的做法其实超简单，因为BehaviourSubject本身就一直持有当前的最新值，你只需要手动调用它的next()方法，把当前的最新值再发送一遍就行：

// 先定义你的BehaviourSubject
const myBehaviorSubject = new BehaviorSubject<string>('初始默认值');

// 已有订阅示例
myBehaviorSubject.subscribe(val => console.log('订阅1接收:', val));
myBehaviorSubject.subscribe(val => console.log('订阅2接收:', val));

// 当你需要给所有已有订阅重发最新值时，直接这么写
myBehaviorSubject.next(myBehaviorSubject.getValue());

执行这段代码后，两个订阅都会再次收到当前的最新值，完美解决你的需求。

如果你的场景需要封装BehaviourSubject（比如对外只暴露Observable，不想让外部直接调用next()），那可以搞个触发信号来间接实现：

import { BehaviorSubject, Subject, merge, of, switchMap } from 'rxjs';

// 触发重发的信号Subject
const resendTrigger$ = new Subject<void>();
// 你的核心BehaviourSubject
const myBehaviorSubject = new BehaviorSubject<string>('初始默认值');

// 组合出可重发的Observable
const resendableObservable$ = merge(
  // 正常接收原始流的值
  myBehaviorSubject,
  // 当触发信号到来时，发送当前的最新值
  resendTrigger$.pipe(switchMap(() => of(myBehaviorSubject.getValue())))
);

// 订阅这个组合后的Observable
resendableObservable$.subscribe(val => console.log('订阅接收:', val));

// 想要重发时，只需要触发这个信号
resendTrigger$.next();

这种方式更安全，外部只能通过触发信号来请求重发，不会误操作BehaviourSubject的其他状态。

总结一下：

• 最直接的方案：subject.next(subject.getValue())，利用BehaviourSubject自带的getValue()获取最新值再发送
• 封装场景方案：用额外的触发信号流组合，间接实现重发逻辑

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