RxJs перестает слушать события щелчка при внутренних наблюдаемых ошибках (запрос Ajax). Я пытаюсь понять, как заставить прослушиватель событий подключиться к событию нажатия кнопки и изящно обрабатывать внутреннюю ошибку ajax.
Вот мой примерный код и ссылка на plunkr
var input = $("#testBtn");
var test = Rx.Observable.fromEvent(input,'click');
var testAjax = function() {
return Rx.Observable.range(0,3).then(function(x){
if(x==2)throw "RAWR"; //Simulating a promise error.
return x;
});
}
test.map(function(){
return Rx.Observable.when(testAjax());
})
.switchLatest()
.subscribe(
function (x) {
console.log('Next: ', x);
},
function (err) {
console.log('Error: ' + err);
},
function () {
console.log('Completed');
});