Cách tạo lại RXJs Thử lại khi có sự chậm trễ và giới hạn đối với các lần thử

Question

Tôi đang cố thực hiện cuộc gọi API (sử dụng angular4), sẽ thử lại khi không thành công, sử dụng retryWhen. Tôi muốn nó trì hoãn 500 ms và thử lại. Điều này có thể đạt được với mã này:

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

Nhưng điều này sẽ tiếp tục cố gắng mãi mãi. Làm thế nào để hạn chế nó, giả sử 10 lần?

Cảm ơn bạn!

Answer 1

Bạn cần phải áp dụng các giới hạn tín hiệu thử lại, ví dụ nếu bạn chỉ muốn 10 lần thử lại:

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

Sử dụng

.retry(3) 

Lặp lại nguồn chuỗi quan sát được số lượng nhất định lần hoặc cho đến khi nó kết thúc thành công.

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