• retry
    • 签名: retry(number: number): Observable
  • 如果发生错误，以指定次数重试 observable 序列。
    • 示例
      • 示例 1: 出错的话可以重试2次
  • 其他资源

    retry

    签名: retry(number: number): Observable

    如果发生错误，以指定次数重试 observable 序列。

    retry - 图1

    示例

    示例 1: 出错的话可以重试2次

    ( jsBin |
    jsFiddle )

    1. import { interval } from 'rxjs/observable/interval';
    2. import { of } from 'rxjs/observable/of';
    3. import { _throw } from 'rxjs/observable/throw';
    4. import { mergeMap, retry } 'rxjs/operators';
    6. // 每1秒发出值
    7. const source = interval(1000);
    8. const example = source.pipe(
    9.   mergeMap(val => {
    10.     // 抛出错误以进行演示
    11.     if (val > 5) {
    12.       return _throw('Error!');
    13.     }
    14.     return of(val);
    15.   }),
    16.   // 出错的话可以重试2次
    17.   retry(2)
    18. );
    19. /*
    20.   输出:
    21.   0..1..2..3..4..5..
    22.   0..1..2..3..4..5..
    23.   0..1..2..3..4..5..
    24.   "Error!: Retried 2 times then quit!"
    25. */
    26. const subscribe = example.subscribe({
    27.   next: val => console.log(val),
    28.   error: val => console.log(`${val}: Retried 2 times then quit!`)
    29. });

    其他资源

    • retry :newspaper: - 官方文档
    • 错误处理操作符: retry 和 retryWhen :video_camera: :dollar: - André Staltz

    :file_folder: 源码: https://github.com/ReactiveX/rxjs/blob/master/src/internal/operators/retry.ts