Package org.apache.hc.core5.jackson2.http

Class JsonTokenEntityConsumer

java.lang.Object

org.apache.hc.core5.jackson2.http.JsonTokenEntityConsumer

All Implemented Interfaces:

AsyncDataConsumer, AsyncEntityConsumer<Void>, ResourceHolder

public class JsonTokenEntityConsumer
extends Object

AsyncEntityConsumer implementation that converts incoming HTTP message entity into a sequence of JSON tokens passed as events to the given JsonTokenEventHandler.

Since:

5.5

Constructor Summary

Constructors

Constructor	Description
JsonTokenEntityConsumer(com.fasterxml.jackson.core.JsonFactory jsonFactory, JsonTokenConsumer tokenConsumer)
JsonTokenEntityConsumer(com.fasterxml.jackson.core.JsonFactory jsonFactory, JsonTokenEventHandler eventHandler)

Method Summary

Modifier and Type	Method	Description
final void	consume(ByteBuffer data)
protected JsonTokenConsumer	createJsonTokenConsumer(Consumer<Void> resultConsumer)
final void	failed(Exception cause)
final Void	getContent()
void	releaseResources()
final void	streamEnd(List<? extends Header> trailers)
final void	streamStart(EntityDetails entityDetails, FutureCallback<Void> resultCallback)
final void	updateCapacity(CapacityChannel capacityChannel)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

JsonTokenEntityConsumer

public JsonTokenEntityConsumer(com.fasterxml.jackson.core.JsonFactory jsonFactory,
 JsonTokenEventHandler eventHandler)

JsonTokenEntityConsumer

public JsonTokenEntityConsumer(com.fasterxml.jackson.core.JsonFactory jsonFactory,
 JsonTokenConsumer tokenConsumer)

Method Details

createJsonTokenConsumer

protected JsonTokenConsumer createJsonTokenConsumer(Consumer<Void> resultConsumer)

streamStart

public final void streamStart(EntityDetails entityDetails,
 FutureCallback<Void> resultCallback)
                       throws HttpException,
IOException

Specified by:

streamStart in interface AsyncEntityConsumer<T>

Throws:

HttpException

IOException

updateCapacity

public final void updateCapacity(CapacityChannel capacityChannel)
                          throws IOException

Specified by:

updateCapacity in interface AsyncDataConsumer

Throws:

IOException

consume

public final void consume(ByteBuffer data)
                   throws IOException

Specified by:

consume in interface AsyncDataConsumer

Throws:

IOException

streamEnd

public final void streamEnd(List<? extends Header> trailers)
                     throws HttpException,
IOException

Specified by:

streamEnd in interface AsyncDataConsumer

Throws:

HttpException

IOException

failed

public final void failed(Exception cause)

Specified by:

failed in interface AsyncEntityConsumer<T>

getContent

public final Void getContent()

Specified by:

getContent in interface AsyncEntityConsumer<T>

releaseResources

public void releaseResources()

Specified by:

releaseResources in interface ResourceHolder