public abstract class AbstractBinDataConsumer extends Object implements AsyncDataConsumer
| Constructor and Description |
|---|
AbstractBinDataConsumer() |
| Modifier and Type | Method and Description |
|---|---|
protected abstract int |
capacityIncrement()
Triggered to obtain the capacity increment.
|
protected abstract void |
completed()
Triggered to signal completion of data processing.
|
void |
consume(ByteBuffer src)
Triggered to pass incoming data to the data consumer.
|
protected abstract void |
data(ByteBuffer src,
boolean endOfStream)
Triggered to pass incoming data packet 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.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitreleaseResourcesprotected abstract int capacityIncrement()
protected abstract void data(ByteBuffer src, boolean endOfStream) throws IOException
src - the data packet.endOfStream - flag indicating whether this data packet is the last in the data stream.IOExceptionprotected abstract void completed()
throws IOException
IOExceptionpublic final void updateCapacity(CapacityChannel capacityChannel) throws IOException
AsyncDataConsumerupdateCapacity in interface AsyncDataConsumercapacityChannel - the channel for capacity updates.IOExceptionpublic final void consume(ByteBuffer src) throws IOException
AsyncDataConsumerconsume in interface AsyncDataConsumersrc - data source.IOExceptionpublic final void streamEnd(List<? extends Header> trailers) throws HttpException, IOException
AsyncDataConsumerstreamEnd in interface AsyncDataConsumertrailers - data stream trailers.HttpExceptionIOExceptionCopyright © 2005–2022 The Apache Software Foundation. All rights reserved.