如何触发catchError并在重试时重试- RXJS

import { of, throwError, timer } from 'rxjs';
import { mergeMap, retryWhen, delay } from 'rxjs/operators';

// 模拟一个会发生错误的Observable
const source$ = of('data').pipe(
  mergeMap(() => {
    if (Math.random() < 0.5) {
      return throwError('Error occurred');
    } else {
      return of('success');
    }
  }),
  retryWhen(errors => {
    return errors.pipe(
      // 延迟1秒后进行重试
      delay(1000)
    );
  })
);

source$.subscribe(
  data => {
    console.log('Received:', data);
  },
  error => {
    console.error('Error:', error);
  }
);