- java.lang.Object
- 
- io.netty5.handler.codec.compression.SnappyCompressor
 
- 
- All Implemented Interfaces:
- Compressor,- AutoCloseable
 
 public final class SnappyCompressor extends Object implements Compressor Compresses aBufferusing the Snappy framing format. See Snappy framing format.
- 
- 
Method SummaryAll Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description voidclose()# Close the compressor.Buffercompress(Buffer in, BufferAllocator allocator)This method will read from the inputBufferand compress into a newBufferthat will be allocated (if needed) from theBufferAllocator.Bufferfinish(BufferAllocator allocator)By calling this method we signal that the compression stream is marked as finish.booleanisClosed()Returntrueif the decompressor was closed,falseotherwise.booleanisFinished()Returns true if the compressor was finished or closed.static Supplier<SnappyCompressor>newFactory()Creates a new snappy compressor factory.
 
- 
- 
- 
Method Detail- 
newFactorypublic static Supplier<SnappyCompressor> newFactory() Creates a new snappy compressor factory.- Returns:
- the new instance.
 
 - 
compresspublic Buffer compress(Buffer in, BufferAllocator allocator) throws CompressionException Description copied from interface:CompressorThis method will read from the inputBufferand compress into a newBufferthat 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:
- compressin interface- Compressor
- Parameters:
- in- the- Bufferthat contains the data to be compressed.
- allocator- the- BufferAllocatorthat is used to allocate a new buffer (if needed) to write the compressed bytes too.
- Returns:
- the Bufferthat 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.
 
 - 
finishpublic Buffer finish(BufferAllocator allocator) Description copied from interface:CompressorBy calling this method we signal that the compression stream is marked as finish. The returnedBuffermight contain a "trailer" which marks the end of the stream.- Specified by:
- finishin interface- Compressor
- Returns:
- the Bufferwhich 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.
 
 - 
isFinishedpublic boolean isFinished() Description copied from interface:CompressorReturns 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()returnstruetheCompressor.compress(Buffer, BufferAllocator)method will just return an empty buffer without consuming anything from its input buffer.- Specified by:
- isFinishedin interface- Compressor
- Returns:
- trueif the compressor was marked as finished,- falseotherwise.
 
 - 
isClosedpublic boolean isClosed() Description copied from interface:CompressorReturntrueif the decompressor was closed,falseotherwise.- Specified by:
- isClosedin interface- Compressor
- Returns:
- trueif the decompressor was closed,- falseotherwise.
 
 - 
closepublic void close() Description copied from interface:Compressor# Close the compressor. After this method was calledCompressor.isFinished()will returntrueas well and it is not allowed to callCompressor.compress(Buffer, BufferAllocator)orCompressor.finish(BufferAllocator)anymore -- Specified by:
- closein interface- AutoCloseable
- Specified by:
- closein interface- Compressor
 
 
- 
 
-