Package net.i2p.util

Class TimeoutPipedInputStream

  • All Implemented Interfaces:
    Closeable, AutoCloseable

    class TimeoutPipedInputStream
    extends PipedInputStream
    Adds setReadTimeout(). Must be used with a TimeoutPipedOutputStream. To support InternalSocket.setSoTimeout(). Package private, not a part of the public API, not for general use.
    • Constructor Detail

      • TimeoutPipedInputStream

        public TimeoutPipedInputStream​(int pipeSize)
    • Method Detail

      • setReadTimeout

        public void setReadTimeout​(int ms)
        Must be called before blocking read call.
        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.