Package io.protostuff
Class ProtostuffIOUtil
java.lang.Object
io.protostuff.ProtostuffIOUtil
Protostuff ser/deser util for messages/objects.
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionstatic <T> int
mergeDelimitedFrom
(DataInput in, T message, Schema<T> schema) Used by the code generated messages that implementExternalizable
.static <T> int
mergeDelimitedFrom
(InputStream in, T message, Schema<T> schema) static <T> int
mergeDelimitedFrom
(InputStream in, T message, Schema<T> schema, LinkedBuffer buffer) static <T> void
Merges themessage
with the byte array using the givenschema
.static <T> void
Merges themessage
with the byte array using the givenschema
.static <T> void
mergeFrom
(InputStream in, T message, Schema<T> schema) static <T> void
mergeFrom
(InputStream in, T message, Schema<T> schema, LinkedBuffer buffer) static Pipe
newPipe
(byte[] data) Creates a protostuff pipe from a byte array.static Pipe
newPipe
(byte[] data, int offset, int len) Creates a protostuff pipe from a byte array.static Pipe
newPipe
(InputStream in) Creates a protostuff pipe from anInputStream
.static <T> boolean
optMergeDelimitedFrom
(InputStream in, T message, Schema<T> schema, boolean drainRemainingBytesIfTooLarge, LinkedBuffer buffer) Optimal/Optional mergeDelimitedFrom - If the message does not fit the buffer, no merge is done and this method will return false.static <T> boolean
optMergeDelimitedFrom
(InputStream in, T message, Schema<T> schema, LinkedBuffer buffer) Optimal/Optional mergeDelimitedFrom - If the message does not fit the buffer, no merge is done and this method will return false.static <T> int
optWriteDelimitedTo
(OutputStream out, T message, Schema<T> schema, LinkedBuffer buffer) Optimal writeDelimitedTo - The varint32 prefix is written to the buffer instead of directly writing to outputstream.static <T> List
<T> parseListFrom
(InputStream in, Schema<T> schema) static <T> byte[]
toByteArray
(T message, Schema<T> schema, LinkedBuffer buffer) Serializes themessage
into a byte array using the given schema.static <T> int
writeDelimitedTo
(DataOutput out, T message, Schema<T> schema) Used by the code generated messages that implementExternalizable
.static <T> int
writeDelimitedTo
(OutputStream out, T message, Schema<T> schema, LinkedBuffer buffer) Serializes themessage
, prefixed with its length, into anOutputStream
.static <T> int
writeListTo
(OutputStream out, List<T> messages, Schema<T> schema, LinkedBuffer buffer) Serializes themessages
(delimited) into anOutputStream
using the given schema.static <T> int
writeTo
(LinkedBuffer buffer, T message, Schema<T> schema) Writes themessage
into theLinkedBuffer
using the given schema.static <T> int
writeTo
(OutputStream out, T message, Schema<T> schema, LinkedBuffer buffer) Serializes themessage
into anOutputStream
using the given schema.
-
Constructor Details
-
ProtostuffIOUtil
private ProtostuffIOUtil()
-
-
Method Details
-
newPipe
Creates a protostuff pipe from a byte array. -
newPipe
Creates a protostuff pipe from a byte array. -
newPipe
Creates a protostuff pipe from anInputStream
. -
mergeFrom
Merges themessage
with the byte array using the givenschema
. -
mergeFrom
Merges themessage
with the byte array using the givenschema
. -
mergeFrom
- Throws:
IOException
-
mergeFrom
public static <T> void mergeFrom(InputStream in, T message, Schema<T> schema, LinkedBuffer buffer) throws IOException Merges themessage
from theInputStream
using the givenschema
.The
buffer
's internal byte array will be used for reading the message.- Throws:
IOException
-
mergeDelimitedFrom
public static <T> int mergeDelimitedFrom(InputStream in, T message, Schema<T> schema) throws IOException - Returns:
- the size of the message
- Throws:
IOException
-
mergeDelimitedFrom
public static <T> int mergeDelimitedFrom(InputStream in, T message, Schema<T> schema, LinkedBuffer buffer) throws IOException Merges themessage
(delimited) from theInputStream
using the givenschema
.The delimited message size must not be larger than the
buffer
's size/capacity.ProtobufException
"size limit exceeded" is thrown otherwise.- Returns:
- the size of the message
- Throws:
IOException
-
mergeDelimitedFrom
public static <T> int mergeDelimitedFrom(DataInput in, T message, Schema<T> schema) throws IOException Used by the code generated messages that implementExternalizable
. Merges from theDataInput
.- Returns:
- the size of the message
- Throws:
IOException
-
toByteArray
Serializes themessage
into a byte array using the given schema.- Returns:
- the byte array containing the data.
-
writeTo
Writes themessage
into theLinkedBuffer
using the given schema.- Returns:
- the size of the message
-
writeTo
public static <T> int writeTo(OutputStream out, T message, Schema<T> schema, LinkedBuffer buffer) throws IOException Serializes themessage
into anOutputStream
using the given schema.- Returns:
- the size of the message
- Throws:
IOException
-
writeDelimitedTo
public static <T> int writeDelimitedTo(OutputStream out, T message, Schema<T> schema, LinkedBuffer buffer) throws IOException Serializes themessage
, prefixed with its length, into anOutputStream
.- Returns:
- the size of the message
- Throws:
IOException
-
writeDelimitedTo
public static <T> int writeDelimitedTo(DataOutput out, T message, Schema<T> schema) throws IOException Used by the code generated messages that implementExternalizable
. Writes to theDataOutput
.- Returns:
- the size of the message.
- Throws:
IOException
-
writeListTo
public static <T> int writeListTo(OutputStream out, List<T> messages, Schema<T> schema, LinkedBuffer buffer) throws IOException Serializes themessages
(delimited) into anOutputStream
using the given schema.- Returns:
- the bytes written
- Throws:
IOException
-
parseListFrom
- Returns:
- the list containing the messages.
- Throws:
IOException
-
optMergeDelimitedFrom
public static <T> boolean optMergeDelimitedFrom(InputStream in, T message, Schema<T> schema, LinkedBuffer buffer) throws IOException Optimal/Optional mergeDelimitedFrom - If the message does not fit the buffer, no merge is done and this method will return false.This is strictly for reading a single message from the stream because the buffer is aggressively filled when reading the delimited size (which could result into reading more bytes than it has to).
The remaining bytes will be drained (consumed and discared) when the message is too large.
- Throws:
IOException
-
optMergeDelimitedFrom
public static <T> boolean optMergeDelimitedFrom(InputStream in, T message, Schema<T> schema, boolean drainRemainingBytesIfTooLarge, LinkedBuffer buffer) throws IOException Optimal/Optional mergeDelimitedFrom - If the message does not fit the buffer, no merge is done and this method will return false.This is strictly for reading a single message from the stream because the buffer is aggressively filled when reading the delimited size (which could result into reading more bytes than it has to).
- Throws:
IOException
-
optWriteDelimitedTo
public static <T> int optWriteDelimitedTo(OutputStream out, T message, Schema<T> schema, LinkedBuffer buffer) throws IOException Optimal writeDelimitedTo - The varint32 prefix is written to the buffer instead of directly writing to outputstream.- Returns:
- the size of the message
- Throws:
IOException
-