// Create two messages
        byte[] data1 = new byte[] { 1, 2 };
        byte[] data2 = new byte[] { 3, 4, 5 };
        byte[] fullData = concat(messageHeader(2), data1, messageHeader(3), data2);
        InputStream in = new ByteArrayInputStream(fullData);
        SocketInputStream sis = new SocketInputStream(in);

        // Read first message
        assertEquals(1, sis.read());