reactor.io.codec.compress

Class CompressionCodec<IN,OUT>

java.lang.Object

reactor.io.codec.Codec<Buffer,IN,OUT>

reactor.io.codec.BufferCodec<IN,OUT>

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

All Implemented Interfaces:

Function<OUT,Buffer>

Direct Known Subclasses:

GzipCodec, SnappyCodec

public abstract class CompressionCodec<IN,OUT>
extends BufferCodec<IN,OUT>

Author:

Jon Brisbin, Stephane Maldini

Field Summary

Fields inherited from class reactor.io.codec.Codec

DEFAULT_DELIMITER, delimiter

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
Buffer	apply(OUT out) Execute the logic of the action, accepting the given parameter.
protected abstract InputStream	createInputStream(InputStream parent)
protected abstract OutputStream	createOutputStream(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.

Methods inherited from class reactor.io.codec.BufferCodec

decode, encode

Methods inherited from class reactor.io.codec.Codec

addDelimiterIfAny, decoder, doBufferDecode, doDelimitedBufferDecode, encoder, invokeCallbackOrReturn

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 class: Codec

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

Specified by:

decoder in class Codec<Buffer,IN,OUT>

Parameters:

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

Returns:

The decoded object.

apply

public Buffer apply(OUT out)

Description copied from interface: Function

Execute the logic of the action, accepting the given parameter.

Parameters:

out - The parameter to pass to the action.

Returns:

result

createInputStream

protected abstract InputStream createInputStream(InputStream parent)
                                          throws IOException

Throws:

IOException

createOutputStream

protected abstract OutputStream createOutputStream(OutputStream parent)
                                            throws IOException

Throws:

IOException