在对象上使用distinctUntilChanged

Lev*_*Lev 2 javascript rxjs

distinctUntilChanged该如何处理这样的对象

myObs = Observable.from([{foo: 'bar'}, {foo: 'bar'}]);

myObs.distinctUntilChanged()
  .subscribe(value => {
  // I only want to receive {foo: 'bar'} once
});
Run Code Online (Sandbox Code Playgroud)

Fab*_*ato 5

您需要在内部传递一个函数,该函数distinctUntilChanged返回一个布尔值以确保对象相同。

    myObs. distinctUntilChanged((a, b) => a.foo === b.foo)
Run Code Online (Sandbox Code Playgroud)