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