Class QueueOutputStream

public class QueueOutputStream
extends OutputStream

Simple alternative to JDK PipedOutputStream; queue input stream provides what's written in queue output stream.

Example usage:

 QueueOutputStream outputStream = new QueueOutputStream();
 QueueInputStream inputStream = outputStream.newPipeInputStream();

 outputStream.write("hello world".getBytes(UTF_8));
 inputStream.read();
 

Unlike JDK PipedInputStream and PipedOutputStream, queue input/output streams may be used safely in a single thread or multiple threads. Also, unlike JDK classes, no special meaning is attached to initial or current thread. Instances can be used longer after initial threads exited.

Closing a QueueOutputStream has no effect. The methods in this class can be called after the stream has been closed without generating an IOException.