public class QueueInputStream extends InputStream
PipedInputStream; queue input stream provides what's written in queue output stream.
QueueInputStream inputStream = new QueueInputStream(); QueueOutputStream outputStream = inputStream.newQueueOutputStream(); outputStream.write("hello world".getBytes(UTF_8)); inputStream.read();
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.
QueueInputStream has no effect. The methods in this class can be called after the stream has been
closed without generating an
|Constructor and Description|
Constructs a new instance with no limit to its internal buffer size.
Constructs a new instance with given buffer
|Modifier and Type||Method and Description|
Creates a new QueueOutputStream instance connected to this.
Reads and returns a single byte.
available, close, mark, markSupported, read, read, reset, skip
public QueueOutputStream newQueueOutputStream()
Copyright © 2002–2021 The Apache Software Foundation. All rights reserved.