net.officefloor.plugin.stream.impl

Class ServerInputStreamImpl

java.lang.Object

java.io.InputStream

net.officefloor.plugin.stream.ServerInputStream

net.officefloor.plugin.stream.impl.ServerInputStreamImpl

All Implemented Interfaces:

Closeable, AutoCloseable

public class ServerInputStreamImpl
extends ServerInputStream

ServerInputStream implementation.

Author:

Daniel Sagenschneider

Constructor Summary

Constructors

Constructor and Description
ServerInputStreamImpl(Object lock) Initiate.
ServerInputStreamImpl(Object lock, Serializable stateMomento) Initiate.

Method Summary

Modifier and Type	Method and Description
int	available()
BrowseInputStream	createBrowseInputStream() Obtains a new BrowseInputStream that starts browsing the input content from the current position of the ServerInputStream within the input stream of data.
Serializable	exportState() Exports the momento containing the current state of the ServerInputStream.
void	inputData(byte[] data, int startIndex, int endIndex, boolean isFurtherData) Inputs data for reading.
int	read()

Methods inherited from class java.io.InputStream

close, mark, markSupported, read, read, reset, skip

Methods inherited from class java.lang.Object

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

Constructor Detail

ServerInputStreamImpl

public ServerInputStreamImpl(Object lock)

Initiate.

Parameters:

lock - Object to synchronize on for operations.

ServerInputStreamImpl

public ServerInputStreamImpl(Object lock,
                             Serializable stateMomento)
                      throws IllegalArgumentException

Initiate.

Parameters:

lock - Object to synchronize on for operations.

stateMomento - Momento containing the state for this ServerInputStream.

Throws:

IllegalArgumentException - Should the momento be invalid.

Method Detail

inputData

public void inputData(byte[] data,
                      int startIndex,
                      int endIndex,
                      boolean isFurtherData)

Inputs data for reading.

Parameters:

data - Data for reading.

startIndex - Start index within the data.

endIndex - End index within the data.

isFurtherData - Indicates if further data is going to be made available.

exportState

public Serializable exportState()
                         throws NotAllDataAvailableException

Exports the momento containing the current state of the ServerInputStream.

Returns:

Momento containing the current state of the ServerInputStream.

Throws:

NotAllDataAvailableException - Should all input data not be available.

createBrowseInputStream

public BrowseInputStream createBrowseInputStream()

Description copied from class: ServerInputStream

Obtains a new BrowseInputStream that starts browsing the input content from the current position of the ServerInputStream within the input stream of data.

Specified by:

createBrowseInputStream in class ServerInputStream

Returns:

BrowseInputStream.

read

public int read()
         throws IOException,
                NoAvailableInputException

Specified by:

read in class ServerInputStream

Throws:

IOException

NoAvailableInputException

available

public int available()
              throws IOException

Specified by:

available in class ServerInputStream

Throws:

IOException