Package io.clonecloudstore.common.quarkus.stream

Class ChunkInputStreamOptionalBuffer

java.lang.Object

java.io.InputStream

io.clonecloudstore.common.quarkus.stream.ChunkInputStreamOptionalBuffer

All Implemented Interfaces:

ChunkInputStreamInterface, Closeable, AutoCloseable

public class ChunkInputStreamOptionalBuffer
extends InputStream
implements ChunkInputStreamInterface

Transform one InputStream to Multiple InputStream, each one being a chunk of the primary one.

Note that if length is not provided, chunk size will be the buffer size used internally, so the buffer size will be reduced to 512 MB for memory capacity handling. Inversely, if length is provided, no buffer will be allocated.

Field Summary

Fields

Modifier and Type	Field	Description
final int	maxChunkSize
static final int	MIN_CHUNK_SIZE

Constructor Summary

Constructors

Constructor	Description
ChunkInputStreamOptionalBuffer(InputStream inputStream, long len, int chunkSize)

Method Summary

Modifier and Type	Method	Description
int	available()
void	close()
long	getAvailableChunkSize()
long	getChunkSize()
int	getCurrentPos()
long	getCurrentTotalRead()
boolean	isChunksDone()
boolean	markSupported()
boolean	nextChunk()
int	read()
int	read(byte[] b, int off, int len)
long	skip(long len)
long	transferTo(OutputStream out)

Methods inherited from class java.io.InputStream

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

Methods inherited from class java.lang.Object

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

Field Details

MIN_CHUNK_SIZE

public static final int MIN_CHUNK_SIZE

See Also:

• Constant Field Values

maxChunkSize

public final int maxChunkSize

Constructor Details

ChunkInputStreamOptionalBuffer

public ChunkInputStreamOptionalBuffer(InputStream inputStream,
 long len,
 int chunkSize)

Parameters:

inputStream - the InputStream to split as multiple InputStream by chunk

len - the real InputStream size; if 0, chunk size will be the buffer size used

chunkSize - the chunk size to split on

Method Details

nextChunk

public boolean nextChunk()
                  throws IOException

Specified by:

nextChunk in interface ChunkInputStreamInterface

Returns:

True if the next Chunk of InputStream is ready, else implies closing of native InputStream

Throws:

IOException - if an issue occurs

isChunksDone

public boolean isChunksDone()

Specified by:

isChunksDone in interface ChunkInputStreamInterface

Returns:

True if all chunks are done

getAvailableChunkSize

public long getAvailableChunkSize()

Specified by:

getAvailableChunkSize in interface ChunkInputStreamInterface

Returns:

if known, the chunk size currently available, else -1

getChunkSize

public long getChunkSize()

Specified by:

getChunkSize in interface ChunkInputStreamInterface

Returns:

the current chunk size

getCurrentPos

public int getCurrentPos()

Specified by:

getCurrentPos in interface ChunkInputStreamInterface

Returns:

the current position in the buffer

getCurrentTotalRead

public long getCurrentTotalRead()

Specified by:

getCurrentTotalRead in interface ChunkInputStreamInterface

Returns:

the total number of read bytes

read

public int read()
         throws IOException

Specified by:

read in interface ChunkInputStreamInterface

Specified by:

read in class InputStream

Throws:

IOException

read

public int read(byte[] b,
 int off,
 int len)
         throws IOException

Specified by:

read in interface ChunkInputStreamInterface

Overrides:

read in class InputStream

Throws:

IOException

skip

public long skip(long len)
          throws IOException

Specified by:

skip in interface ChunkInputStreamInterface

Overrides:

skip in class InputStream

Throws:

IOException

available

public int available()
              throws IOException

Specified by:

available in interface ChunkInputStreamInterface

Overrides:

available in class InputStream

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface ChunkInputStreamInterface

Specified by:

close in interface Closeable

Overrides:

close in class InputStream

Throws:

IOException

markSupported

public boolean markSupported()

Specified by:

markSupported in interface ChunkInputStreamInterface

Overrides:

markSupported in class InputStream

transferTo

public long transferTo(OutputStream out)
                throws IOException

Specified by:

transferTo in interface ChunkInputStreamInterface

Overrides:

transferTo in class InputStream

Throws:

IOException