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

Class ZstdCompressWritableChunkChannel

java.lang.Object

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

All Implemented Interfaces:

Closeable, AutoCloseable, Channel, WritableByteChannel

public class ZstdCompressWritableChunkChannel
extends Object
implements WritableByteChannel

A channel which compresses data with Zstandard algorithm and writes it to a sequence of chunks provided by IChunkSupplier.

Due to limitations of zstd-jni the destination byte buffers provided by the chunk supplier must be direct. As any respectful channel's write, write(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
ZstdCompressWritableChunkChannel(IChunkSupplier chunkSupplier, int level)	Constructs a new channel.

Method Summary

Modifier and Type	Method	Description
final void	close()
final boolean	isOpen()
int	write(ByteBuffer src)

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

ZstdCompressWritableChunkChannel

public ZstdCompressWritableChunkChannel(IChunkSupplier chunkSupplier,
 int level)
                                 throws IOException

Constructs a new channel.

Parameters:

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

level - the Zstd compression level, eligible values are from 1 to 22 (inclusive)

Throws:

IOException - if an IO error occurs

Method Details

write

public int write(ByteBuffer src)
          throws IOException

Specified by:

write in interface WritableByteChannel

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