Передача объектов по трубам

using System;
using System.Collections.Generic;
using System.IO;
using System.IO.Pipes;
using System.Runtime.Serialization.Formatters.Binary;
using System.Text;
using System.Threading;

namespace PipeApplication1
{
    class ProgramPipeTest
    {

        public void ThreadStartServer()
        {
            // Create a name pipe
            using (NamedPipeServerStream pipeStream = new NamedPipeServerStream("mytestpipe2"))
            {
                Console.WriteLine("[Server] Pipe created {0}", pipeStream.GetHashCode());

                // Wait for a connection
                pipeStream.WaitForConnection();
                Console.WriteLine("[Server] Pipe connection established");

                using (StreamReader sr = new StreamReader(pipeStream))
                {
                    string temp;
                    // We read a line from the pipe and print it together with the current time
                    while ((temp = sr.ReadLine()) != null)
                    {
                        Console.WriteLine("{0}: {1}", DateTime.Now, temp);
                    }
                }
            }

            Console.WriteLine("Connection lost");
        }

        public void ThreadStartClient(object obj)
        {
            // Ensure that we only start the client after the server has created the pipe
            ManualResetEvent SyncClientServer = (ManualResetEvent)obj;

            // Only continue after the server was created -- otherwise we just fail badly
            // SyncClientServer.WaitOne();

            using (NamedPipeClientStream pipeStream = new NamedPipeClientStream("mytestpipe2"))
            {
                // The connect function will indefinately wait for the pipe to become available
                // If that is not acceptable specify a maximum waiting time (in ms)
                pipeStream.Connect();

                Console.WriteLine("[Client] Pipe connection established");
                using (StreamWriter sw = new StreamWriter(pipeStream))
                {
                    sw.AutoFlush = true;
                    string temp;
                    Console.WriteLine("Please type a message and press [Enter], or type 'quit' to exit the program");
                    while ((temp = Console.ReadLine()) != null)
                    {
                        if (temp == "quit") break;
                        sw.WriteLine(temp);
                    }
                }
            }
        }



        public void BinServer()
        {
            BinaryFormatter binFormat = new BinaryFormatter();

            // Create a name pipe
            using (NamedPipeServerStream pipeStream = new NamedPipeServerStream("mytestpipe1"))
            {
                Console.WriteLine("[Server] Pipe created {0}", pipeStream.GetHashCode());

                // Wait for a connection
                pipeStream.WaitForConnection();
                Console.WriteLine("[Server] Pipe connection established");

                byte[] buffer = new byte[65000];
                pipeStream.Read(buffer, 0, buffer.Length);
                var stream = new MemoryStream(buffer);
                var obj = (Dictionary<int, string>)binFormat.Deserialize(stream);
                Console.WriteLine(obj);
            }
        }

        public void BinClient(object obj)
        {
            var dic = new Dictionary<int, string> {{11, "hello"}, {22, "world"}};

            BinaryFormatter binFormat = new BinaryFormatter();
            var stream = new MemoryStream();
            binFormat.Serialize(stream, dic);

            using (NamedPipeClientStream pipeStream = new NamedPipeClientStream("mytestpipe1"))
            {
              
                pipeStream.Connect();
                Console.WriteLine("[Client] Pipe connection established");

                byte[] buffer = new byte[65000];
                buffer = Encoding.UTF8.GetBytes(Convert.ToString(stream));

                pipeStream.Write(buffer,0,buffer.Length);

            }
        }

        static void Main(string[] args)
        {

            // To simplify debugging we are going to create just one process, and have two tasks
            // talk to each other. (Which is a bit like me sending an e-mail to my co-workers)

            ProgramPipeTest Server = new ProgramPipeTest();
            ProgramPipeTest Client = new ProgramPipeTest();

            //Thread ServerThread = new Thread(Server.ThreadStartServer);
            //Thread ClientThread = new Thread(Client.ThreadStartClient);
            Thread ServerThread = new Thread(Server.BinServer);
            Thread ClientThread = new Thread(Client.BinClient);

            ServerThread.Start();
            ClientThread.Start();
        }
    }
}

Encoding.UTF8.GetBytes(Convert.ToString(stream));

stream.ToArray();

                        byte[] buffer = new byte[1024];
                        while(pipeServer.Read(buffer, 0, buffer.Length) != 0);