org.apache.http.nio.client.methods
Class AsyncCharConsumer<T>

java.lang.Object
  org.apache.http.nio.protocol.AbstractAsyncResponseConsumer<T>
      org.apache.http.nio.client.methods.AsyncCharConsumer<T>

All Implemented Interfaces:

Closeable, 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 Summary

AsyncCharConsumer()

AsyncCharConsumer(int bufSize)

Method Summary

protected CharsetDecoder	createDecoder(org.apache.http.entity.ContentType contentType) Invoked to create a @{link CharsetDecoder} for contentType.
protected abstract void	onCharReceived(CharBuffer buf, org.apache.http.nio.IOControl ioControl) Invoked to process a chunk of content.
protected void	onContentReceived(org.apache.http.nio.ContentDecoder decoder, org.apache.http.nio.IOControl ioControl)
protected void	onEntityEnclosed(org.apache.http.HttpEntity entity, org.apache.http.entity.ContentType contentType)
protected void	releaseResources()

Methods inherited from class org.apache.http.nio.protocol.AbstractAsyncResponseConsumer

buildResult, cancel, close, consumeContent, failed, getContentType, getException, getResult, isDone, onClose, onResponseReceived, responseCompleted, responseReceived

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AsyncCharConsumer

public AsyncCharConsumer(int bufSize)

AsyncCharConsumer

public AsyncCharConsumer()

Method Detail

onCharReceived

protected abstract void onCharReceived(CharBuffer buf,
                                       org.apache.http.nio.IOControl ioControl)
                                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.

ioControl - 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 ioControl)
                                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>