reactor.io.encoding.compress

Class CompressionCodec<IN,OUT>

java.lang.Object

reactor.io.encoding.compress.CompressionCodec<IN,OUT>

All Implemented Interfaces:

Codec<Buffer,IN,OUT>

Direct Known Subclasses:

GzipCodec, SnappyCodec

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

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	CompressionCodec(Codec<Buffer,IN,OUT> delegate)

Method Summary

Modifier and Type	Method and Description
protected abstract java.io.InputStream	createInputStream(java.io.InputStream parent)
protected abstract java.io.OutputStream	createOutputStream(java.io.OutputStream parent)
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

CompressionCodec

protected CompressionCodec(Codec<Buffer,IN,OUT> delegate)

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.

createInputStream

protected abstract java.io.InputStream createInputStream(java.io.InputStream parent)
                                                  throws java.io.IOException

Throws:

java.io.IOException

createOutputStream

protected abstract java.io.OutputStream createOutputStream(java.io.OutputStream parent)
                                                    throws java.io.IOException

Throws:

java.io.IOException