angular2/RxJS - wie erneut zu versuchen, von innen subscribe()

Question

dies ist mein Code:

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() } } 
) 

, falls eine Ausnahme passiert ist, wird es dann true auf eine Funktion in der API gesendet werden zurückkehren, wenn das Problem ist, behoben (wie zum Beispiel token refreshed) und es muss nur noch einmal nach seiner festen

Ich konnte nicht herausfinden, wie man es erneut versuchen.

Answer 1

In Ihrem .getCompanies() Anruf direkt nach dem .map eine .retryWhen hinzufügen:

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

In diesem Beispiel sind die beobachtbaren abgeschlossen ist nach 2 Fehlern (errorCount < 2).

Answer 2

Sie meinen so etwas?

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) 
     } 
    } 
}