Rxjs: повторить обещание?

Question

Подумайте, почему мое обещание разрешается, но пытается повторить попытку.

var getResultsStream = url => Rx.Observable.onErrorResumeNext( 
    Rx.Observable.defer(() => Rx.Observable 
     .fromPromise(getSearchResults(url) 
     .catch(error => Rx.Observable.of(`Error: ${error}`))) 
     .timeout(20000, new Error(`Timeout: ${url}`)) 
    ) 
    .do(e => console.log(`Retrying: ${url}`)) 
    .retry(3) 
) 

Это лучший способ повторить обещание 3 раза?

Answer 1

Если у вас нет специального применения для defer и/или onErrorResumeNext, вы можете бросить, что все и просто использовать:

const request = url => Rx.Observable.of(url) 
 
     .do(url => console.log("requesting: " + url)) 
 
     .switchMap(url => Rx.Observable.fromPromise(getSearchResults(url))) 
 
     .timeout(20000, new Error(`Timeout: ${url}`)) 
 
     .retry(3); 
 

 
request("http://foobar.com").subscribe(console.log, console.error); 
 

 
function getSearchResults(url) { 
 
    // simulating request-error 
 
    throw new Error("Could not reach: " + url); 
 
}

<script src="https://npmcdn.com/@reactivex/rxjs@5.0.0-beta.10/dist/global/Rx.umd.js"></script>