迁移Knockout代码至Rxjs：如何创建基于BehaviorSubject的计算可观察对象？

Knockout 的计算属性（ko.computed）依赖追踪机制只识别自身的可观察对象（ko.observable/ko.observableArray 等）的读取操作。当你把 firstObs 换成 RxJS 的 BehaviorSubject 后，调用 getValue() 并不会被 Knockout 的依赖系统捕获，所以当 firstObs.next() 发送新值时，计算属性不会自动重新执行 read 函数。

你需要让 Knockout 能感知到 RxJS Subject 的变化，有两种常见的实现方式：

方式一：将 RxJS Subject 包装为 Knockout 可观察对象 #

创建一个 Knockout 可观察对象，通过订阅 RxJS Subject 来同步值，这样计算属性就能正常追踪依赖：

_this.firstObs = new Rx.BehaviorSubject(undefined);
// 创建用于同步的 Knockout 可观察对象
_this.firstKoObs = ko.observable();

// 订阅 RxJS Subject，更新 Knockout 可观察对象
_this.firstObsSubscription = _this.firstObs.subscribe(value => {
    _this.firstKoObs(value);
});

_this.secondObs = ko.computed({
    read: function () {
        var first = _this.firstKoObs();
        return first && first.innerObs();
    },
    deferEvaluation: true,
});

方式二：手动触发计算属性更新 #

如果不想额外维护 Knockout 可观察对象，可以在 RxJS Subject 的订阅回调中手动通知计算属性的订阅者更新：

_this.firstObs = new Rx.BehaviorSubject(undefined);
_this.secondObs = ko.computed({
    read: function () {
        var first = _this.firstObs.getValue();
        return first && first.innerObs();
    },
    deferEvaluation: true,
});

// 订阅 RxJS Subject，手动触发计算属性更新
_this.firstObsSubscription = _this.firstObs.subscribe(() => {
    _this.secondObs.notifySubscribers();
});

• 无论使用哪种方式，都要在组件/对象销毁时取消 RxJS 订阅，避免内存泄漏：

  // 示例：在销毁逻辑中调用
  _this.firstObsSubscription.unsubscribe();
  

• 方式一更符合 Knockout 的依赖追踪设计，推荐优先使用；方式二更适合临时过渡场景。

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