reactor.io.encoding.protobuf

Class ProtobufCodec<IN,OUT>

java.lang.Object

reactor.io.encoding.SerializationCodec<java.util.Map<java.lang.Class<?>,com.google.protobuf.Message>,IN,OUT>

reactor.io.encoding.protobuf.ProtobufCodec<IN,OUT>

All Implemented Interfaces:

Codec<Buffer,IN,OUT>

public class ProtobufCodec<IN,OUT>
extends SerializationCodec<java.util.Map<java.lang.Class<?>,com.google.protobuf.Message>,IN,OUT>

Constructor Summary

Constructors

Constructor and Description
ProtobufCodec()
ProtobufCodec(boolean lengthFieldFraming)

Method Summary

Modifier and Type	Method and Description
protected Function<byte[],IN>	deserializer(java.util.Map<java.lang.Class<?>,com.google.protobuf.Message> messages, java.lang.Class<IN> type, Consumer<IN> next)
protected Function<OUT,byte[]>	serializer(java.util.Map<java.lang.Class<?>,com.google.protobuf.Message> messages)

Methods inherited from class reactor.io.encoding.SerializationCodec

decoder, encoder, getEngine, readType

Methods inherited from class java.lang.Object

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

Constructor Detail

ProtobufCodec

public ProtobufCodec()

ProtobufCodec

public ProtobufCodec(boolean lengthFieldFraming)

Method Detail

deserializer

protected Function<byte[],IN> deserializer(java.util.Map<java.lang.Class<?>,com.google.protobuf.Message> messages,
                                           java.lang.Class<IN> type,
                                           Consumer<IN> next)

Specified by:

deserializer in class SerializationCodec<java.util.Map<java.lang.Class<?>,com.google.protobuf.Message>,IN,OUT>

serializer

protected Function<OUT,byte[]> serializer(java.util.Map<java.lang.Class<?>,com.google.protobuf.Message> messages)

Specified by:

serializer in class SerializationCodec<java.util.Map<java.lang.Class<?>,com.google.protobuf.Message>,IN,OUT>