如何正确递增ReplaySubject的number类型值？所用方案是否合理？

你当前改用BehaviorSubject配合getValue()实现数值增减的方案是符合RxJS设计逻辑的常规实践，完全可用。

两种错误写法的问题本质：

• 直接订阅流后在回调里调用同个流的next会触发无限循环：订阅回调会在流每次推送新值时执行，回调内又往同个流推送新值，会形成无终止的自触发链路。
• 追加take(1)操作符后仅能触发一次更新：take(1)会在接收到第一个值后立即终止订阅，后续流的新推送不会再被回调接收，自然无法支持多次更新。
• 最初选用的ReplaySubject本身不提供同步获取当前最新值的能力，本就不适合需要基于当前状态做更新的场景，替换为BehaviorSubject是匹配场景的正确选型。

使用BehaviorSubject做状态更新时注意两个实践细节：

• 不要把可直接调用next的Subject实例对外暴露，建议将可写实例设为私有，对外仅暴露通过asObservable()返回的只读流，更新逻辑统一封装在状态持有类内部，避免外部随意篡改值引发不可预期问题，参考实现：

// 内部持有可写的BehaviorSubject实例，设置初始值
private readonly _pointsCollected$ = new BehaviorSubject<number>(0);
// 对外暴露只读流，外部无法直接调用next篡改值
public readonly pointsCollected$ = this._pointsCollected$.asObservable();

// 统一封装数值增减方法
public updatePoints(delta: number): void {
  const currentValue = this._pointsCollected$.getValue();
  this._pointsCollected$.next(currentValue + delta);
}

• 如果增量更新逻辑包含异步步骤（比如等待接口校验通过再加积分），不要在异步回调中直接调用getValue()取值，此时可能出现竞态导致拿到非预期的旧值，这类场景优先用scan操作符维护状态流。

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