A socket server implementation that utilizes Reactive Extensions for .NET (Rx)