@Internal
public class JacksonCoreProcessor
extends io.micronaut.core.async.processor.SingleThreadedBufferingProcessor<byte[],io.micronaut.json.tree.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 |
|---|
JacksonCoreProcessor(boolean streamArray,
com.fasterxml.jackson.core.JsonFactory jsonFactory,
io.micronaut.json.JsonStreamConfig deserializationConfig)
Creates a new JacksonProcessor.
|
| 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 JacksonCoreProcessor(boolean streamArray,
com.fasterxml.jackson.core.JsonFactory jsonFactory,
@NonNull
io.micronaut.json.JsonStreamConfig deserializationConfig)
streamArray - Whether arrays should be streamedjsonFactory - Factory to use for creating the parserdeserializationConfig - The deserialization configuration (in particular bignum handling)public boolean needMoreInput()
protected void doOnComplete()
doOnComplete in class io.micronaut.core.async.processor.SingleThreadedBufferingProcessor<byte[],io.micronaut.json.tree.JsonNode>protected void onUpstreamMessage(byte[] message)
onUpstreamMessage in class io.micronaut.core.async.processor.SingleThreadedBufferingProcessor<byte[],io.micronaut.json.tree.JsonNode>