Connection abstraction lifted from WCF

IConnection.cs

using System;
using System.Diagnostics;
using System.Net;
using System.Threading;
using Std.Net.Support;

namespace Std.Net
{
    public interface IConnection
    {
        byte[] AsyncReadBuffer { get; }
        int AsyncReadBufferSize { get; }
        TraceEventType ExceptionEventType { get; set; }
        IPEndPoint RemoteIPEndPoint { get; }

        void Abort();
        void Close(TimeSpan timeout, bool asyncAndLinger);
        void Shutdown(TimeSpan timeout);

        AsyncCompletionResult BeginWrite(byte[] buffer,
            int offset,
            int size,
            bool immediate,
            TimeSpan timeout,
            WaitCallback callback,
            object state);

        void EndWrite();
        void Write(byte[] buffer, int offset, int size, bool immediate, TimeSpan timeout);
        void Write(byte[] buffer, int offset, int size, bool immediate, TimeSpan timeout, BufferManager bufferManager);

        int Read(byte[] buffer, int offset, int size, TimeSpan timeout);
        AsyncCompletionResult BeginRead(int offset, int size, TimeSpan timeout, WaitCallback callback, object state);
        int EndRead();

        // very ugly listener stuff
        object DuplicateAndClose(int targetProcessId);

        object GetCoreTransport();
        IAsyncResult BeginValidate(Uri uri, AsyncCallback callback, object state);
        bool EndValidate(IAsyncResult result);
    }
}