@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 mannerConstructor 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, subscribeDownstream
newDownstreamSubscription, onComplete, onError, onNext, onSubscribe, provideDownstreamSubscription
public 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>