reactor.io.codec.compress

Class GzipCodec<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>

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

All Implemented Interfaces:

Function<OUT,Buffer>

public class GzipCodec<IN,OUT>
extends CompressionCodec<IN,OUT>

Author:

Jon Brisbin

Field Summary

Fields inherited from class reactor.io.codec.Codec

DEFAULT_DELIMITER, delimiter

Constructor Summary

Constructors

Constructor and Description
GzipCodec(Codec<Buffer,IN,OUT> delegate)

Method Summary

Modifier and Type	Method and Description
protected InputStream	createInputStream(InputStream parent)
protected OutputStream	createOutputStream(OutputStream parent)

Methods inherited from class reactor.io.codec.compress.CompressionCodec

apply, decoder

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

GzipCodec

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

Method Detail

createInputStream

protected InputStream createInputStream(InputStream parent)
                                 throws IOException

Specified by:

createInputStream in class CompressionCodec<IN,OUT>

Throws:

IOException

createOutputStream

protected OutputStream createOutputStream(OutputStream parent)
                                   throws IOException

Specified by:

createOutputStream in class CompressionCodec<IN,OUT>

Throws:

IOException