我有一系列需要顺序触发的可观察对象。一旦发生错误,我就需要捕获该错误,将其记录下来,然后继续观察。

此刻,一旦发生错误,观察者将停止。观察者必须继续并且不要因错误而重新启动或完成,这一点很重要。

import * as Rx from "rxjs";
const source = [
  Rx.Observable.from("1").delay(200),
  Rx.Observable.from("2").delay(150),
  Rx.Observable.throw("error"),
  Rx.Observable.from("3").delay(124),
  Rx.Observable.from("4").delay(201),
];
let sSource = Rx.Observable.concat(...source);
sSource.subscribe((v) => {console.log(v)}, (e) => {console.log(e)});

电流输出:
1
2
error

预期产量:
1
2
error
3
4

我们能想到的唯一解决方案是预先循环遍历source可观察对象,并分别向它们添加捕获处理程序,然后一旦发生错误,将对其进行正确处理,并且观察者可以继续执行而无需完成整个串联的可观察对象。

我们觉得应该对此有一个更优雅的解决方案。如果需要,我将发布当前的解决方案。

最佳答案

您可以将catch运算符应用于每个源可观察对象,并可以在其中执行错误记录。像这样:

const sources = [
  Rx.Observable.from("1").delay(200),
  Rx.Observable.from("2").delay(150),
  Rx.Observable.throw("error"),
  Rx.Observable.from("3").delay(124),
  Rx.Observable.from("4").delay(201),
];
const sourcesWithCatch = sources.map(s => s.catch(e => {
  console.log(e);
  return Rx.Observable.empty();
}));
const concatted = Rx.Observable.concat(...sourcesWithCatch);
concatted.subscribe(v => console.log(v));
.as-console-wrapper { max-height: 100% !important; top: 0; }
<script src="https://unpkg.com/rxjs@5/bundles/Rx.min.js"></script>

关于typescript - RXJS在出错后继续concat订阅,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/50957701/

10-13 07:37