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.