for every message

        private static IObservable<byte[]> ForEveryMessage(this TcpClient self, int byteCount, CancellationToken token)
        {
            return Observable.Create<byte[]>(
                obs =>
                {
                    NetworkStream stream = self.GetStream();
                    byte[] buffer = new byte[byteCount];
                    var recieving = Observable.FromAsyncPattern<byte[], int, int, int>(stream.BeginRead, stream.EndRead);
                    bool zeroBytesRead = false;
                    int remainder = byteCount;
                    return Observable.While(
                        () => !token.IsCancellationRequested && remainder > 0 && !zeroBytesRead,
                        Observable.Defer(() =>
                         recieving(buffer, buffer.Length - remainder, remainder).Timeout(TimeSpan.FromSeconds(TIMEOUTSECONDS))
                        .Do(read => { remainder = remainder - read; zeroBytesRead = read == 0; })))
                        .PublishLast(whenCompleted => whenCompleted.Select(_ => {
                            if (zeroBytesRead)
                            {
                                //WSAECONNABORTED
                                //Software caused connection abort.
                                //An established connection was aborted by the software in your host computer, possibly due to a data transmission timeout or protocol error.
                                throw new SocketException(10053);
                            }
                            return buffer;
                        }))
                        .Do(x => { Console.WriteLine(ReadableByteArray(x)); })
                        .Subscribe(obs.OnNext, obs.OnError, obs.OnCompleted);
                }
                );
        }