Class Pipe

java.lang.Object
org.xnio.streams.Pipe

public final class Pipe extends Object
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

      public InputStream getIn()
      Get the input (read) side of the pipe.
      Returns:
      the input side
    • getOut

      public OutputStream getOut()
      Get the output (write) side of the pipe.
      Returns:
      the output side