Package com.e1c.g5.v8.internal.fastzip.chunk

Class ZstdDecompressReadableChunkChannel

java.lang.Object

com.e1c.g5.v8.internal.fastzip.chunk.ZstdDecompressReadableChunkChannel

All Implemented Interfaces:

Closeable, AutoCloseable, Channel, ReadableByteChannel

public class ZstdDecompressReadableChunkChannel
extends Object
implements ReadableByteChannel

A channel which reads Zstandard compressed data from a sequence of chunks provided by IChunkSupplier and decompresses it.

The source data must originate from ZstdCompressWritableChunkChannel. Chunk bounds must be preserved.

Due to limitations of zstd-jni the source byte buffers provided by the chunk supplier must be direct. As any respectful channel's read, read(ByteBuffer) of this channel accepts indirect byte buffers as well as direct ones, but a slight performance penalty is expected for indirect byte buffers because of additional coping.

Constructor Summary

Constructors

Constructor	Description
ZstdDecompressReadableChunkChannel(IChunkSupplier chunkSupplier)	Constructs a new channel.

Method Summary

Modifier and Type	Method	Description
final void	close()
final boolean	isOpen()
int	read(ByteBuffer dst)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.nio.channels.Channel

close, isOpen

Constructor Details

ZstdDecompressReadableChunkChannel

public ZstdDecompressReadableChunkChannel(IChunkSupplier chunkSupplier)

Constructs a new channel.

Parameters:

chunkSupplier - the chunk supplier, must provide direct byte buffers, cannot be null

Method Details

read

public int read(ByteBuffer dst)
         throws IOException

Specified by:

read in interface ReadableByteChannel

Throws:

IOException

isOpen

public final boolean isOpen()

Specified by:

isOpen in interface Channel

close

public final void close()
                 throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Channel

Specified by:

close in interface Closeable

Throws:

IOException