java.lang.Object
org.xnio.streams.Pipe
An in-VM pipe between an input stream and an output stream, which does not suffer from the
bugs in
PipedInputStream
.- Author:
- David M. Lloyd
-
Constructor Details
-
Pipe
public Pipe(int bufferSize) Construct a new instance.- Parameters:
bufferSize
- the buffer size to use
-
-
Method Details
-
await
public void await()Wait for the read side to close. Used when the writer needs to know when the reader finishes consuming a message. -
getIn
Get the input (read) side of the pipe.- Returns:
- the input side
-
getOut
Get the output (write) side of the pipe.- Returns:
- the output side
-