在Observable.interval()中捕获http错误

import { Observable, throwError } from 'rxjs';
import { catchError } from 'rxjs/operators';
import { HttpClient } from '@angular/common/http';

// 创建一个可观察对象，每秒发出一个数字
const interval$ = Observable.interval(1000);

// 在每个数字上发起HTTP请求
const http$ = interval$.pipe(
  mergeMap(() => this.http.get('https://api.example.com/data')),
  catchError(error => {
    // 在发生错误时进行处理
    console.error('HTTP请求错误:', error);
    // 返回一个新的可观察对象，以便继续订阅
    return throwError('发生了HTTP错误');
  })
);

// 订阅可观察对象
http$.subscribe(
  response => {
    // 处理HTTP响应
    console.log('收到HTTP响应:', response);
  },
  error => {
    // 处理错误
    console.error('发生了错误:', error);
  }
);