Package 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	Description
ProtobufSerializationProvider()
ProtobufSerializationProvider(java.util.function.Function<java.lang.Class<?>,com.google.protobuf.Parser<?>> parserForClass)

Method Summary

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

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 SerializationProvider.

Specified by:

getSerializer in interface SerializationProvider

Type Parameters:

T - The data type to serialize.

Parameters:

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

Returns:

An instance of StreamingSerializer that can serialize instances of SerializationProvider.

getSerializer

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

Description copied from interface: SerializationProvider

Provide a StreamingSerializer instance that can serialize instances of SerializationProvider.

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 SerializationProvider.

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 SerializationProvider.

Specified by:

getDeserializer in interface SerializationProvider

Type Parameters:

T - The data type to deserialize.

Parameters:

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

Returns:

An instance of StreamingDeserializer that can deserialize instances of SerializationProvider.

getDeserializer

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

Description copied from interface: SerializationProvider

Provide a StreamingDeserializer instance that can deserialize instances of SerializationProvider.

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 SerializationProvider.