c# - 如何为异步等待调用创建包装器？

Question

据我所知，ConnectAsync 没有内置(或框架扩展)支持/AcceptAsync/SendAsync/ReceiveAsync ，等等。我将如何编写自己的包装器，该包装器将由异步等待机制支持。例如，我当前处理 ReceiveAsyn 的代码c 内联和回调(在 SocketAsyncEventArgs 中指定):

private void PostReceive(SocketAsyncEventArgs e)
{       
    e.SetBuffer(ReceiveBuffer.DataBuffer, ReceiveBuffer.Count, ReceiveBuffer.Remaining);            
    e.Completed += Receive_Completed;

            // if ReceiveAsync returns false, then completion happened inline
    if (m_RemoteSocket.ReceiveAsync(e) == false)
    {
        Receive_Completed(this, e);
    }                          
}

.

private void Receive_Completed(object sender, SocketAsyncEventArgs e)
{   
    e.Completed -= Receive_Completed;       

    if (e.BytesTransferred == 0 || e.SocketError != SocketError.Success)
    {
        if (e.BytesTransferred > 0)
        {                   
            OnDataReceived(e);
        }

        Disconnect(e);                
        return;
    }

    OnDataReceived(e);

    //
    // we do not push the SocketAsyncEventArgs back onto the pool, instead
    // we reuse it in the next receive call
    //
    PostReceive(e);
}

Answer 1

诀窍是使用 TaskCompletionSource来处理这种情况。

我写了关于这个的博客。有关详细信息，请参阅 Preparing Existing code For Await .