Rx fromPromise e riprovare

Question

Perché devi per flatMap il fromPromise per ottenere il tentativi al lavoro?
(Il '/ error' restituisce lo stato 500)

var responseStream = Rx.Observable.just('/error'). 
     flatMap(requestUrl => { 
      return Rx.Observable.fromPromise(_this.$http.get(requestUrl)); 
    }); 

    responseStream. 
     retry(3). 
     subscribe(
     function (x) { 
      console.log('Next: ' + x); 
     }, 
     function (err) { 
      console.log('Error: ' + err); 
     }, 
     function() { 
      console.log('Completed'); 
     }); 

vorrei tagliare il cerimoniale e solo:

Rx.Observable.fromPromise(_this.$http.get('error')). 
     retry(3). 
     subscribe(
     function (x) { 
      console.log('Next: ' + x); 
     }, 
     function (err) { 
      console.log('Error: ' + err); 
     }, 
     function() { 
      console.log('Completed'); 
     }); 

In questo secondo caso la chiamata XHR è solo eseguito una volta.

Answer 1

Perché Promises non dispone di un'API per riprovare. fromPromise sta semplicemente avvolgendo lo Promise e lo fa emettere tramite un Observable. Quando chiami _this.$http.get('error') hai già creato un Promise ed è già in volo, quindi non c'è modo di riprovare la promessa senza chiamare nuovamente il metodo.

Il motivo per cui funziona quando viene eseguito il wrapping con flatMap è dovuto al fatto che quando si riprova il Observable si sta effettivamente rieseguendo il metodo che genera la promessa.

Se la verbosità ti fa davvero male, renditi conto che molti operatori supportano implicitamente Promises, senza la necessità di chiamare il metodo fromPromise.

Così il vostro esempio può essere ridotta fino al

var responseStream = Rx.Observable.just('/error') 
     .flatMap(requestUrl => _this.$http.get(requestUrl)); 

    responseStream 
     .retry(3) 
     .subscribe(
      (x) => console.log('Next: ' + x), 
      (err) => console.log('Error: ' + err), 
     () => console.log('Completed')); 

o anche più semplicemente usando defer:

Observable.defer(() => _this.$http.get('/error')) 
    .retry(3) 
    .subscribe(
     (x) => console.log('Next: ' + x), 
     (err) => console.log('Error: ' + err), 
    () => console.log('Completed'));