CombineLatest 无限循环采摘算子

Question

注意：我在具有 ngFor 的组件中调用 set 函数。因此，当我调用 set 函数时，ngOnInit 会多次执行，因此 set 函数也会多次执行。 我有一个可观察的对象，我更新它以保持数据一致。

private app= this.subject.asObservable().distinctUntilChanged();

我使用这种方法访问数据

select<T>(name: string): Observable<T> {
   return this.app.pluck(name);
}

当我在每个用户选择上更新这个“应用程序”时，我会进入一个无限循环。所以 $info 开始一遍又一遍地打印相同的信息。并且“集合”被一遍又一遍地调用。 我正在使用异步管道在 html 视图中订阅和取消订阅。有什么想法吗？

updateFruits(fruit) {
  this.app.set('Fruits', fruit);
}

set(name: string, state: any) {
  this.subject.next({ ...this.value, [name]: state });
}

   this.info$ = combineLatest(fruits$)
  .pipe(
      distinctUntilChanged(),
      debounceTime(0)
      map(fruits => fruits)
   );

Answer 1

我认为要使用pluck 或distinctUntilChanged 之类的运算符，您必须使用pipe。

private app = this.subject.asObservable().pipe(distinctUntilChanged());

select<T>(name: string): Observable<T> {
   return this.app.pipe(pluck(name));
}

我也从未见过set 用于可观察对象的方法，只有next。

-- 编辑

我明白了，我原以为 this.app 是可观察的。

我试图重现该错误，但一切似乎都很好： 希望对您有所帮助：https://stackblitz.com/edit/rxjs-stack