Jak utworzyć próbę RXJ? Z opóźnieniem i limitem prób

Question

Próbuję wykonać wywołanie API (używając angular4), które ponawia próbę, gdy się nie powiedzie, używając metody retryWhen. Chcę, aby opóźnić o 500 ms i ponowić próbę ponownie. Można to osiągnąć za pomocą tego kodu:

loadSomething(): Observable<SomeInterface> { 
    return this.http.get(this.someEndpoint, commonHttpHeaders()) 
    .retryWhen(errors => errors.delay(500)); 
} 

Ale to będzie próbować na zawsze. Jak ograniczyć to do, powiedzmy 10 razy?

Dziękujemy!

Answer 1

Trzeba zastosować limit do ponawiania sygnału, na przykład, jeśli tylko chciał 10 ponownych prób:

loadSomething(): Observable<SomeInterface> { 
    return this.http.get(this.someEndpoint, commonHttpHeaders()) 
    .retryWhen(errors => 
     // Time shift the retry 
     errors.delay(500) 
      // Only take 10 items 
      .take(10) 
      // Throw an exception to signal that the error needs to be propagated 
      .concat(Rx.Observable.throw(new Error('Retry limit exceeded!')) 
    ); 
} 

Answer 2

pomocą

.retry(3) 

Powtarza zaobserwować źródłowej sekwencji określona liczba razy, lub dopóki nie kończy się powodzeniem.

https://github.com/Reactive-Extensions/RxJS/blob/master/doc/api/core/operators/retry.md