如何阻止Angular中HTTP Observable流遇错误时自动关闭？

先把你的代码补全并格式化，方便咱们梳理逻辑：

// 触发搜索操作
this.searchSubject.next(postBody);

// 搜索逻辑处理流
this.searchSubject
  .switchMap((view: any) => {
    // upsert用于记录搜索，此步骤为必要操作
    return this.searchHistoryService.upsert(view)
      .flatMap(() => this.http.post(this.url, view))
      .map((data) => this.pageTransform(data));
  })
  .subscribe(res => {
    this.successSubject.next(this.pageTransform(res));
  }, err => {
    this.errorSubject.next(err); // 推测这里是你的错误处理逻辑
  });

几个关键细节和优化建议 #

• switchMap的选型很合适：搜索场景下用switchMap是绝佳选择——它会自动取消前一次未完成的请求，避免旧的搜索结果覆盖新结果的问题，这点考虑得很到位。

• 去掉重复的pageTransform调用：你在switchMap的流里已经通过map做了一次数据转换，但在subscribe的回调里又重复转换了一次，这会导致数据被处理两次。直接把转换后的结果传给successSubject就行：

  .subscribe(res => {
    this.successSubject.next(res);
  }, ...)
  

• 错误处理可以更精细化：当前的错误逻辑会把upsert和http.post的错误统一传给errorSubject，如果需要区分「搜索历史保存失败」和「搜索请求失败」，可以给upsert单独加错误捕获：

  return this.searchHistoryService.upsert(view)
    .catch(upsertErr => {
      // 比如在这里打日志，或者给用户提示“历史记录保存失败”
      console.error('保存搜索历史失败:', upsertErr);
      // 如果不想让这个错误中断后续搜索，可以返回空Observable继续执行
      return Observable.of(null);
    })
    .flatMap(() => this.http.post(this.url, view))
    .map((data) => this.pageTransform(data));
  

• 提升类型安全性：当前view的类型是any，建议定义一个具体的接口（比如SearchQueryParams），这样能获得IDE的类型提示，也能提前发现类型错误。

• 避免内存泄漏：如果这段代码在组件里，记得在组件销毁时取消订阅，不然会导致内存泄漏。可以用takeUntil配合销毁主题实现：

  private destroy$ = new Subject<void>();
  
  ngOnDestroy() {
    this.destroy$.next();
    this.destroy$.complete();
  }
  
  // 修改订阅逻辑
  this.searchSubject
    .switchMap(...)
    .takeUntil(this.destroy$)
    .subscribe(...);
  

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