Class InputChunked

java.lang.Object

java.io.InputStream

com.esotericsoftware.kryo.io.Input

com.esotericsoftware.kryo.io.InputChunked

All Implemented Interfaces:

Closeable, AutoCloseable

public class InputChunked
extends Input

An InputStream that reads lengths and chunks of data from another OutputStream, allowing chunks to be skipped.

Field Summary

Fields

Modifier and Type	Field	Description
private int	chunkSize

Fields inherited from class Input

buffer, capacity, chars, inputStream, limit, position, total

Constructor Summary

Constructors

Constructor	Description
InputChunked()	Creates an uninitialized InputChunked with a buffer size of 2048.
InputChunked(int bufferSize)	Creates an uninitialized InputChunked.
InputChunked(InputStream inputStream)	Creates an InputChunked with a buffer size of 2048.
InputChunked(InputStream inputStream, int bufferSize)

Method Summary

Modifier and Type	Method	Description
protected int	fill(byte[] buffer, int offset, int count)	Fills the buffer with more bytes.
void	nextChunks()	Advances the stream to the next set of chunks.
private void	readChunkSize()
void	rewind()	Sets the position and total to zero.
void	setBuffer(byte[] bytes, int offset, int count)	Sets a new buffer.
void	setInputStream(InputStream inputStream)	Sets a new InputStream.

Methods inherited from class Input

available, canReadInt, canReadLong, close, eof, getBuffer, getInputStream, limit, position, read, read, read, readBoolean, readByte, readBytes, readBytes, readBytes, readByteUnsigned, readChar, readChars, readDouble, readDouble, readDoubles, readFloat, readFloat, readFloats, readInt, readInt, readInts, readInts, readLong, readLong, readLongs, readLongs, readShort, readShorts, readShortUnsigned, readString, readStringBuilder, readVarInt, readVarLong, require, setBuffer, setLimit, setPosition, setTotal, skip, skip, total

Methods inherited from class InputStream

mark, markSupported, reset

Methods inherited from class Object

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

Field Details

chunkSize

private int chunkSize

Constructor Details

InputChunked

public InputChunked()

Creates an uninitialized InputChunked with a buffer size of 2048. The InputStream must be set before it can be used.

InputChunked

public InputChunked(int bufferSize)

Creates an uninitialized InputChunked. The InputStream must be set before it can be used.

InputChunked

public InputChunked(InputStream inputStream)

Creates an InputChunked with a buffer size of 2048.

InputChunked

public InputChunked(InputStream inputStream,
 int bufferSize)

Method Details

setInputStream

public void setInputStream(InputStream inputStream)

Description copied from class: Input

Sets a new InputStream. The position and total are reset, discarding any buffered bytes.

Overrides:

setInputStream in class Input

Parameters:

inputStream - May be null.

setBuffer

public void setBuffer(byte[] bytes,
 int offset,
 int count)

Description copied from class: Input

Sets a new buffer. The position and total are reset, discarding any buffered bytes.

Overrides:

setBuffer in class Input

rewind

public void rewind()

Description copied from class: Input

Sets the position and total to zero.

Overrides:

rewind in class Input

fill

protected int fill(byte[] buffer,
 int offset,
 int count)
            throws KryoException

Description copied from class: Input

Fills the buffer with more bytes. Can be overridden to fill the bytes from a source other than the InputStream.

Overrides:

fill in class Input

Returns:

-1 if there are no more bytes.

Throws:

KryoException

readChunkSize

private void readChunkSize()

nextChunks

public void nextChunks()

Advances the stream to the next set of chunks. InputChunked will appear to hit the end of the data until this method is called.