Package org.apache.commons.io.output
Class QueueOutputStream
java.lang.Object
java.io.OutputStream
org.apache.commons.io.output.QueueOutputStream
- All Implemented Interfaces:
- Closeable,- Flushable,- AutoCloseable
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.
 
- Since:
- 2.9.0
- See Also:
- 
Constructor SummaryConstructorsConstructorDescriptionConstructs a new instance with no limit to internal buffer size.QueueOutputStream(BlockingQueue<Integer> blockingQueue) Constructs a new instance with given buffer.
- 
Method SummaryModifier and TypeMethodDescriptionConstructs a new QueueInputStream instance connected to this.voidwrite(int b) Writes a single byte.Methods inherited from class java.io.OutputStreamclose, flush, write, write
- 
Constructor Details- 
QueueOutputStreampublic QueueOutputStream()Constructs a new instance with no limit to internal buffer size.
- 
QueueOutputStreamConstructs a new instance with given buffer.- Parameters:
- blockingQueue- backing queue for the stream
 
 
- 
- 
Method Details- 
newQueueInputStreamConstructs a new QueueInputStream instance connected to this. Writes to this output stream will be visible to the input stream.- Returns:
- QueueInputStream connected to this stream
 
- 
writeWrites a single byte.- Specified by:
- writein class- OutputStream
- Throws:
- InterruptedIOException- if the thread is interrupted while writing to the queue.
 
 
-