Class AsyncByteConsumer<T>

  • All Implemented Interfaces:
    Closeable, AutoCloseable, org.apache.http.concurrent.Cancellable, org.apache.http.nio.protocol.HttpAsyncResponseConsumer<T>

    public abstract class AsyncByteConsumer<T>
    extends org.apache.http.nio.protocol.AbstractAsyncResponseConsumer<T>
    HttpAsyncResponseConsumer implementation that provides convenience methods for processing of binary content entities enclosed in an HTTP response.
    Since:
    4.0
    • Constructor Detail

      • AsyncByteConsumer

        public AsyncByteConsumer​(int bufSize)
      • AsyncByteConsumer

        public AsyncByteConsumer()
    • Method Detail

      • onByteReceived

        protected abstract void onByteReceived​(ByteBuffer buf,
                                               org.apache.http.nio.IOControl ioctrl)
                                        throws IOException
        Invoked to process a chunk of content. The IOControl interface can be used to suspend input events if the consumer is temporarily unable to consume more content.
        Parameters:
        buf - chunk of content.
        ioctrl - I/O control of the underlying connection.
        Throws:
        IOException - in case of an I/O error
      • onEntityEnclosed

        protected final void onEntityEnclosed​(org.apache.http.HttpEntity entity,
                                              org.apache.http.entity.ContentType contentType)
                                       throws IOException
        Specified by:
        onEntityEnclosed in class org.apache.http.nio.protocol.AbstractAsyncResponseConsumer<T>
        Throws:
        IOException
      • onContentReceived

        protected final void onContentReceived​(org.apache.http.nio.ContentDecoder decoder,
                                               org.apache.http.nio.IOControl ioctrl)
                                        throws IOException
        Specified by:
        onContentReceived in class org.apache.http.nio.protocol.AbstractAsyncResponseConsumer<T>
        Throws:
        IOException
      • releaseResources

        protected void releaseResources()
        Specified by:
        releaseResources in class org.apache.http.nio.protocol.AbstractAsyncResponseConsumer<T>