Constructor Detail

• TimeoutPipedInputStream

  public TimeoutPipedInputStream(int pipeSize)

  TimeoutPipedInputStream.

Method Detail

• close

  public void close()
             throws IOException

  Overridden to save state. We have to do this because can't get to closedByReader in super

  Specified by:

  close in interface Closeable

  Specified by:

  close in interface AutoCloseable

  Overrides:

  close in class PipedInputStream

  Throws:

  IOException

• read

  public int read()
           throws IOException

  Overrides:

  read in class PipedInputStream

  Throws:

  SocketTimeoutException - if timeout is reached

  IOException

• setReadTimeout

  public void setReadTimeout(int ms)

  Must be called before blocking read call.

  Parameters:

  ms - less than or equal to zero means forever

• x_receivedLast

  void x_receivedLast()

  To save state. We have to do this because can't get to closedByWriter in super.