Angular拦截器抛出错误后如何保持keyup触发的请求流不终止？

RxJS 中的 Observable 流遵循「错误即终止」原则，一旦有未被捕获的错误上浮到最外层的 subscribe 错误回调，整个流就会直接结束，不再响应后续事件。你的代码中 HTTP 请求抛出的错误没有在 mergeMap 内部的子流中处理，直接冒泡到了外层的 inputChanged 主流程，导致主流程终止，后续 keyup 事件自然无法触发请求。

不需要修改拦截器和服务层代码，只需要在组件的 mergeMap 中对每个独立的 HTTP 请求子流做错误捕获，避免错误上浮到主流程即可。
核心逻辑是将 catchError 作用在每个 HTTP 子流上，错误发生时直接在子流内消化，返回一个正常的 next 事件（比如空数组，或你自定义的错误结构），主流程全程不会收到错误通知，也就不会终止。

修改后的组件代码 #

import { of } from 'rxjs'
import { catchError } from 'rxjs/operators'

ngOnInit() {
  // 输入框keyup触发地址查询逻辑
  this.inputChanged.pipe(
    debounceTime(500),
    distinctUntilChanged(),
    mergeMap((searchTerm) => 
      // 给每个HTTP请求的子流添加错误捕获
      this.mapboxService.search_address(searchTerm).pipe(
        catchError(err => {
          // 这里可以自定义错误提示逻辑
          console.log('地址查询失败：', err);
          // 返回空数组，外层subscribe会正常收到这个值，不会触发错误回调
          return of([]);
          // 如果你需要区分成功和失败结果，也可以返回自定义对象：
          // return of({ success: false, list: [], error: err })
        })
      )
    )
  )
  .subscribe((features: Feature[]) => {
    this.addresses = features
    // 如果是返回自定义对象的场景，这里可以做分支判断：
    // if(features.success) { this.addresses = features.list } else { 展示错误提示 }
  })
}

注意：如果是Angular旧版本，确认of、catchError操作符的导入路径和当前项目RxJS版本匹配即可。

如果所有调用search_address方法的场景都不需要因为请求错误断流，也可以把错误捕获逻辑放到服务层统一处理：

search_address(query: string): Observable<Feature[]> {
  const url = 'https://api.mapbox.com/geocoding/v5/mapbox.places2/'
  return this.http.get<MapboxOutput>(url + query + '.json?limit=5&types=address&access_token=' + environment.mapboxToken).pipe(
    map((res: MapboxOutput) => res.features),
    catchError(err => {
      console.log('地址查询接口报错：', err)
      return of([])
    })
  )
}

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