Class BasicAsyncEntityConsumer
java.lang.Object
org.apache.hc.core5.http.nio.entity.AbstractBinDataConsumer
org.apache.hc.core5.http.nio.entity.AbstractBinAsyncEntityConsumer<byte[]>
org.apache.hc.core5.http.nio.entity.BasicAsyncEntityConsumer
- All Implemented Interfaces:
AsyncDataConsumer
,AsyncEntityConsumer<byte[]>
,ResourceHolder
Basic
AsyncEntityConsumer
implementation
that processes the data stream content into a byte array.- Since:
- 5.0
-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected int
Triggered to obtain the capacity increment.protected void
data
(ByteBuffer src, boolean endOfStream) Triggered to pass incoming data packet to the data consumer.protected byte[]
Triggered to generate entity representation.void
protected void
streamStart
(ContentType contentType) Triggered to signal beginning of entity content stream.Methods inherited from class org.apache.hc.core5.http.nio.entity.AbstractBinAsyncEntityConsumer
completed, failed, getContent, streamStart
Methods inherited from class org.apache.hc.core5.http.nio.entity.AbstractBinDataConsumer
consume, streamEnd, updateCapacity
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.apache.hc.core5.http.nio.AsyncDataConsumer
consume, streamEnd, updateCapacity
-
Field Details
-
buffer
-
-
Constructor Details
-
BasicAsyncEntityConsumer
public BasicAsyncEntityConsumer()
-
-
Method Details
-
streamStart
Description copied from class:AbstractBinAsyncEntityConsumer
Triggered to signal beginning of entity content stream.- Specified by:
streamStart
in classAbstractBinAsyncEntityConsumer<byte[]>
- Parameters:
contentType
- the entity content type- Throws:
HttpException
IOException
-
capacityIncrement
protected int capacityIncrement()Description copied from class:AbstractBinDataConsumer
Triggered to obtain the capacity increment.- Specified by:
capacityIncrement
in classAbstractBinDataConsumer
- Returns:
- the number of bytes this consumer is prepared to process.
-
data
Description copied from class:AbstractBinDataConsumer
Triggered to pass incoming data packet to the data consumer.- Specified by:
data
in classAbstractBinDataConsumer
- Parameters:
src
- the data packet.endOfStream
- flag indicating whether this data packet is the last in the data stream.- Throws:
IOException
-
generateContent
Description copied from class:AbstractBinAsyncEntityConsumer
Triggered to generate entity representation.- Specified by:
generateContent
in classAbstractBinAsyncEntityConsumer<byte[]>
- Returns:
- the entity content
- Throws:
IOException
-
releaseResources
public void releaseResources()
-