大佬教程收集整理的这篇文章主要介绍了angular – 处理RxJs flatMap流中的错误并继续处理，大佬教程大佬觉得挺不错的，现在分享给大家，也给大家做个参考。
为此,我想捕获flatMap-ing http get请求(下面的代码)生成的错误,并继续进行进一步的流处理.如果出现错误,我当前的解决方案会导致流停止.
Rx.observable.range(1,5) .flatMap(pageNo => { params.set('page',''+pageNo); return this.http.get(this.API_GET,params) .catch( (err) => { //save request return Rx.observable.throw(new Error('http Failed')); }); }) .map((res) => res.json());
让我们说在上面的例子中,第2页和第3页的http请求失败.我想为这两个请求处理错误(保存失败的请求以后重试),并让其他请求继续并映射到json().
如果要将信息传播到外部流,可以使用返回Observable.of(“Error：Foo.bar”);例如.
或者在catch中记录错误并返回一个Observable.empty()以使外部流基本上忽略该错误.
换句话说,只是链接这个：
.catch(error => Rx.observable.of(error));
const stream$= Rx.observable.range(1,5) .flatMap(num => { return simulateRest(num) .catch(error => { console.error(error); return Rx.observable.empty(); }); }); stream$.subscribe(console.log); // mocking-fn for simulaTing an error function simulateRest(num) { if (num === 2) { return Rx.observable.throw("Error for request: " + num); } return Rx.observable.of("Result: " + num); }
<script src="https://unpkg.com/rxjs/bundles/Rx.min.js"></script>
以上是大佬教程为你收集整理的angular – 处理RxJs flatMap流中的错误并继续处理全部内容，希望文章能够帮你解决angular – 处理RxJs flatMap流中的错误并继续处理所遇到的程序开发问题。
如果觉得大佬教程网站内容还不错，欢迎将大佬教程推荐给程序员好友。
本图文内容来源于网友网络收集整理提供，作为学习参考使用，版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ：384754419，请注明来意。