reactor.io.encoding

Class DelimitedCodec<IN,OUT>

java.lang.Object

reactor.io.encoding.DelimitedCodec<IN,OUT>

Type Parameters:

IN - The type that will be produced by decoding

OUT - The type that will be consumed by encoding

All Implemented Interfaces:

Codec<Buffer,IN,OUT>

public class DelimitedCodec<IN,OUT>
extends java.lang.Object
implements Codec<Buffer,IN,OUT>

An implementation of Codec that decodes by splitting a Buffer into segments based on a delimiter and encodes by appending its delimiter to each piece of output. During decoding the delegate is used to process each segment. During encoding the delegate is used to create a buffer for each piece of output to which the delimiter is then appended.

Constructor Summary

Constructors

Constructor and Description
DelimitedCodec(boolean stripDelimiter, Codec<Buffer,IN,OUT> delegate) Create a line-feed-delimited codec, using the given Codec as a delegate.
DelimitedCodec(byte delimiter, boolean stripDelimiter, Codec<Buffer,IN,OUT> delegate) Create a delimited codec using the given delimiter and using the given Codec as a delegate.
DelimitedCodec(Codec<Buffer,IN,OUT> delegate) Create a line-feed-delimited codec, using the given Codec as a delegate.

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.
Function<OUT,Buffer>	encoder() Provide the caller with an encoder to turn an output object into an instance of the source type.

Methods inherited from class java.lang.Object

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

Constructor Detail

DelimitedCodec

public DelimitedCodec(Codec<Buffer,IN,OUT> delegate)

Create a line-feed-delimited codec, using the given Codec as a delegate.

Parameters:

delegate - The delegate Codec.

DelimitedCodec

public DelimitedCodec(boolean stripDelimiter,
                      Codec<Buffer,IN,OUT> delegate)

Create a line-feed-delimited codec, using the given Codec as a delegate.

Parameters:

stripDelimiter - Flag to indicate whether the delimiter should be stripped from the chunk or not during decoding.

delegate - The delegate Codec.

DelimitedCodec

public DelimitedCodec(byte delimiter,
                      boolean stripDelimiter,
                      Codec<Buffer,IN,OUT> delegate)

Create a delimited codec using the given delimiter and using the given Codec as a delegate.

Parameters:

delimiter - The delimiter to use.

stripDelimiter - Flag to indicate whether the delimiter should be stripped from the chunk or not during decoding.

delegate - The delegate Codec.

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.