Package akka.stream.impl.io.compression
Class Compressor
- java.lang.Object
-
- akka.stream.impl.io.compression.Compressor
-
- Direct Known Subclasses:
DeflateCompressor
public abstract class Compressor extends java.lang.Object
Compresses the given input and returns compressed data. The implementation can and will choose to buffer output data to improve compression. Useflush
orcompressAndFlush
to make sure that all input data has been compressed and pending output data has been returned.
-
-
Constructor Summary
Constructors Constructor Description Compressor()
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description abstract void
close()
Make sure any resources have been releasedabstract ByteString
compress(ByteString input)
abstract ByteString
compressAndFinish(ByteString input)
Combines `compress` + `finish`abstract ByteString
compressAndFlush(ByteString input)
Combines `compress` + `flush`abstract ByteString
finish()
Closes this compressed stream and return the remaining compressed data.abstract ByteString
flush()
Flushes any output data and returns the currently remaining compressed data.
-
-
-
Method Detail
-
close
public abstract void close()
Make sure any resources have been released
-
compress
public abstract ByteString compress(ByteString input)
-
compressAndFinish
public abstract ByteString compressAndFinish(ByteString input)
Combines `compress` + `finish`
-
compressAndFlush
public abstract ByteString compressAndFlush(ByteString input)
Combines `compress` + `flush`
-
finish
public abstract ByteString finish()
Closes this compressed stream and return the remaining compressed data. After calling this method, this Compressor cannot be used any further.- Returns:
- (undocumented)
-
flush
public abstract ByteString flush()
Flushes any output data and returns the currently remaining compressed data.- Returns:
- (undocumented)
-
-