Package com.storedobject.common

Class InputOutputStream

java.lang.Object

com.storedobject.common.InputOutputStream

All Implemented Interfaces:

AutoCloseable

public class InputOutputStream
extends Object
implements AutoCloseable

A class that combines an InputStream and an OutputStream. One thread may be writing to it and another may be reading from it.

Author:

Syam

Constructor Summary

Constructors

Constructor	Description
InputOutputStream()	Constructor with a default buffer size of 8K.
InputOutputStream(int bufferSize)	Constructor.

Method Summary

Modifier and Type	Method	Description
void	abort()	Abort the streams.
void	close()
InputStream	getInputStream()	Get the input stream for reading.
OutputStream	getOutputStream()	Get the output stream for writing to it.
final boolean	isReusable()	Check whether this is reusable or not.
void	setDataListener(Runnable dataListener)	Sets a listener that will be executed when specific data-related events occur.
void	setExternalException(Exception e)	Set an exception to the input stream so that someone will get it when they try to read something from it.
void	setReusable(boolean reusable)	Set this in 'reusable' mode.

Methods inherited from class java.lang.Object

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

Constructor Details

InputOutputStream

public InputOutputStream()

Constructor with a default buffer size of 8K.

InputOutputStream

public InputOutputStream(int bufferSize)

Constructor.

Parameters:

bufferSize - Buffer size

Method Details

getInputStream

public InputStream getInputStream()

Get the input stream for reading.

Returns:

Input stream.

getOutputStream

public OutputStream getOutputStream()

Get the output stream for writing to it.

Returns:

Output stream.

isReusable

public final boolean isReusable()

Check whether this is reusable or not. (When set to 'reusable' mode, the buffer will be reset and it will possible to start reading from and writing to it again.)

Returns:

True or false.

setReusable

public void setReusable(boolean reusable)

Set this in 'reusable' mode. (When set to 'reusable' mode, the buffer will be reset and it will possible to start reading from and writing to it again.)

Parameters:

reusable - True or false

abort

public void abort()

Abort the streams. After this operation, this can not be reused too.

setExternalException

public void setExternalException(Exception e)

Set an exception to the input stream so that someone will get it when they try to read something from it.

Parameters:

e - Exception to set.

setDataListener

public void setDataListener(Runnable dataListener)

Sets a listener that will be executed when specific data-related events occur. This method allows you to register a Runnable that will be triggered during data handling processes, enabling custom logic to be integrated.

Parameters:

dataListener - The Runnable to be executed as the data listener.

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception