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
public class BasicAsyncEntityConsumer extends AbstractBinAsyncEntityConsumer<byte[]>
BasicAsyncEntityConsumer
implementation that processes the data stream content into a byte array.- Since:
- 5.0
-
-
Field Summary
Fields Modifier and Type Field Description private ByteArrayBuffer
buffer
-
Constructor Summary
Constructors Constructor Description BasicAsyncEntityConsumer()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected int
capacityIncrement()
Triggered to obtain the capacity increment.protected void
data(java.nio.ByteBuffer src, boolean endOfStream)
Triggered to pass incoming data packet to the data consumer.protected byte[]
generateContent()
Triggered to generate entity representation.void
releaseResources()
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 Detail
-
buffer
private final ByteArrayBuffer buffer
-
-
Method Detail
-
streamStart
protected void streamStart(ContentType contentType) throws HttpException, java.io.IOException
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
java.io.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
protected void data(java.nio.ByteBuffer src, boolean endOfStream) throws java.io.IOException
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:
java.io.IOException
-
generateContent
protected byte[] generateContent() throws java.io.IOException
Description copied from class:AbstractBinAsyncEntityConsumer
Triggered to generate entity representation.- Specified by:
generateContent
in classAbstractBinAsyncEntityConsumer<byte[]>
- Returns:
- the entity content
- Throws:
java.io.IOException
-
releaseResources
public void releaseResources()
-
-