Class AsyncCharConsumer<T>

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

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

      • AsyncCharConsumer

        public AsyncCharConsumer​(int bufSize)
      • AsyncCharConsumer

        public AsyncCharConsumer()
    • Method Detail

      • onCharReceived

        protected abstract void onCharReceived​(CharBuffer 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
      • createDecoder

        protected CharsetDecoder createDecoder​(org.apache.http.entity.ContentType contentType)
        Invoked to create a @{link CharsetDecoder} for contentType. This allows to use different default charsets for different content types and set appropriate coding error actions.
        Parameters:
        contentType - response Content-Type or null if not specified.
        Returns:
        content decoder.
        Since:
        4.1
      • 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>