如果 Observable 对象抛出错误,则该辅助方法会重新订阅 Observable 以获取数据流,参数为重新订阅次数

  1. import { interval, of, throwError } from "rxjs"
  2. import { mergeMap, retry } from "rxjs/operators"
  3. interval(1000)
  4. .pipe(
  5. mergeMap(val => {
  6. if (val > 2) {
  7. return throwError("Error!")
  8. }
  9. return of(val)
  10. }),
  11. retry(2)
  12. )
  13. .subscribe({
  14. next: console.log,
  15. error: console.log
  16. })

43.png