@Override
            protected Input begin(Pipe.Schema<?> pipeSchema) throws IOException
            {
                return byteArrayInput;
            }
Creates a protostuff pipe from a byte array.
protostuff-core/src/main/java/io/protostuff/ProtostuffIOUtil.java