reactor.io.encoding.compress

Class SnappyCodec<IN,OUT>

java.lang.Object

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

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

All Implemented Interfaces:

Codec<Buffer,IN,OUT>

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

Constructor Summary

Constructors

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

Method Summary

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

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

decoder, encoder

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SnappyCodec

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

Method Detail

createInputStream

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

Specified by:

createInputStream in class CompressionCodec<IN,OUT>

Throws:

java.io.IOException

createOutputStream

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

Specified by:

createOutputStream in class CompressionCodec<IN,OUT>

Throws:

java.io.IOException