public class BasicAsyncEntityConsumer extends AbstractBinAsyncEntityConsumer<byte[]>
AsyncEntityConsumer implementation
 that processes the data stream content into a byte array.| Constructor and Description | 
|---|
| BasicAsyncEntityConsumer() | 
| Modifier and Type | Method and Description | 
|---|---|
| protected int | capacityIncrement()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[] | generateContent()Triggered to generate entity representation. | 
| void | releaseResources() | 
| protected void | streamStart(ContentType contentType)Triggered to signal beginning of entity content stream. | 
completed, failed, getContent, streamStartconsume, streamEnd, updateCapacityclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitconsume, streamEnd, updateCapacityprotected void streamStart(ContentType contentType) throws HttpException, IOException
AbstractBinAsyncEntityConsumerstreamStart in class AbstractBinAsyncEntityConsumer<byte[]>contentType - the entity content typeHttpException - in case of an HTTP protocol violation.IOException - in case of an I/O error.protected int capacityIncrement()
AbstractBinDataConsumercapacityIncrement in class AbstractBinDataConsumerprotected void data(ByteBuffer src, boolean endOfStream) throws IOException
AbstractBinDataConsumerdata in class AbstractBinDataConsumersrc - 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 byte[] generateContent()
                          throws IOException
AbstractBinAsyncEntityConsumergenerateContent in class AbstractBinAsyncEntityConsumer<byte[]>IOException - in case of an I/O error.public void releaseResources()
Copyright © 2005–2021 The Apache Software Foundation. All rights reserved.