reactor.io.encoding.kryo

Class KryoCodec<IN,OUT>

java.lang.Object

reactor.io.encoding.SerializationCodec<com.esotericsoftware.kryo.Kryo,IN,OUT>

reactor.io.encoding.kryo.KryoCodec<IN,OUT>

All Implemented Interfaces:

Codec<Buffer,IN,OUT>

public class KryoCodec<IN,OUT>
extends SerializationCodec<com.esotericsoftware.kryo.Kryo,IN,OUT>

Constructor Summary

Constructors

Constructor and Description
KryoCodec()
KryoCodec(com.esotericsoftware.kryo.Kryo engine, boolean lengthFieldFraming)

Method Summary

Modifier and Type	Method and Description
protected Function<byte[],IN>	deserializer(com.esotericsoftware.kryo.Kryo engine, java.lang.Class<IN> type, Consumer<IN> next)
protected Function<OUT,byte[]>	serializer(com.esotericsoftware.kryo.Kryo engine)

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

KryoCodec

public KryoCodec()

KryoCodec

public KryoCodec(com.esotericsoftware.kryo.Kryo engine,
                 boolean lengthFieldFraming)

Method Detail

deserializer

protected Function<byte[],IN> deserializer(com.esotericsoftware.kryo.Kryo engine,
                                           java.lang.Class<IN> type,
                                           Consumer<IN> next)

Specified by:

deserializer in class SerializationCodec<com.esotericsoftware.kryo.Kryo,IN,OUT>

serializer

protected Function<OUT,byte[]> serializer(com.esotericsoftware.kryo.Kryo engine)

Specified by:

serializer in class SerializationCodec<com.esotericsoftware.kryo.Kryo,IN,OUT>