TCP (Клиент-сервер) - потеря данных

using System;
using System.Threading;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading.Tasks;
using System.Collections.Generic;
 
namespace сlient
{
 
    class Program
    {
        const int startCount = 10000;
        static int countClient = 0;
        static int countServer = 0;
        Guid guid = Guid.NewGuid();
 
        void Connect(object obj)
        {
            try
            {
 
                IPEndPoint ep = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 8080);
                TcpClient client = new TcpClient();
                client.Connect(ep);
                string request;
                StringBuilder sb = new StringBuilder();
                using (NetworkStream stream = client.GetStream())
                {
                    request = obj.ToString() + '\0';
                    Console.WriteLine("Client: " + request);
 
                    stream.Write(Encoding.UTF8.GetBytes(request), 0, request.Length);
                    countServer = countServer + 1;
                    int i;
                    while ((i = stream.ReadByte()) != 0)
                    {
                        sb.Append((char)i);
                    }
                }
                client.Close();
 
                if (!request.Contains(guid.ToString()))
                {
                    Logfile.LogFile("Вернулось другое значение" + sb.ToString());
                }
 
                Console.WriteLine(sb.ToString());
 
 
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex.Message);
            }
 
        }
 
        void start()
        {
            using (var threadCount = new CountdownEvent(startCount))
            {
                for (int i = startCount; i > 0; i--)
                {
                    ThreadPool.QueueUserWorkItem(
                        x
                        =>
                        {
                            countClient = countClient + 1;
                            Connect((object)string.Format("Send iteration:{0}  --- " + guid + "", countClient));
                            threadCount.Signal();
 
                        });
                }
 
                /*        while (true)
                        {
 
                            string str = Console.ReadLine();
                            ThreadPool.QueueUserWorkItem(Connect, (object)str);
               }*/
                threadCount.Wait();
            }
            if (countClient == startCount)
            {
                Logfile.LogFile("Client[" + guid + "] - отправлено: [" + countClient.ToString() + "] - " + "пришло: [" + countServer.ToString() + "]");
            }
            else
            {
                Logfile.LogFile("Client[" + guid + "] - отправлено: [" + countClient.ToString() + "] - " + "пришло: [" + countServer.ToString() + "]");
            }
        }
 
 
        static void Main(string[] args)
        {
            Program p = new Program();
            p.start();
 
            Console.ReadKey();
        }
    }
}

using System;
using System.Threading;
using System.Net;
using System.Net.Sockets;
using System.Text;
 
namespace server
{
    public class server
    {
        ManualResetEvent tcpClientConnected = new ManualResetEvent(false);
 
        void ProcessIncomingData(object obj)
        {
            try
            {
                TcpClient client = (TcpClient)obj;
                StringBuilder sb = new StringBuilder();
 
                using (NetworkStream stream = client.GetStream())
                {
                    int i;
                    while ((i = stream.ReadByte()) != 0)
                    {
                        sb.Append((char)i);
                    }
 
                    string reply = "Server: " + sb.ToString() + '\0';
                    //  stream.Write(Encoding.ASCII.GetBytes(reply), 0, reply.Length);
                    stream.Write(System.Text.Encoding.UTF8.GetBytes(reply), 0, reply.Length);
                }
                Console.WriteLine(sb.ToString());
            }
            catch(Exception ex)
            {
                Console.WriteLine(ex.Message);
            }
        }
 
        void ProcessIncomingConnection(IAsyncResult ar)
        {
            //Thread.Sleep(10000);
            TcpListener listener = (TcpListener)ar.AsyncState;
            TcpClient client = listener.EndAcceptTcpClient(ar);
 
            ThreadPool.QueueUserWorkItem(ProcessIncomingData, client);
            tcpClientConnected.Set();
        }
 
        public void start()
        {
            IPEndPoint endpoint = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 8080);
            TcpListener listener = new TcpListener(endpoint);
            listener.Start();
 
            while (true)
            {
                tcpClientConnected.Reset();
                listener.BeginAcceptTcpClient(new AsyncCallback(ProcessIncomingConnection), listener);
                tcpClientConnected.WaitOne();
            }
        }
    }
 
    class Program
    {
        static void Main(string[] args)
        {
            server s = new server();
            s.start();
        }
    }
}