reactor.io.codec.protobuf

Class ProtobufCodec<IN,OUT>

java.lang.Object

reactor.io.codec.Codec<Buffer,IN,OUT>

reactor.io.codec.BufferCodec<IN,OUT>

reactor.io.codec.SerializationCodec<Map<Class<?>,com.google.protobuf.Message>,IN,OUT>

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

All Implemented Interfaces:

Function<OUT,Buffer>

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

Author:

Jon Brisbin

Field Summary

Fields inherited from class reactor.io.codec.Codec

DEFAULT_DELIMITER, delimiter

Constructor Summary

Constructors

Constructor and Description
ProtobufCodec()
ProtobufCodec(boolean lengthFieldFraming)

Method Summary

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

Methods inherited from class reactor.io.codec.SerializationCodec

apply, decoder, getEngine, readType

Methods inherited from class reactor.io.codec.BufferCodec

decode, encode

Methods inherited from class reactor.io.codec.Codec

addDelimiterIfAny, decoder, doBufferDecode, doDelimitedBufferDecode, encoder, invokeCallbackOrReturn

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(Map<Class<?>,com.google.protobuf.Message> messages,
                                           Class<IN> type,
                                           Consumer<IN> next)

Specified by:

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

serializer

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

Specified by:

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