com.esotericsoftware.kryo.io

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.

Author:

Nathan Sweet

Field Summary

Fields inherited from class com.esotericsoftware.kryo.io.Input

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and 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.
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 com.esotericsoftware.kryo.io.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 java.io.InputStream

mark, markSupported, reset

Methods inherited from class java.lang.Object

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

Constructor Detail

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 Detail

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

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.