reactor.io.encoding

Class PassThroughCodec<SRC>

java.lang.Object

reactor.io.encoding.PassThroughCodec<SRC>

All Implemented Interfaces:

Codec<SRC,SRC,SRC>

public class PassThroughCodec<SRC>
extends java.lang.Object
implements Codec<SRC,SRC,SRC>

A simple Codec that uses the source object as both input and output. Override the beforeAccept(Object) and beforeApply(Object) methods to intercept data coming in and going out (respectively).

Constructor Summary

Constructors

Constructor and Description
PassThroughCodec()

Method Summary

Modifier and Type	Method and Description
protected SRC	beforeAccept(SRC src) Override to intercept the source object before it is passed into the next Consumer or returned to the caller if a Consumer is not set.
protected SRC	beforeApply(SRC src) Override to intercept the source object before it is returned for output.
Function<SRC,SRC>	decoder(Consumer<SRC> next) Provide the caller with a decoder to turn a source object into an instance of the input type.
Function<SRC,SRC>	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

PassThroughCodec

public PassThroughCodec()

Method Detail

decoder

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

Parameters:

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

Returns:

The decoded object.

encoder

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

Returns:

The encoded source object.

beforeAccept

protected SRC beforeAccept(SRC src)

Override to intercept the source object before it is passed into the next Consumer or returned to the caller if a Consumer is not set.

Parameters:

src - The source object.

Returns:

beforeApply

protected SRC beforeApply(SRC src)

Override to intercept the source object before it is returned for output.

Parameters:

src -

Returns: