angular2/RxJS - làm thế nào để thử lại từ bên trong đăng ký()

Question

đây là mã của tôi:

this._api.getCompanies().subscribe(
    res => this.companies = JSON.parse(res), 
    exception => {if(this._api.responseErrorProcess(exception)) { // in case this retured TRUE then I need to retry() } } 
) 

trong trường hợp một ngoại lệ xảy ra, nó sẽ được gửi đến một hàm trong API sau đó trở về true nếu vấn đề là cố định (ví dụ như làm mới mã thông báo) và nó chỉ cần thử lại sau khi đã sửa số

cố định của tôi và tôi không thể tìm ra cách để thử lại.

Answer 1

Trong .getCompanies() cuộc gọi của bạn ngay sau khi .map thêm một .retryWhen:

.retryWhen((errors) => { 
    return errors.scan((errorCount, err) => errorCount + 1, 0) 
       .takeWhile((errorCount) => errorCount < 2); 
}); 

Trong ví dụ này chạy xong quan sát được sau 2 thất bại (errorCount < 2).

Answer 2

Bạn có ý nghĩa như thế này?

this._api.getCompanies().subscribe(this.updateCompanies.bind(this)) 

updateCompanies(companies, exception) { 
    companies => this.companies = JSON.parse(companies), 
    exception => { 
     if(this._api.responseErrorProcess(exception)) { 
      // in case this retured TRUE then I need to retry() 
      this.updateCompanies(companies, exception) 
     } 
    } 
}