如何在namedPipeWrapper中实现服务器和客户端之间的消息推送？

using System.IO.Pipes;

public class Server
{
    private NamedPipeServerStream pipeServer;

    public void Start()
    {
        pipeServer = new NamedPipeServerStream("MyPipe", PipeDirection.Out);

        // 等待客户端连接
        pipeServer.WaitForConnection();

        // 发送消息给客户端
        byte[] message = Encoding.UTF8.GetBytes("Hello, client!");
        pipeServer.Write(message, 0, message.Length);

        // 断开连接并关闭命名管道
        pipeServer.Disconnect();
        pipeServer.Close();
    }
}

using System.IO.Pipes;

public class Client
{
    private NamedPipeClientStream pipeClient;

    public void Connect()
    {
        pipeClient = new NamedPipeClientStream(".", "MyPipe", PipeDirection.In);

        // 连接到服务器端的命名管道
        pipeClient.Connect();

        // 接收服务器端发送的消息
        byte[] buffer = new byte[1024];
        int bytesRead = pipeClient.Read(buffer, 0, buffer.Length);
        string message = Encoding.UTF8.GetString(buffer, 0, bytesRead);

        // 处理接收到的消息
        Console.WriteLine("Received message: " + message);

        // 关闭命名管道
        pipeClient.Close();
    }
}