使用RxJS的shareReplay算子后Mocha测试无法正常结束的问题

这是个非常典型的RxJS订阅生命周期管理问题，我来帮你理清背后的逻辑：

核心原因：shareReplay(1)的默认行为会保持对源Observable的订阅 #

你用的shareReplay(1)在RxJS（尤其是v7+版本）里，等价于调用shareReplay({bufferSize: 1, refCount: false})。这里的关键是refCount: false这个配置：

• 当设置refCount: false时，shareReplay会创建一个永久订阅源Observable的共享实例，哪怕所有外部订阅者（比如你的测试代码里的订阅）都已经取消订阅，它也不会断开对源的连接。
• 你的源Observable是interval(100)，这是一个永远不会主动完成的流，只要有订阅存在，它就会持续触发定时器。当测试里的take(5)完成后，你的测试订阅虽然结束了，但shareReplay内部的订阅还在盯着interval(100)跑，导致Node.js的事件循环里一直有未完成的定时器任务，Mocha进程没法正常退出，VSCode的控制栏自然也就不会自动关闭。

而当你移除shareReplay后，take(5)会直接终止对interval(100)的订阅，定时器被清理，事件循环空了，进程就正常退出了。

解决方案：启用refCount自动清理订阅 #

把shareReplay(1)改成带配置的形式，开启refCount: true：

export function doStuffWithShareReplay() { 
  return interval(100).pipe( 
    shareReplay({bufferSize: 1, refCount: true}), 
    tap(d => console.log('do stuff 1', d)), 
    take(5) 
  ); 
}

当refCount: true时，shareReplay会跟踪外部订阅的数量：

• 当第一个订阅者订阅时，它会连接到源Observable；
• 当最后一个订阅者取消订阅时，它会自动断开对源Observable的连接，清理掉interval(100)的定时器。

这样测试跑完后，所有订阅都被清理，事件循环没有pending任务，Mocha进程就能正常退出，VSCode的控制栏也会自动关闭了。

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