org.conqat.lib.commons.io

Class ChunkInputStream

java.lang.Object

java.io.InputStream

org.conqat.lib.commons.io.ChunkInputStream

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

public class ChunkInputStream
extends java.io.InputStream

A stream that provides functionality for reading from a list of byte arrays, also called chunks.

Constructor Summary

Constructors

Constructor and Description
ChunkInputStream(java.util.List<byte[]> chunks) Creates a new ChunkInputStream with the given chunks.
ChunkInputStream(java.util.List<byte[]> chunks, int lastChunkSize) Creates a new ChunkInputStream with the given chunks.

Method Summary

Modifier and Type	Method and Description
int	available()
void	close()
int	read()
int	read(byte[] b, int offset, int length)

Methods inherited from class java.io.InputStream

mark, markSupported, read, reset, skip

Methods inherited from class java.lang.Object

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

Constructor Detail

ChunkInputStream

public ChunkInputStream(java.util.List<byte[]> chunks)

Creates a new ChunkInputStream with the given chunks.

ChunkInputStream

public ChunkInputStream(java.util.List<byte[]> chunks,
                        int lastChunkSize)

Creates a new ChunkInputStream with the given chunks. If the input chunks are the output of a ChunkOutputStream, the last chunk is probably smaller than its actual byte array size. Therefore the lastChunkSize can be specified additionally.

Parameters:

chunks - the chunks to read from, the list must not contain null values or empty arrays

lastChunkSize - the real size of the last chunk

Method Detail

read

public int read()

Specified by:

read in class java.io.InputStream

read

public int read(byte[] b,
                int offset,
                int length)

Overrides:

read in class java.io.InputStream

available

public int available()

Overrides:

available in class java.io.InputStream

close

public void close()

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Overrides:

close in class java.io.InputStream