io.servicetalk.data.protobuf

Class ProtobufSerializationProvider

java.lang.Object

io.servicetalk.data.protobuf.ProtobufSerializationProvider

All Implemented Interfaces:

SerializationProvider

public final class ProtobufSerializationProvider
extends java.lang.Object
implements SerializationProvider

A SerializationProvider for serializing/deserializing protocol buffer objects. Note: This implementation assumes byte streams represent a single message. This implementation currently uses writeTo/parseFrom and not writeDelimitedTo/parseDelimitedFrom to serialize/deserialize messages. It cannot be used to process a stream of delimited messages on a single Buffer.

Constructor Summary

Constructors

Constructor and Description
ProtobufSerializationProvider()
ProtobufSerializationProvider(java.util.function.Function<java.lang.Class<?>,com.google.protobuf.Parser<?>> parserForClass)

Method Summary

Modifier and Type	Method and Description
<T> StreamingDeserializer<T>	getDeserializer(java.lang.Class<T> classToDeSerialize) Provide a StreamingDeserializer instance that can deserialize instances of T.
<T> StreamingDeserializer<T>	getDeserializer(TypeHolder<T> typeToDeserialize) Provide a StreamingDeserializer instance that can deserialize instances of T.
<T> StreamingSerializer	getSerializer(java.lang.Class<T> classToSerialize) Provide a StreamingSerializer instance that can serialize instances of T.
<T> StreamingSerializer	getSerializer(TypeHolder<T> typeToSerialize) Provide a StreamingSerializer instance that can serialize instances of T.

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.servicetalk.serialization.api.SerializationProvider

serialize

Constructor Detail

ProtobufSerializationProvider

public ProtobufSerializationProvider()

ProtobufSerializationProvider

public ProtobufSerializationProvider(java.util.function.Function<java.lang.Class<?>,com.google.protobuf.Parser<?>> parserForClass)

Method Detail

getSerializer

public <T> StreamingSerializer getSerializer(java.lang.Class<T> classToSerialize)

Description copied from interface: SerializationProvider

Provide a StreamingSerializer instance that can serialize instances of T.

Specified by:

getSerializer in interface SerializationProvider

Type Parameters:

T - The data type to serialize.

Parameters:

classToSerialize - The class for T, the object to be serialized.

Returns:

An instance of StreamingSerializer that can serialize instances of T.

getSerializer

public <T> StreamingSerializer getSerializer(TypeHolder<T> typeToSerialize)

Description copied from interface: SerializationProvider

Provide a StreamingSerializer instance that can serialize instances of T.

Specified by:

getSerializer in interface SerializationProvider

Type Parameters:

T - The data type to serialize.

Parameters:

typeToSerialize - TypeHolder holding the ParameterizedType to be serialized.

Returns:

An instance of StreamingSerializer that can serialize instances of T.

getDeserializer

public <T> StreamingDeserializer<T> getDeserializer(java.lang.Class<T> classToDeSerialize)

Description copied from interface: SerializationProvider

Provide a StreamingDeserializer instance that can deserialize instances of T.

Specified by:

getDeserializer in interface SerializationProvider

Type Parameters:

T - The data type to deserialize.

Parameters:

classToDeSerialize - The class for T, the object to be deserialized.

Returns:

An instance of StreamingDeserializer that can deserialize instances of T.

getDeserializer

public <T> StreamingDeserializer<T> getDeserializer(TypeHolder<T> typeToDeserialize)

Description copied from interface: SerializationProvider

Provide a StreamingDeserializer instance that can deserialize instances of T.

Specified by:

getDeserializer in interface SerializationProvider

Type Parameters:

T - The data type to deserialize.

Parameters:

typeToDeserialize - TypeHolder holding the ParameterizedType to be deserialized.

Returns:

An instance of StreamingDeserializer that can deserialize instances of T.