javascript - 如何观察 RxJS 中的属性变化？

Question

我对 RxJS 的经验不多，但我想知道是否有一种方法可以订阅对象属性的变化？ 我正在使用 RxJS 5。我使用 BehaviorSubject 将新值推送给订阅者。该主题包含一个对象，该对象定义了一些应用程序设置。

所以，我想做的是，我希望应用程序组件在特定属性更改时订阅并获取新值。 或者，我希望 observable 为每个订阅者生成对象的副本 - 这样他们就没有对原始对象的引用。

我的问题类似于this one .

提供应用设置的服务:

app.factory('settingsProvider', ['$rootScope', function ($rootScope) {

    let subject = new Rx.BehaviorSubject();

    let updateSettings = function (obj) {

        subject.next(_.merge({}, subject.getValue(), obj));
    };

    return {

        updateSettings: updateSettings,
        getObservable: function () {

            return subject.asObservable();
        }
    };
}]);

在某些指令中，我想订阅对某些属性的更改。 我目前有这个:

let settings = {};
let settingsSubscription = settingsProvider.getObservable().subscribe(x => settings = x);

Answer 1

我相信您需要运算符 distinct。 https://rxjs-dev.firebaseapp.com/api/operators/distinct

这是一个老问题，所以我将提供 v6 语法并假设您已同时更新。这个概念没有改变，所以您可以在 v5 中应用这种方法。

您犯的大错误是强制将 settings 重新分配为闭包。 Observable 以流的形式工作得最好，您可以将一个 observable 传输到下一个并且没有副作用。如果我们假设您开始观察正在构建它的东西，例如 { foo: 1, bar: 2, baz: 3}，我们可以先映射我们想要的 Prop ，然后distinct 以确保我们只在更改时发出。

const fooUpdate$ = mySub$
  .pipe(
    .map(({ foo }) => foo)
    .distinct()
  );

fooUpdate$.subscribe(val => console.log(val));

// Example of testing it
mySub$.next({ foo: 1, bar: 2 });
mySub$.next({ foo: 1, bar: 3 });
mySub$.next({ foo: 2, bar: 4 });
mySub$.next({ foo: 2, bar: 5 });
mySub$.next({ foo: 2, bar: 5 });
mySub$.next({ foo: 3, bar: 2 });

// 1, 2, 3