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';
constnumbers=interval(1000);
varexample=numbers.pipe(
map((val)=>{
if(val==3){
thrownewError('oops!');
}else{
returnval;
}
},
retry(2)
));
example.subscribe({
next:(val:any)=>console.log(val),
error:(val:any)=>console.log(val.message)
});
这段代码打印，并没有retry，我是哪里用的不对呢？谢谢。
0
1
2
Error:oops!

Answer 1

retry(2)放的地方不对,你放到map中了varexample=numbers.pipe(map(val=>{if(val==3){thrownewError('oops!')}else{returnval}}/**,retry(2)*/),//不应该放在map中retry(2),)