Module 

Interface BufferPipeInputStream.InputHandler

  • All Superinterfaces:
    java.lang.AutoCloseable, java.io.Closeable
    Enclosing class:
    BufferPipeInputStream

    public static interface BufferPipeInputStream.InputHandler
    extends java.io.Closeable
    A handler for events relating to the consumption of data from a BufferPipeInputStream instance.
    • Method Detail

      • acknowledge

        void acknowledge​(Pooled<java.nio.ByteBuffer> pooled)
                  throws java.io.IOException
        Acknowledges the successful processing of an input buffer. Though this method may throw an exception, it is not acted upon. The acknowledged resource is passed in, with its position set to the number of bytes consumed.
        Parameters:
        pooled - the pooled resource which was consumed
        Throws:
        java.io.IOException - if an I/O error occurs sending the acknowledgement
      • close

        void close()
            throws java.io.IOException
        Signifies that the user of the enclosing BufferPipeInputStream has called the close() method explicitly. Any thrown exception is propagated up to the caller of NioByteInput.close().
        Specified by:
        close in interface java.lang.AutoCloseable
        Specified by:
        close in interface java.io.Closeable
        Throws:
        java.io.IOException - if an I/O error occurs