如何监听RxJS Observable取消订阅并重置busy状态？

你的场景核心问题是：当Observable被主动取消订阅时，tap和catchError都不会触发，导致busy标志无法重置。解决这个问题的关键是使用**finalize操作符**——它会在Observable生命周期结束时（包括正常完成、错误抛出、主动取消订阅三种情况）执行指定的清理逻辑。

修正后的代码示例： #

busy: boolean = false;

letsCheck(): Observable<any> {
    if (this.busy) {
        return of(null); // 实际场景可替换为请求排队逻辑
    }

    this.busy = true;
    return resultsFromAnAPI().pipe(
      tap(() => {
        // 可保留正常完成时的额外业务逻辑（如果需要）
      }),
      catchError((err) => {
        // 错误处理逻辑（如果需要）
        return of(null);
      }),
      finalize(() => {
        // 无论Observable以何种方式终止，都会执行此处代码
        this.busy = false;
      })
    );
}

关键说明： #

• finalize的回调函数覆盖所有终止场景：API正常返回、请求报错、订阅被主动取消（调用unsubscribe()），完美解决你遇到的busy无法重置的问题。
• 注意修正原代码中的语法错误：this.busy => false是箭头函数写法，正确的赋值语句应为this.busy = false。
• 如果不需要单独在tap或catchError中处理额外逻辑，可以直接去掉这两个操作符，仅通过finalize统一重置busy状态。

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