Class Lz4FrameDecompressor

java.lang.Object

io.netty.handler.codec.compression.Lz4FrameDecompressor

All Implemented Interfaces:

Decompressor, AutoCloseable

@UnstableApi
public final class Lz4FrameDecompressor
extends Object

Uncompresses a ByteBuf encoded with the LZ4 format. See original LZ4 Github project and LZ4 block format for full description. Since the original LZ4 block format does not contains size of compressed block and size of original data this encoder uses format like LZ4 Java library written by Adrien Grand and approved by Yann Collet (author of original LZ4 library). * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * Magic * Token * Compressed * Decompressed * Checksum * + * LZ4 compressed * * * * length * length * * * block * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * *

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	Lz4FrameDecompressor.Builder

Nested classes/interfaces inherited from interface Decompressor

Decompressor.AbstractDecompressorBuilder, Decompressor.Status

Modifier and Type	Interface	Description
static class	Decompressor.AbstractDecompressorBuilder
static enum	Decompressor.Status	Current status of the decompressor.

Field Summary

Fields

Modifier and Type	Field	Description
protected final ByteBufAllocator	allocator

Method Summary

Modifier and Type	Method	Description
final void	addInput(ByteBuf buf)	Add a new input buffer.
static Lz4FrameDecompressor.Builder	builder()
void	close()	Close this decompressor, cleaning up any associated resources.
void	endOfInput()	Notify the decompressor that the end of input has been reached.
Decompressor.Status	status()	Get the current status.
final ByteBuf	takeOutput()	Take a decompressed buffer from this decompressor.

Methods inherited from class Object

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

Field Details

allocator

protected final ByteBufAllocator allocator

Method Details

status

public Decompressor.Status status()
                           throws DecompressionException

Description copied from interface: Decompressor

Get the current status. Like the other operations on this class, calling this method is not permitted if the decompressor has failed or was closed.

Returns:

The current status

Throws:

DecompressionException

endOfInput

public void endOfInput()
                throws DecompressionException

Description copied from interface: Decompressor

Notify the decompressor that the end of input has been reached. Some implementations may flush remaining data or throw an exception if the input is truncated, but most implementations do nothing. Only permitted for Decompressor.Status.NEED_INPUT.

Throws:

DecompressionException

builder

@UnstableApi
public static Lz4FrameDecompressor.Builder builder()

addInput

public final void addInput(ByteBuf buf)
                    throws DecompressionException

Description copied from interface: Decompressor

Add a new input buffer. Only permitted for Decompressor.Status.NEED_INPUT.

Specified by:

addInput in interface Decompressor

Parameters:

buf - The input buffer. Buffer ownership transfers to the decompressor (also on exception).

Throws:

DecompressionException

takeOutput

public final ByteBuf takeOutput()
                         throws DecompressionException

Description copied from interface: Decompressor

Take a decompressed buffer from this decompressor. Only permitted for Decompressor.Status.NEED_OUTPUT. Buffer ownership transfers to the caller.

Specified by:

takeOutput in interface Decompressor

Returns:

The decompressed buffer. May be empty.

Throws:

DecompressionException

close

public void close()

Description copied from interface: Decompressor

Close this decompressor, cleaning up any associated resources. This method is idempotent.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Decompressor