如何将异步委托连接到事件

Question

在我开始之前，我在这里能找到的最接近的答案是 How do you implement an async action delegate method? 但是，作为一个有点小脑袋的熊，我无法让我的脑细胞围绕答案以及它如何适用于我当前的问题。

我正在围绕 RabbitMq C# 客户端编写一个包装器，但我的委托和异步事​​件有问题。

这段代码看起来很好：

private Action<object, BasicAckEventArgs> _syncHandlerBasicAck;
private Action<object, BasicNackEventArgs> _syncHandlerBasicNack;

在这里定义代码：

_syncHandlerBasicAck = delegate(object o, BasicAckEventArgs args)
{
    //[Do stuff here]
};

_syncHandlerBasicNack = delegate(object o, BasicNackEventArgs args)
{
    //[Do stuff here]
};

然后使用它：

Channel.BasicAcks += _syncHandlerBasicAck.Invoke;
Channel.BasicNacks += _syncHandlerBasicNack.Invoke;

我遇到的问题是异步 BasicDeliver 事件。这是我当前的代码：

private Func<object, BasicDeliverEventArgs, Task> _syncHandlerIncomingMessage;

紧随其后

_syncHandlerIncomingMessage = async delegate(object o, BasicDeliverEventArgs args)
{
    //[Do stuff here]
};

但是每当我尝试这样做时：

Consumer.Received += _syncHandlerIncomingMessage.Invoke;

我收到 System.NullReferenceException 告诉我

对象引用未设置为对象的实例。

我看到有一个可用的 BeginInvoke 方法，但我不确定这是否适用于我目前的情况，因为我没有使用回调，只是想异步调用它。

有人指点吗？ （我什至会采用“重复问题：在此处回答”类型的回复，因为我确信我可能遗漏了什么）。

编辑

我有两个问题；一个是把它连接起来，另一个是一些重构妨碍了我！非常感谢@Coolbots 的回答和@Camilo 向我展示我的方式的错误。

Answer 1

问题是事件订阅不直接支持async delegate，所以需要一个包装器，像这样：

替代语法（参见EDIT）：

async Task MyDelegate(object sender, BasicDeliverEventArgs e)
{
   // Do stuff 
} 

Consumer.Received += async (s, e) => await MyDelegate(s, e);

我正在使用手机（无法测试代码），所以虽然我确定这适用于 async Task MyDelegate(...)，但我不是 100% 这适用于 async delegate MyDelegate(...)；虽然理论上应该。

编辑：删除，然后根据 OP 的要求恢复我的答案（我很高兴它具有一定的价值）；终于到了一台电脑上，并验证了所有 3 种订阅方法都有效，正如@CamiloTerevinto 在评论中所验证的那样，以及我最初删除这个答案的原因：

Func<object, BasicDeliverEventArgs, Task> _syncHandlerIncomingMessage;

_syncHandlerIncomingMessage = async delegate (object sender, BasicDeliverEventArgs eventArgs)
{
   await Task.Delay(1000); // Do stuff
};

// OR

async Task SyncHandlerIncomingMessage(object sender, BasicDeliverEventArgs eventArgs)
{
   await Task.Delay(1000); // Do stuff
} 

// Can be subscribed as follows:

Consumer.Received += _syncHandlerIncomingMessage.Invoke; // as posted by OP

// OR

Consumer.Received += async (s, e) => await SyncHanlderIncomingMessage.Invoke(s, e);

// OR

Consumer.Received += SyncHandlerIncomingMessage;

总结：不需要包装器。我很高兴我最初的答案对 OP 很有价值；我正在添加此编辑以确保答案的完整性/正确性，希望对其他人有用。