处理RxJs flatMap流中的错误并继续处理

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

const source$ = of(1, 2, 3, 4, 5).pipe(
  flatMap((value) => {
    if (value === 3) {
      throw new Error('Error occurred');
    }
    return of(value);
  }),
  catchError((error) => {
    console.error('Error occurred:', error);
    // 返回一个新的Observable，继续处理流
    return of('Error handled');
  })
);

source$.subscribe(
  (value) => console.log('Next:', value),
  (error) => console.error('Error:', error),
  () => console.log('Complete')
);

import { of } from 'rxjs';
import { catchError, retry } from 'rxjs/operators';

const source$ = of(1, 2, 3, 4, 5).pipe(
  flatMap((value) => {
    if (value === 3) {
      throw new Error('Error occurred');
    }
    return of(value);
  }),
  retry(2), // 最多重试2次
  catchError((error) => {
    console.error('Error occurred:', error);
    return of('Error handled');
  })
);

source$.subscribe(
  (value) => console.log('Next:', value),
  (error) => console.error('Error:', error),
  () => console.log('Complete')
);