reactor.io.encoding

Class SerializationCodec<E,IN,OUT>

java.lang.Object

reactor.io.encoding.SerializationCodec<E,IN,OUT>

All Implemented Interfaces:

Codec<Buffer,IN,OUT>

Direct Known Subclasses:

JacksonJsonCodec, KryoCodec, ProtobufCodec

public abstract class SerializationCodec<E,IN,OUT>
extends java.lang.Object
implements Codec<Buffer,IN,OUT>

Abstract base class for Codec Codecs that perform serialization of objects. Optionally handles writing class names so that an object that is serialized can be properly instantiated with full type information on the other end.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	SerializationCodec(E engine, boolean lengthFieldFraming) Create a SerializationCodec using the given engine and specifying whether or not to prepend a length field to frame the message.

Method Summary

Modifier and Type	Method and Description
Function<Buffer,IN>	decoder(Consumer<IN> next) Provide the caller with a decoder to turn a source object into an instance of the input type.
protected abstract Function<byte[],IN>	deserializer(E engine, java.lang.Class<IN> type, Consumer<IN> next)
Function<OUT,Buffer>	encoder() Provide the caller with an encoder to turn an output object into an instance of the source type.
protected E	getEngine()
java.lang.Class<IN>	readType(Buffer buffer)
protected abstract Function<OUT,byte[]>	serializer(E engine)

Methods inherited from class java.lang.Object

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

Constructor Detail

SerializationCodec

protected SerializationCodec(E engine,
                             boolean lengthFieldFraming)

Create a SerializationCodec using the given engine and specifying whether or not to prepend a length field to frame the message.

Parameters:

engine - the engine which will perform the serialization

lengthFieldFraming - true to prepend a length field, or false to skip

Method Detail

decoder

public Function<Buffer,IN> decoder(Consumer<IN> next)

Description copied from interface: Codec

Provide the caller with a decoder to turn a source object into an instance of the input type.

Specified by:

decoder in interface Codec<Buffer,IN,OUT>

Parameters:

next - The Consumer to call after the object has been decoded.

Returns:

The decoded object.

encoder

public Function<OUT,Buffer> encoder()

Description copied from interface: Codec

Provide the caller with an encoder to turn an output object into an instance of the source type.

Specified by:

encoder in interface Codec<Buffer,IN,OUT>

Returns:

The encoded source object.

getEngine

protected E getEngine()

deserializer

protected abstract Function<byte[],IN> deserializer(E engine,
                                                    java.lang.Class<IN> type,
                                                    Consumer<IN> next)

serializer

protected abstract Function<OUT,byte[]> serializer(E engine)

readType

public java.lang.Class<IN> readType(Buffer buffer)