Я новичок в Rxjs, и мне очень сложно заставить его работать с Promise.Чего я хочу добиться:
- Сделать
check
каждые 1 секунду - Когда
check
успех, Promise
должен быть resolved
с возвращаемым значением true
и проверки больше не будет. - Если
check
не удастся 5 раз, Promise
должно быть rejected
с сообщением об ошибке
Я пробовал многораз и один из них похож на следующее.Но никто из них не может полностью достичь моей цели ... Было бы здорово, если бы кто-то мог помочь!
interval(1000).pipe(
flatMap((i) => {
if(i===4){
return throwError('...');
}
if(check()){
return of(true);
}
return of(false);
}),
takeWhile(val => !val),
).toPromise();