4

我有以下方法负责调用我的服务类并将结果传递给另一个方法以将它们保存在我的数据库中：

public IObservable<bool> SyncSessions()
{
    var subject = new ReplaySubject<bool>();

    try
    {
        var query = new ByFilterQuery { SearchPeriodStartTime = DateTime.Now };
        var sessions = _sessionService.GetSessions(query).Result;
        var saved = SaveSessions(sessions);
        subject.OnNext(saved);
        subject.OnCompleted();
    }
    catch (Exception ex)
    {
        subject.OnError(ex);
    }

    return subject;
 }

如果服务器返回 500 或类似的值，_sessionService.GetSessions 将抛出 HttpRequestException。我有一个模拟这种行为的单元测试，并想测试我的方法优雅地处理错误。

有没有更好的方法以 Rx 方式传播错误？我试着做：

_sessionService.GetSessions(query).ToObservable().Select(SaveSessions);

但这引发了我的错误，而不是将其传递给调用方法中的错误处理操作。我还计划将此方法与其他几种方法合并，并在合并的庄园中处理错误。

编辑：这是我订阅 observable 的方式

Exception error = null;
_sessionManager
    .SyncSessions()
    .Subscribe(null, e => error = e);

Assert.That(error, Is.Not.Null.After(500));

我将 null 传递给第一个参数，因为在此测试的上下文中我并不真正关心它

4

1 回答 1

3

首先，对于您发布的原始代码，我建议使用AsyncSubject而不是ReplaySubject. 将其视为针对单一结果案例进行了优化。

现在回答你的问题...

每当可观察源生成异常时，该异常就会通过OnError处理程序传播。如果，当您订阅 observable 时，您没有提供OnError处理程序，那么将抛出异常。

您发布的小代码：

_sessionService.GetSessions(query).ToObservable().Select(SaveSessions);

是不足够的。如果不发布显示您如何订阅 observable 的代码，我只能猜测您没有提供OnError处理程序。

根据 OP 的测试代码进行编辑

您的模拟服务是返回一个Task引发异常的，还是模拟服务只是引发异常？除非您使用 async/await，否则应该返回 a 的函数Task，但在创建时Task会抛出异常，该函数将立即引发异常，而不是返回 failed Task。ToObservable 甚至从未被调用，因为 GetSessions 抛出。如果您更改模拟服务以返回失败Task，那么您的测试可能会正常工作。

如果您想立即捕获异常以及失败的任务，那么您可以使用Defer延迟执行您的方法，直到观察者订阅。除了失败的任务，它还将收集任何立即抛出的异常：

return Observable
    .Defer(() => _sessionService.GetSessions(query))
    .Select(SaveSessions);
于 2013-07-01T23:17:37.690 回答