.NET (Core and Framework)

<br />
public  void OnDataReceived(IAsyncResult asyn)<br />
{<br />
	try<br />
	{<br />
<br />
		// SocketPacket is a class with the buffer of packet<br />
                SocketPacket socketData = (SocketPacket)asyn.AsyncState ;<br />
<br />
		int iRx  = 0 ;<br />
		// Complete the BeginReceive() asynchronous call by EndReceive() method<br />
		// which will return the number of characters written to the stream <br />
		// by the client<br />
		iRx = socketData.m_currentSocket.EndReceive (asyn);<br />
		if(iRx > 0)<br />
		{<br />
                        // this get client object/class data (nickname, receive buffer for this client, socket)<br />
			ClientSocketType client = GetClientSocket(socketData.m_currentSocket);<br />
<br />
			if(client != null)<br />
			{<br />
                                // create a new receiving buffer for this server/client receive<br />
				if(client.PacketBuffer == null)<br />
					client.PacketBuffer = new MemoryStream();<br />
<br />
                                // append received buffers to that buffer<br />
				BinaryWriter binwrite = new BinaryWriter(client.PacketBuffer);<br />
				binwrite.Write(socketData.dataBuffer, 0, iRx);<br />
<br />
                                // if packets for this message are finished process message<br />
                                // ?!? WORKING ?<br />
				if(asyn.IsCompleted)<br />
				{<br />
                                        // prepare the stream and send to a parsing function<br />
					MemoryStream stream = new MemoryStream(client.PacketBuffer.GetBuffer(), 0, client.PacketBuffer.GetBuffer().Length,true, false);<br />
					ProcessMessage(socketData.m_currentSocket, stream );<br />
<br />
                                        // empty client receive buffer<br />
					client.PacketBuffer = null;<br />
				}<br />
			}<br />
<br />
			// Continue the waiting for data on the Socket<br />
			WaitForData( socketData.m_currentSocket );<br />
		}<br />
		else<br />
		{<br />
			((SocketPacket)asyn.AsyncState).m_currentSocket.Close();<br />
			RemoveSocketFromList(((SocketPacket)asyn.AsyncState).m_currentSocket);<br />
			AddLogMessage("Disconnected user");				<br />
		}<br />
	}<br />
	catch (ArgumentNullException se)<br />
	{<br />
		AddLogMessage(se.Message );				<br />
	}<br />
	catch (ObjectDisposedException )<br />
	{<br />
		System.Diagnostics.Debugger.Log(0,"1","\nOnDataReceived: Socket has been closed\n");<br />
	}<br />
	catch(SocketException se)<br />
	{<br />
		AddLogMessage(se.Message );<br />
		if(se.ErrorCode == 10054)<br />
		{<br />
			((SocketPacket)asyn.AsyncState).m_currentSocket.Close();<br />
			RemoveSocketFromList(((SocketPacket)asyn.AsyncState).m_currentSocket);<br />
			AddLogMessage("User disconnected: no ping received");<br />
		}<br />
	}<br />
}<br />