c# - 如何在任务产生事件时从任务中获取异常

Question

我有以下场景。 Task生成事件并可能引发异常:

public event EventHandler<EventArgs> MyEvent;
new Task(() =>
    {
        while (condition)
        {
            // Generate standard .NET event.
            MyEvent(this, new EventArgs());

            // Maybe throw exception.
            if (somethingIsWrong) throw new Exception();
        }
    });

一切都非常简单。我使用 Observable.FromEvent 收听事件:

var events =
    Observable.FromEvent<EventArgs>(h => myClass.MyEvent += h,
                                    h => myClass.MyEvent -= h);
events.Subscribe(
    ev => DoSomethingOnNext(ev),
    ex => DoSomethingOnError(ex),
    () => DoSomethingOnCompleted());

如果没有异常发生，一切正常。然而，当任务抛出异常时，我想在我的可观察对象中知道这一点。异常现在“隐藏”在任务中。

我只能通过在发生异常时创建另一个事件并将其包装在 IObservable 中来做到这一点吗？并订阅这个新的可观察对象？或者有更简单的方法吗？

Answer 1

这个怎么样:

class Program
{
    public event EventHandler<EventArgs> MyEvent;
    static void Main(string[] args)
    {
        var myClass = new Program();            

        var task = new Task(() =>
        {
            for(var i=0; i<5; i++) {
                // Generate standard .NET event. 
                myClass.MyEvent(myClass, new EventArgs());
            }

            throw new Exception();
        });

        var obsTask = task.ToObservable();

        var events = Observable.FromEvent<EventArgs>(h => myClass.MyEvent += h, h => myClass.MyEvent -= h);            

        events.TakeUntil(obsTask).Subscribe(
            ev => DoSomethingOnNext(ev), 
            ex => DoSomethingOnError(ex),
            () => DoSomethingOnCompleted());

        task.Start();

        Console.ReadKey();
    }

    private static void DoSomethingOnCompleted()
    {
        Console.WriteLine("DoSomethingOnCompleted");
    }

    private static void DoSomethingOnError(Exception ex)
    {
        Console.WriteLine("DoSomethingOnError:" + ex.ToString());
    }

    private static void DoSomethingOnNext(IEvent<EventArgs> ev)
    {
        Console.WriteLine("DoSomethingOnNext:" + ev.ToString());
    }

输出是:

DoSomethingOnNext:System.Collections.Generic.Event1[System.EventArgs]
DoSomethingOnNext:System.Collections.Generic.Event1[System.EventArgs]DoSomethingOnNext:System.Collections.Generic.Event1[System.EventArgs]
DoSomethingOnNext:System.Collections.Generic.Event1[System.EventArgs]DoSomethingOnNext:System.Collections.Generic.Event`1[System.EventArgs]DoSomethingOnError:System.AggregateException: 发生一个或多个错误。 ---> System.Exception:抛出“System.Exception”类型的异常。 在 C:\Users\Richard.Hein\Documents\Visual Studio 2010\Projects\RxConsole\RxDisposeTests\Program.cs 中的 RxDisposeTests.Program.<>c_DisplayClass9.b_0():第 25 行 在 System.Threading.Tasks.Task.InnerInvoke() 在 System.Threading.Tasks.Task.Execute() --- 内部异常堆栈跟踪结束 ------>(内部异常 #0)System.Exception:引发了“System.Exception”类型的异常。 在 C:\Users\Richard.Hein\Documents\Visual Studio 2010\Projects\RxConsole\RxDisposeTests\Program.cs 中的 RxDisposeTests.Program.<>c_DisplayClass9.b_0():第 25 行 在 System.Threading.Tasks.Task.InnerInvoke() 在 System.Threading.Tasks.Task.Execute()<---

编辑:

不确定 TakeUntil 是否是一个好的解决方案，因为 Task 可能会返回 Exceptions 以外的东西，对吗？所以这可行:

var events = Observable.CreateWithDisposable<IEvent<EventArgs>>(observer =>
{
    var eventObs = Observable.FromEvent<EventArgs>(
        h => myClass.MyEvent += h, h => myClass.MyEvent -= h);
    task.ToObservable().Subscribe(_ => { }, observer.OnError, observer.OnCompleted);
    return eventObs.Subscribe(observer.OnNext, observer.OnError, observer.OnCompleted);
});

events.Subscribe(
    ev => DoSomethingOnNext(ev), 
    ex => DoSomethingOnError(ex),
    () => DoSomethingOnCompleted());