如何在使用rxjs retryWhen时抛出原始错误

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

const maxRetryAttempts = 3; // 最大重试次数
const retryDelay = 1000; // 重试延迟时间

// 模拟一个会抛出错误的Observable
const source$ = throwError(new Error('原始错误'));

// 使用retryWhen进行重试
source$.pipe(
  retryWhen(errors =>
    errors.pipe(
      mergeMap((error, index) => {
        if (index < maxRetryAttempts) {
          // 抛出原始错误，以便在达到重试次数上限后将错误传递给订阅者
          return throwError(error);
        }
        // 如果达到重试次数上限，则抛出错误给订阅者
        throw error;
      }),
      // 设置重试延迟时间
      mergeMap(() => timer(retryDelay))
    )
  )
).subscribe({
  next: value => console.log(value),
  error: err => console.error('发生错误:', err)
});