rxjs怎么catch throw出的错误?
例子
const Rx = require('rx');
const x = (data) => {
let x = new Rx.Subject();
setTimeout(() => {
throw 'x error';
x.onNext(data.replace(/a/g, 'x'));
}, 1000)
return x;
};
Rx.Observable.just('a')
.flatMap(x)
.subscribe((data) => {
console.log(data);
}, (err) => {
console.log('rx error: ' + err);
});
请问如果需要在 subscribe 中捕捉到 throw 出去的错误,需要怎么做呢?
如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。
绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
发布评论
评论(1)
subscribe
的第2个参数就是 error handler 啊。不知道你是不是想要这样的效果 =。=
https://jsfiddle.net/DrakeLeu...