AsyncRequestConsumer that represents the request message as
a Message and relies on a AsyncEntityConsumer to process request entity stream.
| Modifier and Type | Field and Description |
|---|---|
| private final AtomicReference | |
| private final Supplier |
| Access | Constructor and Description |
|---|---|
| public | |
| public |
| Modifier and Type | Method and Description |
|---|---|
| public void | consume(final ByteBuffer
data source. src)Implements org. |
| public void | consumeRequest(final HttpRequest
the request message head. request, final EntityDetails the request entity details or entityDetails, final HttpContext null if the request
does not enclose an entity.the actual execution context. httpContext, final FutureCallback<Message<HttpRequest, T>> the result callback called when request processing
has been completed successfully or unsuccessfully. resultCallback)Implements org. |
| public void | failed(final Exception
the cause of the failure. cause)Implements org. |
| public void | |
| public void | streamEnd(final List<? extends Header>
data stream trailers. trailers)Implements org. |
| public void | updateCapacity(final CapacityChannel
the channel for capacity updates. capacityChannel)Implements org. |
| dataConsumerRef | back to summary |
|---|---|
| private final AtomicReference<AsyncEntityConsumer<T>> dataConsumerRef | |
| dataConsumerSupplier | back to summary |
|---|---|
| private final Supplier<AsyncEntityConsumer<T>> dataConsumerSupplier | |
| BasicRequestConsumer | back to summary |
|---|---|
| public BasicRequestConsumer(final Supplier<AsyncEntityConsumer<T>> dataConsumerSupplier) | |
| BasicRequestConsumer | back to summary |
|---|---|
| public BasicRequestConsumer(final AsyncEntityConsumer<T> dataConsumer) | |
| consume | back to summary |
|---|---|
| public void consume(final ByteBuffer src) throws IOException Implements org. Doc from org. Triggered to pass incoming data to the data consumer. The consumer must consume the entire content of the data buffer. The consumer must stop incrementing its capacity on the capacity channel if it is unable to accept more data. Once the data consumer has handled accumulated data or allocated more intermediate storage it can update its capacity information on the capacity channel.
| |
| consumeRequest | back to summary |
|---|---|
| public void consumeRequest(final HttpRequest request, final EntityDetails entityDetails, final HttpContext httpContext, final FutureCallback<Message<HttpRequest, T>> resultCallback) throws HttpException, IOException Implements org. Doc from org. Triggered to signal receipt of a request message head.
| |
| failed | back to summary |
|---|---|
| public void failed(final Exception cause) Implements org. Doc from org. Triggered to signal a failure in data processing. | |
| releaseResources | back to summary |
|---|---|
| public void releaseResources() Implements org.
| |
| streamEnd | back to summary |
|---|---|
| public void streamEnd(final List<? extends Header> trailers) throws HttpException, IOException Implements org. Doc from org. Triggered to signal termination of the data stream. | |
| updateCapacity | back to summary |
|---|---|
| public void updateCapacity(final CapacityChannel capacityChannel) throws IOException Implements org. Doc from org. Triggered to signal ability of the underlying data stream to receive data capacity update. The data consumer can choose to write data immediately inside the call or asynchronously at some later point.
| |