RxJS：错误处理运算符retry

如果有错误，此操作员将尝试在源Observable上重试，并且将根据给定的输入计数进行重试。

语法

retry(retry_count: number): Observable

参量

retry_count-参数retry_count是您要重试的次数。

返回值

它将返回可通过重试计数逻辑观察到的源。

例

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

let all_nums = of(1, 6, 5, 10, 9, 20, 10);
let final_val = ajax('http://localhost:8081/getData').pipe(retry(4));
final_val.subscribe(
   x => console.log(x), => console.error(err),
   () => console.log("Task Complete")
);

在示例中，我们使用ajax调用URL。网址-http:// localhost:8081/getData给出了404，因此retry()运算符尝试再次调用url 4次。输出如下所示。

输出