用Reactive Extensions实现一个简单的EchoServer

在昨天的随笔Reactive Extensions学习里，我写了个简单的stream异步读操作的扩展封装。今天我用它来实现了一个简单的EchoServer： 

    //一个简单的异步echo server
    static void Main(string[] args)
    {
        var listener = new TcpListener(new IPEndPoint(IPAddress.Loopback, 3000));
            
        listener.Start();
        while (true)
        {
            var client = listener.AcceptTcpClient();

            var stream = client.GetStream();
            var writer = new StreamWriter(stream) { AutoFlush = true };
            var buffer = new byte[1024];

            stream.ReadLinesAsync(buffer)
                .Select(line => ">>> " + line)
                .Finally(client.Close)
                .Subscribe(writer.WriteLine);
        }
    }

代码非常精简，比起以前的异步架构来说精简了不少。后续有时间的话再尝试用它重写一下以前的MSN客户端看看效果怎么样。