public abstract class AbstractCharDataConsumer extends Object implements AsyncDataConsumer
Modifier and Type | Field and Description |
---|---|
protected static int |
DEF_BUF_SIZE |
Modifier | Constructor and Description |
---|---|
|
AbstractCharDataConsumer() |
protected |
AbstractCharDataConsumer(int bufSize,
CharCodingConfig charCodingConfig) |
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(CharBuffer src,
boolean endOfStream)
Triggered to pass incoming data packet to the data consumer.
|
protected void |
setCharset(Charset charset) |
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 static final int DEF_BUF_SIZE
protected AbstractCharDataConsumer(int bufSize, CharCodingConfig charCodingConfig)
public AbstractCharDataConsumer()
protected abstract int capacityIncrement()
protected abstract void data(CharBuffer 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
protected final void setCharset(Charset charset)
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.