akka.stream.impl.io.compression

Class GzipCompressor

java.lang.Object

akka.stream.impl.io.compression.Compressor

akka.stream.impl.io.compression.DeflateCompressor

akka.stream.impl.io.compression.GzipCompressor

public class GzipCompressor
extends DeflateCompressor

INTERNAL API

Constructor Summary

Constructors

Constructor and Description
GzipCompressor()

Method Summary

Modifier and Type	Method and Description
protected ByteString	compressWithBuffer(ByteString input, byte[] buffer)
protected java.util.zip.Deflater	deflater()
protected ByteString	finishWithBuffer(byte[] buffer)
protected ByteString	flushWithBuffer(byte[] buffer)

Methods inherited from class akka.stream.impl.io.compression.DeflateCompressor

close, compress, compressAndFinish, compressAndFlush, drainDeflater, finish, flush, MinBufferSize

Methods inherited from class java.lang.Object

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

Constructor Detail

GzipCompressor

public GzipCompressor()

Method Detail

deflater

protected java.util.zip.Deflater deflater()

Overrides:

deflater in class DeflateCompressor

compressWithBuffer

protected ByteString compressWithBuffer(ByteString input,
                                        byte[] buffer)

Overrides:

compressWithBuffer in class DeflateCompressor

flushWithBuffer

protected ByteString flushWithBuffer(byte[] buffer)

Overrides:

flushWithBuffer in class DeflateCompressor

finishWithBuffer

protected ByteString finishWithBuffer(byte[] buffer)

Overrides:

finishWithBuffer in class DeflateCompressor