如何向Action<X>类型参数传递异步函数？

问题场景 #

你的应用里有一段Rx接口定义：

IDisposable IObservable<X>.Subscribe<X>(Action<X> onNext)

现在要给Subscribe传入异步处理函数Process，写法如下：

async Task Process(X notification, CancellationToken ct) {...}

source.Subscribe(async x => await Process(x, CancellationToken.None)); // 触发警告

警告的核心原因 #

ReSharper会弹出警告：“避免在委托类型返回void时使用'async' lambda”，本质问题是：这种返回void的异步Lambda里，Process抛出的异常无法被常规try/catch捕获，会直接冒泡到线程池，大概率导致程序崩溃。

有争议的替代写法 #

改成下面的代码就不会触发警告，但业界普遍认为Wait()属于不良代码风格：

source.Subscribe(x => Process(x, CancellationToken.None).Wait());

靠谱的解决办法 #

1. 用Rx官方异步扩展方法 #

Rx本身提供了支持异步处理的SubscribeAsync扩展方法（需引用System.Reactive包），它接受返回Task的委托，能正常处理异常，写法简洁：

source.SubscribeAsync(async x => await Process(x, CancellationToken.None));

2. 手动封装异常处理（无扩展时使用） #

如果无法使用扩展方法，可在Lambda内手动处理异步任务的异常，规避async void的陷阱：

source.Subscribe(x => 
{
    // 用_丢弃返回值避免编译器警告，通过ContinueWith处理异常
    _ = Process(x, CancellationToken.None).ContinueWith(task =>
    {
        if (task.Exception != null)
        {
            // 替换为你的异常处理逻辑，比如日志记录
            Console.WriteLine($"处理通知失败: {task.Exception.GetBaseException().Message}");
        }
    }, TaskContinuationOptions.OnlyOnFaulted);
});

为什么别用Wait() #

Wait()会直接阻塞当前线程，完全违背异步编程“不阻塞、提升资源利用率”的初衷：在UI线程使用会导致界面卡死；在后台服务使用会降低并发能力，甚至可能触发死锁（比如Process内部使用ConfigureAwait(true)时）。

内容的提问来源于stack exchange，提问作者ca9163d9