public interface AsyncDataConsumer extends ResourceHolder
| Modifier and Type | Method and Description | 
|---|---|
| void | consume(ByteBuffer src)Triggered to pass incoming data to the data consumer. | 
| void | streamEnd(List<? extends Header> trailers)Triggered to signal termination of the data stream. | 
| void | updateCapacity(CapacityChannel capacityChannel)Triggered to signal ability of the underlying data stream to receive
 data capacity update. | 
releaseResourcesvoid updateCapacity(CapacityChannel capacityChannel) throws IOException
capacityChannel - the channel for capacity updates.IOExceptionvoid consume(ByteBuffer src) throws IOException
src - data source.IOExceptionvoid streamEnd(List<? extends Header> trailers) throws HttpException, IOException
trailers - data stream trailers.HttpExceptionIOExceptionCopyright © 2005–2022 The Apache Software Foundation. All rights reserved.