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.IOException - in case of an I/O error.protected abstract void completed()
                           throws IOException
IOException - in case of an I/O error.public final void updateCapacity(CapacityChannel capacityChannel) throws IOException
AsyncDataConsumerupdateCapacity in interface AsyncDataConsumercapacityChannel - the channel for capacity updates.IOException - in case of an I/O error.public final void consume(ByteBuffer src) throws IOException
AsyncDataConsumerconsume in interface AsyncDataConsumersrc - data source.IOException - in case of an I/O error.public final void streamEnd(List<? extends Header> trailers) throws HttpException, IOException
AsyncDataConsumerstreamEnd in interface AsyncDataConsumertrailers - data stream trailers.HttpException - in case of an HTTP protocol violation.IOException - in case of an I/O error.Copyright © 2005–2021 The Apache Software Foundation. All rights reserved.