RxJs retry如何使用

Question

刚开始接触RxJS，用的版本6，看了文档retry的用法。https://rxjs-cn.github.io/lea... 做实验如下：import { interval, of, throwError } from 'rxjs';import { take, map, retry } from 'rxjs/operators';  const numbers = interval(1000);var example = numbers.pipe(     map((val) => {        if(val == 3) {            throw new Error('oops!');         } else {            return val;         }     },     retry(2) )); example.subscribe({   next: (val:any) => console.log(val),   error: (val:any) => console.log(val.message) });这段代码打印，并没有retry，我是哪里用的不对呢？谢谢。012Error: oops!

Answer 1

只可意会不可言传
文档里是mergeMap，而你这里是map，问题就在这