reactiveui - 订阅 ReactiveAsyncCommand 不会在抛出异常时调用 OnError

Question

我创建了一个 ReactiveAsyncCommand (SL5) 并且无法获得订阅来触发 OnError 方法。这是代码

        Start1Command = new ReactiveAsyncCommand();
        Start1Command.RegisterAsyncObservable(_ => this.Start())
            .Subscribe<int>(
                u => Debug.WriteLine("OnNext-->" + u.ToString()),
                ex => Debug.WriteLine("OnError-->" + ex.Message),
                () => Debug.WriteLine("OnComplete-->")
            );
        Start1Command.Execute(null);

和开始的代码

 public IObservable<int> Start()
 {
     return Observable.Start(() =>
         {
            throw new Exception("Exception");
            return 42;
         },
         RxApp.TaskpoolScheduler);
 }

当我运行这段代码时，我从 ReactiveUI 框架中得到一个异常，这表明我应该订阅 ThrownExceptions。当我这样做时，我上面抛出的异常被正确处理。

 Start1Command.ThrownExceptions.Subscribe(ex => Debug.WriteLine("ThrownExceptions OnNext-->" + ex.Message));

我应该期望命令订阅会调用 OnError 吗？或者我必须使用ThrownExceptions。

Answer 1

通常，您的期望是完全正确的。然而，RegisterAsync*有效拦截OnError .这使得针对 RegisterAsync 进行编程变得更加容易。 ，因为一旦你处理了 OnError曾经，在 Subscribe ，它再也不会工作了。处理 ThrownExceptions意味着您不需要处理重新订阅。

如果这没有意义，请不要担心，只需处理 ThrownExceptions并假设订阅只收到 OnNext