Class AbstractBinAsyncEntityConsumer<T>
java.lang.Object
org.apache.hc.core5.http.nio.entity.AbstractBinDataConsumer
org.apache.hc.core5.http.nio.entity.AbstractBinAsyncEntityConsumer<T>
- Type Parameters:
T
- entity representation.
- All Implemented Interfaces:
AsyncDataConsumer
,AsyncEntityConsumer<T>
,ResourceHolder
- Direct Known Subclasses:
BasicAsyncEntityConsumer
public abstract class AbstractBinAsyncEntityConsumer<T>
extends AbstractBinDataConsumer
implements AsyncEntityConsumer<T>
Abstract binary entity content consumer.
- Since:
- 5.0
-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected final void
Triggered to signal completion of data processing.final void
Triggered to signal a failure in data processing.protected abstract T
Triggered to generate entity representation.final T
Returns the result of entity processing when it becomes available ornull
if the entity is still being received.protected abstract void
streamStart
(ContentType contentType) Triggered to signal beginning of entity content stream.final void
streamStart
(EntityDetails entityDetails, FutureCallback<T> resultCallback) Signals beginning of an incoming request entity stream.Methods inherited from class org.apache.hc.core5.http.nio.entity.AbstractBinDataConsumer
capacityIncrement, consume, data, 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
Methods inherited from interface org.apache.hc.core5.http.nio.ResourceHolder
releaseResources
-
Field Details
-
resultCallback
-
-
-
Constructor Details
-
AbstractBinAsyncEntityConsumer
public AbstractBinAsyncEntityConsumer()
-
-
Method Details
-
streamStart
Triggered to signal beginning of entity content stream.- Parameters:
contentType
- the entity content type- Throws:
HttpException
IOException
-
generateContent
Triggered to generate entity representation.- Returns:
- the entity content
- Throws:
IOException
-
streamStart
public final void streamStart(EntityDetails entityDetails, FutureCallback<T> resultCallback) throws IOException, HttpException Description copied from interface:AsyncEntityConsumer
Signals beginning of an incoming request entity stream.- Specified by:
streamStart
in interfaceAsyncEntityConsumer<T>
- Parameters:
entityDetails
- the details of the incoming message entity.resultCallback
- the result callback.- Throws:
IOException
HttpException
-
completed
Description copied from class:AbstractBinDataConsumer
Triggered to signal completion of data processing.- Specified by:
completed
in classAbstractBinDataConsumer
- Throws:
IOException
-
failed
Description copied from interface:AsyncEntityConsumer
Triggered to signal a failure in data processing.- Specified by:
failed
in interfaceAsyncEntityConsumer<T>
- Parameters:
cause
- the cause of the failure.
-
getContent
Description copied from interface:AsyncEntityConsumer
Returns the result of entity processing when it becomes available ornull
if the entity is still being received.- Specified by:
getContent
in interfaceAsyncEntityConsumer<T>
- Returns:
- the response processing result.
-