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

Class JsonNodeSequenceEntityConsumer

java.lang.Object

org.apache.hc.core5.jackson2.http.JsonNodeSequenceEntityConsumer

All Implemented Interfaces:

AsyncDataConsumer, AsyncEntityConsumer<Long>, ResourceHolder

public class JsonNodeSequenceEntityConsumer
extends Object

AsyncEntityConsumer implementation that converts incoming HTTP message entity into a sequence of JsonNode instance and passes those objects to the JsonResultSink.

Since:

5.5

Constructor Summary

Constructors

Constructor	Description
JsonNodeSequenceEntityConsumer(com.fasterxml.jackson.databind.ObjectMapper objectMapper, JsonResultSink<com.fasterxml.jackson.databind.JsonNode> resultSink)

Method Summary

Modifier and Type	Method	Description
final void	consume(ByteBuffer data)
protected JsonTokenConsumer	createJsonTokenConsumer(Consumer<Long> resultConsumer)
final void	failed(Exception cause)
final Long	getContent()
void	releaseResources()
final void	streamEnd(List<? extends Header> trailers)
final void	streamStart(EntityDetails entityDetails, FutureCallback<Long> 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

JsonNodeSequenceEntityConsumer

public JsonNodeSequenceEntityConsumer(com.fasterxml.jackson.databind.ObjectMapper objectMapper,
 JsonResultSink<com.fasterxml.jackson.databind.JsonNode> resultSink)

Method Details

createJsonTokenConsumer

protected JsonTokenConsumer createJsonTokenConsumer(Consumer<Long> resultConsumer)

streamStart

public final void streamStart(EntityDetails entityDetails,
 FutureCallback<Long> 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 Long getContent()

Specified by:

getContent in interface AsyncEntityConsumer<T>

releaseResources

public void releaseResources()

Specified by:

releaseResources in interface ResourceHolder