IPROTO-266 Allow for custom Encoder/Decoder implementations for TagWriter/TagReader

Author: wburns

core/src/main/java/org/infinispan/protostream/ProtobufUtil.java

@@ -75,6 +75,10 @@ public static void writeTo(ImmutableSerializationContext ctx, OutputStream out,
       write(ctx, TagWriterImpl.newInstance(ctx, out), t);
    }
 
+   public static void writeTo(ImmutableSerializationContext ctx, TagWriterImpl.Encoder encoder, Object t) throws IOException {
+      write(ctx, TagWriterImpl.newInstance(ctx, encoder), t);
+   }
+
    public static byte[] toByteArray(ImmutableSerializationContext ctx, Object t) throws IOException {
       ByteArrayOutputStream baos = new ByteArrayOutputStream(DEFAULT_ARRAY_BUFFER_SIZE);
       writeTo(ctx, baos, t);
@@ -112,6 +116,10 @@ public static <A> A fromByteBuffer(ImmutableSerializationContext ctx, ByteBuffer
       return readFrom(TagReaderImpl.newInstance(ctx, byteBuffer), clazz);
    }
 
+   public static <A> A fromDecoder(ImmutableSerializationContext ctx, TagReaderImpl.Decoder decoder, Class<A> clazz) throws IOException {
+      return readFrom(TagReaderImpl.newInstance(ctx, decoder), clazz);
+   }
+
    /**
     * Parses a top-level message that was wrapped according to the org.infinispan.protostream.WrappedMessage proto
     * definition.
@@ -137,6 +145,10 @@ public static <A> A fromWrappedStream(ImmutableSerializationContext ctx, InputSt
       return WrappedMessage.read(ctx, TagReaderImpl.newInstance(ctx, in));
    }
 
+   public static <A> A fromWrappedDecoder(ImmutableSerializationContext ctx, TagReaderImpl.Decoder decoder) throws IOException {
+      return WrappedMessage.read(ctx, TagReaderImpl.newInstance(ctx, decoder));
+   }
+
    //todo [anistor] should make it possible to plug in a custom wrapping strategy instead of the default one
    public static byte[] toWrappedByteArray(ImmutableSerializationContext ctx, Object t) throws IOException {
       return toWrappedByteArray(ctx, t, DEFAULT_ARRAY_BUFFER_SIZE);
@@ -162,6 +174,10 @@ public static void toWrappedStream(ImmutableSerializationContext ctx, OutputStre
       WrappedMessage.write(ctx, TagWriterImpl.newInstance(ctx, out, bufferSize), t);
    }
 
+   public static void toWrappedEncoder(ImmutableSerializationContext ctx, TagWriterImpl.Encoder encoder, Object t) throws IOException {
+      WrappedMessage.write(ctx, TagWriterImpl.newInstance(ctx, encoder), t);
+   }
+
    /**
     * Converts a Protobuf encoded message to its <a href="https://developers.google.com/protocol-buffers/docs/proto3#json">
     * canonical JSON representation</a>.