Package io.clonecloudstore.common.standard.inputstream

Class ZstdCompressInputStream

java.lang.Object

java.io.InputStream

io.clonecloudstore.common.standard.inputstream.AbstractCommonInputStream

io.clonecloudstore.common.standard.inputstream.ZstdCompressInputStream

All Implemented Interfaces:

Closeable, AutoCloseable

public class ZstdCompressInputStream
extends AbstractCommonInputStream

Zstd InputStream: takes an InputStream as entry and give back a compressed InputStream

Field Summary

Fields inherited from class io.clonecloudstore.common.standard.inputstream.AbstractCommonInputStream

done, inputStream, ioExceptionAtomicReference, outputStream, pipedInputStream, pipedOutputStream, sizeOutput, sizeRead

Constructor Summary

Constructors

Constructor	Description
ZstdCompressInputStream(InputStream inputStream)	Default constructor with flush by packet
ZstdCompressInputStream(InputStream inputStream, int level)

Method Summary

Modifier and Type	Method	Description
protected OutputStream	getNewOutputStream(Object level)
long	getSizeCompressed()
long	getSizeRead()

Methods inherited from class io.clonecloudstore.common.standard.inputstream.AbstractCommonInputStream

available, checkException, close, markSupported, read, read, read, skip, toString, transferTo

Methods inherited from class java.io.InputStream

mark, nullInputStream, readAllBytes, readNBytes, readNBytes, reset, skipNBytes

Methods inherited from class java.lang.Object

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

Constructor Details

ZstdCompressInputStream

public ZstdCompressInputStream(InputStream inputStream)
                        throws IOException

Default constructor with flush by packet

Throws:

IOException

ZstdCompressInputStream

public ZstdCompressInputStream(InputStream inputStream,
 int level)
                        throws IOException

Throws:

IOException

Method Details

getNewOutputStream

protected OutputStream getNewOutputStream(Object level)
                                   throws IOException

Specified by:

getNewOutputStream in class AbstractCommonInputStream

Throws:

IOException

getSizeRead

public long getSizeRead()

getSizeCompressed

public long getSizeCompressed()