如何在无订阅者场景下维持shareReplay的活性？

你遇到的问题是 shareReplay(1) 的默认行为导致的：默认配置下refCount = true，当没有活跃订阅时，shareReplay会自动销毁内部的重放缓冲区并终止上游订阅，因此第一个订阅者接入时没有历史值可以重放。

无需添加永久订阅，有两种可行解决方案：

方案1：调整shareReplay配置关闭引用计数 #

RxJS v6.4及以上版本支持给shareReplay传入配置对象，将refCount设为false即可让缓冲区永久保留，即使所有订阅都退订，上游发射的值依然会被缓存，新订阅者接入可直接拿到最新缓存值：

// 原写法（存在首订阅拿不到值的问题）
const shared$ = source$.pipe(shareReplay(1));

// 修复后写法
const shared$ = source$.pipe(
  shareReplay({
    bufferSize: 1,
    refCount: false
  })
);

该方案实现简单，适合不需要手动清理缓冲区的场景。

方案2：使用share+ReplaySubject自定义多播逻辑 #

如果需要更灵活地控制缓冲区生命周期，可以用share操作符自定义连接器，指定内部使用ReplaySubject实现多播：

const shared$ = source$.pipe(
  share({
    connector: () => new ReplaySubject(1),
    resetOnError: false,
    resetOnComplete: false,
    resetOnRefCountZero: false
  })
);

你可以根据业务需求调整三个重置参数：

• resetOnError：上游抛出错误时是否重置缓冲区
• resetOnComplete：上游完成时是否重置缓冲区
• resetOnRefCountZero：订阅数归零后是否重置缓冲区

两种方案都不需要额外添加永久订阅，即可实现所有订阅者（包括首个订阅者）接入时都能拿到上游最近一次的发射值。

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