javascript-错误后继续订阅

2019-11-12 03:36:24 阅读：244 来源： 互联网

标签：ajax rxjs rxjs5 reactive-programming javascript

我有一个代码,其中我为每个id发出ajax请求并在结果出现时对其进行处理.这是我的实际代码和jsfiddle的简单副本：

var ids = [1,2,3,4,5,6];
var ids$= (id) => {
    return Observable.of(id);
};
var loadIds$= (id) => {
    if(id == 4) return xhr('/echo/jsoneee/', {id: id});
    return xhr('/echo/json/', {id: id});
};

Observable.from(ids)
.concatMap(id => Observable.forkJoin(ids$(id), loadIds$(id)))
.catch((err, caught) => {
  //get the id for which loadIds failed
  //send the id to subscribe() and continue the subscription
  return Observable.empty();
})
.subscribe(result => console.log(result))

但是现在我需要修改代码,以便如果发生错误,我将必须获取ajax请求失败的ID,然后继续订阅,就像什么都没有发生一样.我还不能做到这一点.非常感谢您的帮助.

解决方法:

我认为您可以通过在Observable.create(…)中正确发出正确的值来大大简化此操作：

function xhr(url, json) {
    return Observable.create(function (observer) {
        $.ajax({
            url: url,
            data: JSON.stringify(json),
            success: function (response) {
                observer.next([json.id, json]);
            },
            error: function (jqXHR, status, error) {
                observer.next([json.id]); // <== Notice this
            },
            complete: function () {
                observer.complete();
            }
        });
    });
}

var ids = [1,2,3,4,5,6];
var ids$= (id) => {
    return Observable.of(id);
};
var loadIds$= (id) => {
    if(id == 4) return xhr('/echo/jsoneee/', {id: id});
    return xhr('/echo/json/', {id: id});
};

Observable.from(ids)
    .concatMap(id => loadIds$(id))
    .subscribe(result => console.log(result));

这样您可以完全避免forkJoin().另请注意,catch()运算符会自动从其来源退订.该运算符旨在继续使用另一个Observable,因此在诸如您这样的情况下非常有用.

您当然可以使用：

.catch((error, caught) => {
    return caught;
})

但是,这会导致重新订阅,因此从一开始就重新释放通常不希望的所有值.

还有onErrorResumeNext()运算符,它只是忽略错误,但这可能不是您想要的.

观看演示：https://jsfiddle.net/4f1zmeyd/1/

有点类似的问题：get new ticket then retry first request

标签：ajax,rxjs,rxjs5,reactive-programming,javascript
来源： https://codeday.me/bug/20191112/2024341.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

javascript-错误后继续订阅