RxJS Subject搭配mergeMap时意外触发订阅？如何仅在点击时执行逻辑？

你使用mergeMap(() => this.searchResults$)的写法中，mergeMap会在每次clearSearch$触发时，持续订阅内部的this.searchResults$ Observable，只要searchResults$有新数据流入就会向下游传递，所以后续的搜索结果更新都会重复触发删除逻辑。

根据你的业务实现可以选择以下两种方案：

方案1：单次获取searchResults$最新值（通用场景） #

在内部Observable后追加take(1)操作符，每次点击触发clear时仅获取searchResults$的当前值一次，不会监听后续的数据流更新：

public clearSearch$ = new Subject<boolean>();

this.clearSearch$.pipe(
  mergeMap(() => this.searchResults$.pipe(take(1)))
).subscribe((groups: SearchGroup[]) => {
  groups.forEach((group) => {
    this.searchService.deleteResultGroup(group);
  });
});

方案2：直接同步取状态值（推荐，适用searchResults$为BehaviorSubject场景） #

如果你的searchResults$是BehaviorSubject类型（本身存储了当前最新的搜索结果状态），可以直接在clear方法中同步取值执行逻辑，无需嵌套响应式流，写法更简洁也不会产生额外监听：

public clear() {
  const currentGroups: SearchGroup[] = this.searchResults$.value;
  currentGroups.forEach(group => this.searchService.deleteResultGroup(group));
}

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