reactor.io.encoding

Interface Codec<SRC,IN,OUT>

Type Parameters:

SRC - The type that the codec decodes from and encodes to

IN - The type produced by decoding

OUT - The type consumed by encoding

All Known Implementing Classes:

ByteArrayCodec, CompressionCodec, DelimitedCodec, FrameCodec, GzipCodec, JacksonJsonCodec, JavaSerializationCodec, JsonCodec, KryoCodec, LengthFieldCodec, PassThroughCodec, ProtobufCodec, SerializationCodec, SnappyCodec, StringCodec

public interface Codec<SRC,IN,OUT>

Implementations of a Codec are responsible for decoding a SRC into an instance of IN and passing that to the given Consumer. A codec also provides an encoder to take an instance of OUT and encode to an instance of SRC.

Method Summary

Modifier and Type	Method and Description
Function<SRC,IN>	decoder(Consumer<IN> next) Provide the caller with a decoder to turn a source object into an instance of the input type.
Function<OUT,SRC>	encoder() Provide the caller with an encoder to turn an output object into an instance of the source type.

Method Detail

decoder

Function<SRC,IN> decoder(Consumer<IN> next)

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

Parameters:

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

Returns:

The decoded object.

encoder

Function<OUT,SRC> encoder()

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

Returns:

The encoded source object.