Class NonBlockingPumpInputStream

  • All Implemented Interfaces:
    java.io.Closeable, java.lang.AutoCloseable

    public class NonBlockingPumpInputStream
    extends NonBlockingInputStream
    • Constructor Detail

      • NonBlockingPumpInputStream

        public NonBlockingPumpInputStream()
      • NonBlockingPumpInputStream

        public NonBlockingPumpInputStream​(int bufferSize)
    • Method Detail

      • getOutputStream

        public java.io.OutputStream getOutputStream()
      • available

        public int available()
        Overrides:
        available in class java.io.InputStream
      • read

        public int read​(long timeout,
                        boolean isPeek)
                 throws java.io.IOException
        Specified by:
        read in class NonBlockingInputStream
        Throws:
        java.io.IOException
      • readBuffered

        public int readBuffered​(byte[] b,
                                int off,
                                int len,
                                long timeout)
                         throws java.io.IOException
        Overrides:
        readBuffered in class NonBlockingInputStream
        Throws:
        java.io.IOException
      • setIoException

        public void setIoException​(java.io.IOException exception)
      • checkIoException

        protected void checkIoException()
                                 throws java.io.IOException
        Throws:
        java.io.IOException
      • close

        public void close()
                   throws java.io.IOException
        Specified by:
        close in interface java.lang.AutoCloseable
        Specified by:
        close in interface java.io.Closeable
        Overrides:
        close in class java.io.InputStream
        Throws:
        java.io.IOException