private void ReadMessagesEx(TcpClient client) {
            var socket = client.Client;
            var ready = true;
            var lengthBuffer = new byte[LENGTH_BUFFER_SIZE];
            var buffer = default(byte[]);
            var length = 0;
            var index = 0;
            while (_running) {
                if (client.Available == 0) continue;
                if (ready) {
                    index = 0;
                    var read = socket.Receive(lengthBuffer, 0, LENGTH_BUFFER_SIZE, SocketFlags.None);
                    if (read > 0) {
                        if (BitConverter.IsLittleEndian) Array.Reverse(lengthBuffer);
                        length = BitConverter.ToInt32(lengthBuffer, 0);
                        buffer = new byte[length];
                        ready = false;
                    }
                } else
                    index += socket.Receive(buffer, index, length - index, SocketFlags.None);
                ready = index == length;
                if (ready) _dataQueue.Enqueue(buffer);
            }
        }