基于其他订阅结果的RXJS重试

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

// 模拟一个可能会失败的异步操作
const simulateAsyncOperation = () => {
  const random = Math.random();
  return random > 0.5 ? of('Success') : throwError('Error');
};

// 进行重试的回调函数
const retryCallback = errors => {
  return errors.pipe(
    mergeMap((error, index) => {
      if (index >= 3) {
        return throwError('Max retries reached');
      }
      return of(error).pipe(delay(1000));
    })
  );
};

// 进行订阅并重试
simulateAsyncOperation()
  .pipe(retryWhen(retryCallback))
  .subscribe(
    result => console.log('订阅成功：', result),
    error => console.error('订阅失败：', error)
  );