Package io.servicetalk.serializer.utils

Class VarIntLengthStreamingSerializer<T>

java.lang.Object

io.servicetalk.serializer.utils.VarIntLengthStreamingSerializer<T>

Type Parameters:

T - The type of object to serialize.

All Implemented Interfaces:

StreamingDeserializer<T>, StreamingSerializer<T>, StreamingSerializerDeserializer<T>

public final class VarIntLengthStreamingSerializer<T>
extends Object
implements StreamingSerializerDeserializer<T>

A StreamingSerializerDeserializer that uses a SerializerDeserializer and frames each object by preceding it with the length in bytes. The length component is variable length and encoded as base 128 VarInt.

Constructor Summary

Constructors

Constructor	Description
VarIntLengthStreamingSerializer(SerializerDeserializer<T> serializer, ToIntFunction<T> bytesEstimator)	Create a new instance.

Method Summary

Modifier and Type	Method	Description
Publisher<T>	deserialize(Publisher<Buffer> serializedData, BufferAllocator allocator)	Deserialize a Publisher of Buffer into a Publisher of StreamingDeserializer.
Publisher<Buffer>	serialize(Publisher<T> toSerialize, BufferAllocator allocator)	Serialize a Publisher of StreamingSerializers into a Publisher of Buffer.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.servicetalk.serializer.api.StreamingDeserializer

deserialize

Methods inherited from interface io.servicetalk.serializer.api.StreamingSerializer

serialize, serialize

Constructor Details

VarIntLengthStreamingSerializer

public VarIntLengthStreamingSerializer(SerializerDeserializer<T> serializer,
 ToIntFunction<T> bytesEstimator)

Create a new instance.

Parameters:

serializer - The SerializerDeserializer used to serialize/deserialize individual objects.

bytesEstimator - Estimates the length in bytes for each VarIntLengthStreamingSerializer being serialized.

Method Details

deserialize

public Publisher<T> deserialize(Publisher<Buffer> serializedData,
 BufferAllocator allocator)

Description copied from interface: StreamingDeserializer

Deserialize a Publisher of Buffer into a Publisher of StreamingDeserializer.

Specified by:

deserialize in interface StreamingDeserializer<T>

Parameters:

serializedData - the serialized stream of data represented in a Publisher of Buffer.

allocator - the BufferAllocator to use if allocation is required.

Returns:

The deserialized Publisher of StreamingDeserializers.

serialize

public Publisher<Buffer> serialize(Publisher<T> toSerialize,
 BufferAllocator allocator)

Description copied from interface: StreamingSerializer

Serialize a Publisher of StreamingSerializers into a Publisher of Buffer.

Specified by:

serialize in interface StreamingSerializer<T>

Parameters:

toSerialize - the deserialized stream of data represented in a Publisher of StreamingSerializer.

allocator - the BufferAllocator to use if allocation is required.

Returns:

the serialized stream of data represented in a Publisher of Buffer.