Class QueueOutputStream

All Implemented Interfaces:
Closeable, Flushable, AutoCloseable

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));;
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.

See Also:
  • Constructor Details

    • QueueOutputStream

      Constructs a new instance with no limit to internal buffer size.
    • QueueOutputStream

      public QueueOutputStream(BlockingQueue<Integer> blockingQueue)
      Constructs a new instance with given buffer.
      blockingQueue - backing queue for the stream
  • Method Details