@Override
            protected void end(Pipe.Schema<?> pipeSchema, Input input,
                    boolean cleanupOnly) throws IOException
            {
                if (cleanupOnly)
                    return;

                assert input == byteArrayInput;
            }
Creates a protobuf pipe from a byte array.
protostuff-core/src/main/java/io/protostuff/ProtobufIOUtil.java