将本地结果与可能的（超时/错误）异步 Web 结果相结合

Question

我有两种方法都返回 IObservable

IObservable<Something[]> QueryLocal();

并且

IObservable<Something[]> QueryWeb();

QueryLocal 总是成功的。 QueryWeb 很容易出现超时和可能出现的 Web 错误。

我希望实现一个 QueryLocalAndWeb() 来调用两者并组合它们的结果。 到目前为止，我已经：

IObservable<Something[]> QueryLocalAndWeb()
{
  var a = QueryLocal();
  var b = QueryWeb();
  var plan = a.And(b).Then((x, y) => x.Concat(y).ToArray());
  return Observable.When(plan).Timeout(TimeSpan.FromSeconds(10), a);
}

但是，我不确定它是否可以处理 QueryWeb 产生错误的情况。 将来我可能还会有一个 QueryWeb2() 也需要考虑在内。

那么，如何组合多个 IObservables 的结果而忽略抛出错误（或超时）的结果呢？

Answer 1

我想 OnErrorResumeNext 应该能够处理这种情况：

来自 MSDN：

继续正常终止或被终止的可观察序列
下一个可观察序列的异常。

IObservable<Something[]> QueryLocalAndWeb()
{
  var a = QueryLocal();
  var b = QueryWeb().Timeout(TimeSpan.FromSeconds(10));
  return Observable.OnErrorResumeNext(b, a);
}

您可以通过对返回的可观察值使用聚合来执行数组的连接。
我假设本地和网络都是冷可观察的，即只有当有人订阅它们时它们才开始产生值。

Answer 2

怎么样：

var plan = a.And(b).Then((x, y) => x.Concat(y.Catch(Observable.Empty<Something[]>()).ToArray());