reactor.io.encoding

Class FrameCodec

java.lang.Object

reactor.io.encoding.FrameCodec

All Implemented Interfaces:

Codec<Buffer,Frame,Frame>

public class FrameCodec
extends java.lang.Object
implements Codec<Buffer,Frame,Frame>

Codec for decoding data into length-field-based Frames.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	FrameCodec.LengthField

Constructor Summary

Constructors

Constructor and Description
FrameCodec(int prefixLength, FrameCodec.LengthField lengthField)

Method Summary

Modifier and Type	Method and Description
Function<Buffer,Frame>	decoder(Consumer<Frame> next) Provide the caller with a decoder to turn a source object into an instance of the input type.
Function<Frame,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

FrameCodec

public FrameCodec(int prefixLength,
                  FrameCodec.LengthField lengthField)

Method Detail

decoder

public Function<Buffer,Frame> decoder(Consumer<Frame> 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,Frame,Frame>

Parameters:

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

Returns:

The decoded object.

encoder

public Function<Frame,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,Frame,Frame>

Returns:

The encoded source object.