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.
|
releaseResources
void updateCapacity(CapacityChannel capacityChannel) throws IOException
capacityChannel
- the channel for capacity updates.IOException
void consume(ByteBuffer src) throws IOException
src
- data source.IOException
void streamEnd(List<? extends Header> trailers) throws HttpException, IOException
trailers
- data stream trailers.HttpException
IOException
Copyright © 2005–2021 The Apache Software Foundation. All rights reserved.