RxJS повторить оператор с помощью AJAX вызова

Question

Я пытаюсь понять, почему мое использование повторов не работает в этом примере: http://jsbin.com/bobecoluxu/edit?js,output

var response$ = Rx.Observable.fromPromise(
    $.ajax({ 
    url: 'http://en.wikipedia.org/w/api.php', 
    dataType: 'jsonp', 
    data: { 
     action: 'opensearch', 
     format: 'json', 
     search: term 
    } 
    })) 
.retry(3); 

Я завернутый вызов Ajax в наблюдаемом в функции searchWikipedia , но если я попытаюсь заставить отказ этого вызова отключить Wi-Fi или выбросить исключение связанным оператором, он просто не работает.

Заранее благодарен!

Answer 1

Когда вы передаете обещание fromPromise и повторите попытку вызова, он просто будет продолжать излучать то же обещание (т. Е. Последующие HTTP-запросы не будут сделаны).

Если вы передадите функцию, которая возвращает Promise на fromPromise, эта функция будет повторно вызвана (что позволяет отправлять последующие HTTP-запросы при сбое). Следующий пример иллюстрирует это:

const makesPromise =() => { 
    console.log('calling'); 

    // Purposefully reject the Promise. You would return the return value 
    // of your call to $.ajax() 
    return Promise.reject(); 
}; 

const stream = Rx.Observable.fromPromise(makesPromise).retry(3); 

stream.subscribe(log); 

// >> calling 
// >> calling 
// >> calling 
// Finally throws an uncaught error 

Примечание: я должен был обновить до последней версии 4.х RXJS, чтобы использовать эту функцию