Observable中的Catch停止来自Observable.interval的HTTP调用

基础概念

Observable 是 RxJS（Reactive Extensions for JavaScript）中的一个核心概念，它代表了一个异步数据流。Observable.interval 是一个操作符，用于创建一个按固定时间间隔发出递增数值的 Observable。而 catch 操作符用于处理 Observable 中的错误，它可以捕获上游 Observable 抛出的错误，并返回一个新的 Observable。

类型

Observable.interval 创建的是一个 Observable<number>，即发出数值的 Observable。catch 操作符返回的也是一个 Observable，可以是与上游 Observable 相同类型，也可以是其他类型。

应用场景

Observable.interval 常用于定时任务、轮询等场景。结合 catch 操作符，可以在定时任务或轮询过程中捕获和处理可能出现的错误。

问题及解决方案

假设我们有一个场景，使用 Observable.interval 定时发起 HTTP 请求，并希望在请求失败时能够捕获错误并进行处理。

import { Observable, of } from 'rxjs';
import { interval, catchError, mergeMap } from 'rxjs/operators';
import axios from 'axios';

const httpCall$ = (url) => {
  return axios.get(url).then(response => response.data).catch(error => {
    throw error;
  });
};

const source$ = interval(1000).pipe(
  mergeMap(() => httpCall$('https://api.example.com/data')),
  catchError(error => {
    console.error('HTTP请求失败:', error);
    return of(null); // 返回一个空值或其他默认值
  })
);

source$.subscribe({
  next: value => console.log('收到数据:', value),
  error: error => console.error('订阅错误:', error),
  complete: () => console.log('完成')
});

在这个示例中，我们使用 interval 创建了一个每秒发出一个递增数值的 Observable，然后通过 mergeMap 操作符将每个数值映射为一个 HTTP 请求。如果请求失败，catchError 操作符会捕获错误并返回一个发出 null 的 Observable，从而避免整个数据流中断。