Package io.clonecloudstore.common.quarkus.stream

Class ChunkInputStreamNotBuffered

java.lang.Object

java.io.InputStream

io.clonecloudstore.common.quarkus.stream.ChunkInputStreamNotBuffered

All Implemented Interfaces:

ChunkInputStreamInterface, Closeable, AutoCloseable

public class ChunkInputStreamNotBuffered
extends InputStream
implements ChunkInputStreamInterface

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

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
ChunkInputStreamNotBuffered(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

ChunkInputStreamNotBuffered

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

Parameters:

inputStream - the InputStream to split as multiple InputStream by chunk

len - the real InputStream size if known

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, possibly empty, 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 buffer 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