- java.lang.Object
-
- io.netty5.handler.codec.compression.LzmaCompressor
-
- All Implemented Interfaces:
Compressor
,AutoCloseable
public final class LzmaCompressor extends Object implements Compressor
Compresses aBuffer
using the LZMA algorithm. See LZMA and LZMA format or documents in LZMA SDK archive.
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
# Close the compressor.Buffer
compress(Buffer in, BufferAllocator allocator)
This method will read from the inputBuffer
and compress into a newBuffer
that will be allocated (if needed) from theBufferAllocator
.Buffer
finish(BufferAllocator allocator)
By calling this method we signal that the compression stream is marked as finish.boolean
isClosed()
Returntrue
if the decompressor was closed,false
otherwise.boolean
isFinished()
Returns true if the compressor was finished or closed.static Supplier<LzmaCompressor>
newFactory()
Creates LZMA compressor factory with default settings.static Supplier<LzmaCompressor>
newFactory(int dictionarySize)
static Supplier<LzmaCompressor>
newFactory(int lc, int lp, int pb)
Creates LZMA compressor factory with specifiedlc
,lp
,pb
values and the medium dictionary size of 65536.static Supplier<LzmaCompressor>
newFactory(int lc, int lp, int pb, int dictionarySize)
Creates LZMA compressor factory with specifiedlc
,lp
,pb
values and custom dictionary size.static Supplier<LzmaCompressor>
newFactory(int lc, int lp, int pb, int dictionarySize, boolean endMarkerMode, int numFastBytes)
Creates LZMA compressor factory with specified settings.
-
-
-
Method Detail
-
newFactory
public static Supplier<LzmaCompressor> newFactory()
Creates LZMA compressor factory with default settings.- Returns:
- the factory.
-
newFactory
public static Supplier<LzmaCompressor> newFactory(int lc, int lp, int pb)
Creates LZMA compressor factory with specifiedlc
,lp
,pb
values and the medium dictionary size of 65536.- Returns:
- the factory.
-
newFactory
public static Supplier<LzmaCompressor> newFactory(int dictionarySize)
Creates LZMA compressor factory with specified dictionary size and default values oflc
= 3,lp
= 0,pb
= 2.- Returns:
- the factory.
-
newFactory
public static Supplier<LzmaCompressor> newFactory(int lc, int lp, int pb, int dictionarySize)
Creates LZMA compressor factory with specifiedlc
,lp
,pb
values and custom dictionary size.- Returns:
- the factory.
-
newFactory
public static Supplier<LzmaCompressor> newFactory(int lc, int lp, int pb, int dictionarySize, boolean endMarkerMode, int numFastBytes)
Creates LZMA compressor factory with specified settings.- Parameters:
lc
- the number of "literal context" bits, available values [0, 8], default value 3.lp
- the number of "literal position" bits, available values [0, 4], default value 0.pb
- the number of "position" bits, available values [0, 4], default value 2.dictionarySize
- available values [0,Integer.MAX_VALUE
], default value is 65536.endMarkerMode
- indicates shouldLzmaCompressor
use end of stream marker or not. Note, thatLzmaCompressor
always sets size of uncompressed data in LZMA header, so EOS marker is unnecessary. But you may use it for better portability. For full description see "LZMA Decoding modes" section of LZMA-Specification.txt in official LZMA SDK.numFastBytes
- available values [5, 273].- Returns:
- the factory.
-
compress
public Buffer compress(Buffer in, BufferAllocator allocator) throws CompressionException
Description copied from interface:Compressor
This method will read from the inputBuffer
and compress into a newBuffer
that will be allocated (if needed) from theBufferAllocator
. This method is expected to consume all data from the input but not take ownership. The caller is responsible to release the input buffer after this method returns.- Specified by:
compress
in interfaceCompressor
- Parameters:
in
- theBuffer
that contains the data to be compressed.allocator
- theBufferAllocator
that is used to allocate a new buffer (if needed) to write the compressed bytes too.- Returns:
- the
Buffer
that contains the compressed data. The caller of this method takes ownership of the buffer. The return value will never benull
. - Throws:
CompressionException
- thrown if an compression error was encountered or the compressor was closed already.
-
finish
public Buffer finish(BufferAllocator allocator)
Description copied from interface:Compressor
By calling this method we signal that the compression stream is marked as finish. The returnedBuffer
might contain a "trailer" which marks the end of the stream.- Specified by:
finish
in interfaceCompressor
- Returns:
- the
Buffer
which represent the end of the compression stream, which might be empty if the compressor don't need a trailer to signal the end. The caller of this method takes ownership of the buffer. The return value will never benull
.
-
isFinished
public boolean isFinished()
Description copied from interface:Compressor
Returns true if the compressor was finished or closed. This might happen because someone explicit calledCompressor.finish(BufferAllocator)
/Compressor.close()
or the compressor implementation did decide to close itself due a compression error which can't be recovered. AfterCompressor.isFinished()
returnstrue
theCompressor.compress(Buffer, BufferAllocator)
method will just return an empty buffer without consuming anything from its input buffer.- Specified by:
isFinished
in interfaceCompressor
- Returns:
true
if the compressor was marked as finished,false
otherwise.
-
isClosed
public boolean isClosed()
Description copied from interface:Compressor
Returntrue
if the decompressor was closed,false
otherwise.- Specified by:
isClosed
in interfaceCompressor
- Returns:
true
if the decompressor was closed,false
otherwise.
-
close
public void close()
Description copied from interface:Compressor
# Close the compressor. After this method was calledCompressor.isFinished()
will returntrue
as well and it is not allowed to callCompressor.compress(Buffer, BufferAllocator)
orCompressor.finish(BufferAllocator)
anymore -- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceCompressor
-
-