using System.IO;

using System.Net.Sockets;

​

public class TcpConn

{

    private readonly TcpClient _tcpClient;

    private readonly object _readLocker = new object ();

    private Stream _networkStream;

​

    public TcpConn(string hostname, int port)

    {

        _tcpClient = new TcpClient();

        _tcpClient.Connect(hostname, port);

        _networkStream = _tcpClient.GetStream();

    }

​

    public int Read(byte[] b)

    {

        lock (_readLocker)

        {

            int byteLength = b.Length;

            int total = _networkStream.Read(b, 0, byteLength);

            if (total == byteLength || total == 0)

                return total;

            while (total < byteLength)

            {

                int n = _networkStream.Read(b, total, byteLength - total);

                if (n == 0)

                    return total;

                total += n;

            }

​

            return total;

        }

    }

}