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，我是哪里用的不对呢？谢谢。012Error:oops!

Answer 1

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