如何在订阅 observable 之前使用 distinctUntilChanged 检查 json 对象

Question

我只想在我从观察者主题收到的 JSON 对象的值发生变化时订阅 observable：

 searchedName = '';


  filters = {
  "page": 1,
  "perPage": 10,
  "sortOrder": "asc",
  "tag": "allUsers",
  "sortBy": "firstname"
}
  getUsers(e)
  {
    console.log("searched")
    const searchedKeyword = this.searchedName.trim();
    if(searchedKeyword !== '')
    this.filters['name'] = searchedKeyword
    this._service.triggerCallForUsers(this.filters)
  }
   ngOnInit()
{
  //Initially called to load users..
   this._service.triggerCallForUsers(this.filters)

   //Subscribe to fetch users
    this._service.startFetchingUsers$
      .distinctUntilChanged()
      .subscribe((filters) => {
        console.log("filters", filters)
        if (filters) {
          this._service.getUsersByFilter(filters)
            .subscribe(
              users => {
                console.log('users', users);

              },
              error => {}
            );
        }

      })
}

过滤器在哪里：

这可能吗？

尝试解决如下：

.distinctUntilChanged((a, b) => {
  console.log('compare', b['name'], a['name'], b['name'] === a['name']);
  return a === b
})

// 第一次订阅时 输出：- 比较没有输出

//当我添加 's' searchedName 字段时，即发送到的过滤器 next() 将包含

过滤器['name']

输出：- 比较 s undefined false

// 如果我将 searchedName 更改为 'sd':

输出：- 比较 sd sd true。

更新：

   <input type="text" (keyUp.enter)="getUsers($event)" [(ngModel)]="searchedName">

服务：

在服务中，我在 observable 上调用 next()：

private startFetchingUsers = new BehaviorSubject < any > (null);
startFetchingUsers$ = this.startFetchingUsers.asObservable();



triggerCallForCareGroup(filter) {

    this.startFetchingUsers .next(filter);
  }

Answer 1

如果您需要深度相等，请尝试使用来自 lodash 的 isEqual。

另外，您在 subscribe 中的逻辑过多 - 考虑使用 do/tap 处理副作用，使用 mergeMap 合并其他 Observables。

import { isEqual } from 'lodash';

this._service.startFetchingUsers$
    .distinctUntilChanged(isEqual)
    .do(filters => console.log("filters", filters))
    .mergeMap(filters => this._service.getUsersByFilter(filters))
    .do(users => console.log('users', users))
    .subscribe({
        error(error) {
            console.error(error);
        },
    });

当我在过滤器 json 中更改名称参数时，我得到更新的值 a['name'] 和 b['name'] 相同。

这表明您的代码中的其他地方也可能存在问题。可以分享一下你调用startFetchingUsers.next(newFilters)的代码吗？

更新

您正在改变this.filters 对象，因此您看不到更改，因为a === b 始终成立。对象本身是一样的！像这样使用浅拷贝：this._service.triggerCallForUsers({ ...this.filters })