从我可以告诉,对于没有内置(或框架扩展)的支持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);
}
}
Run Code Online (Sandbox Code Playgroud)
.
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 …Run Code Online (Sandbox Code Playgroud)