2
如果3次嘗試後集合不成功,我需要重試一系列RxJS observables並在序列中拋出該項目的錯誤對象。我發現這個例子(An incremental back-off strategy for handling errors):如何從RXJS Observable重試時拋出一個錯誤
var source = get('url').retryWhen(
attempts =>
attempts
.zip(Observable.range(1, 3), (_, i) => i)
.flatMap(i => {
console.log('delay retry by ' + i + ' second(s)');
return Rx.Observable.timer(i * 1000);
});
);
var subscription = source.subscribe(
data => {
// Displays the data from the URL or cached data
console.log(data);
});
你怎麼扔屬於該項目集合中的錯誤?上述代碼似乎吞噬了錯誤,而不是將其呈現給調用者來處理。 - 在_
將是錯誤(_, i) => i
:
非常感謝你! –