public class JacksonProcessor
extends io.micronaut.core.async.processor.SingleThreadedBufferingProcessor<byte[],com.fasterxml.jackson.databind.JsonNode>
JsonNode once the JSON has been fully consumed.
Uses NonBlockingJsonParser internally allowing the parsing of
JSON from an incoming stream of bytes in a non-blocking manner| Constructor and Description |
|---|
JacksonProcessor()
Default constructor.
|
JacksonProcessor(com.fasterxml.jackson.databind.DeserializationConfig deserializationConfig)
Construct with default JSON factory.
|
JacksonProcessor(com.fasterxml.jackson.core.JsonFactory jsonFactory)
Construct with given JSON factory.
|
JacksonProcessor(com.fasterxml.jackson.core.JsonFactory jsonFactory,
boolean streamArray)
Creates a new JacksonProcessor.
|
JacksonProcessor(com.fasterxml.jackson.core.JsonFactory jsonFactory,
boolean streamArray,
com.fasterxml.jackson.databind.DeserializationConfig deserializationConfig)
Creates a new JacksonProcessor.
|
JacksonProcessor(com.fasterxml.jackson.core.JsonFactory jsonFactory,
com.fasterxml.jackson.databind.DeserializationConfig deserializationConfig)
Construct with given JSON factory.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
doOnComplete() |
boolean |
needMoreInput() |
protected void |
onUpstreamMessage(byte[] message) |
currentDownstreamSubscriber, doOnError, doOnNext, doOnSubscribe, getDownstreamSubscriber, subscribe, subscribeDownstreamnewDownstreamSubscription, onComplete, onError, onNext, onSubscribe, provideDownstreamSubscriptionpublic JacksonProcessor(com.fasterxml.jackson.core.JsonFactory jsonFactory,
boolean streamArray,
@Nullable
com.fasterxml.jackson.databind.DeserializationConfig deserializationConfig)
jsonFactory - The JSON factorystreamArray - Whether arrays should be streameddeserializationConfig - The jackson deserialization configurationpublic JacksonProcessor(com.fasterxml.jackson.core.JsonFactory jsonFactory,
boolean streamArray)
jsonFactory - The JSON factorystreamArray - Whether arrays should be streamedpublic JacksonProcessor(com.fasterxml.jackson.core.JsonFactory jsonFactory,
com.fasterxml.jackson.databind.DeserializationConfig deserializationConfig)
jsonFactory - To configure and construct reader (aka parser, JsonParser)
and writer (aka generator, JsonGenerator) instances.deserializationConfig - The jackson deserialization configurationpublic JacksonProcessor(com.fasterxml.jackson.core.JsonFactory jsonFactory)
jsonFactory - To configure and construct reader (aka parser, JsonParser)
and writer (aka generator, JsonGenerator) instances.public JacksonProcessor(com.fasterxml.jackson.databind.DeserializationConfig deserializationConfig)
deserializationConfig - The jackson deserialization configurationpublic JacksonProcessor()
public boolean needMoreInput()
protected void doOnComplete()
doOnComplete in class io.micronaut.core.async.processor.SingleThreadedBufferingProcessor<byte[],com.fasterxml.jackson.databind.JsonNode>protected void onUpstreamMessage(byte[] message)
onUpstreamMessage in class io.micronaut.core.async.processor.SingleThreadedBufferingProcessor<byte[],com.fasterxml.jackson.databind.JsonNode>