@Internal public class JacksonCoreProcessor extends SingleThreadedBufferingProcessor<byte[],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 mannerSingleThreadedBufferingSubscriber.BackPressureState, SingleThreadedBufferingSubscriber.DownstreamSubscription
upstreamBuffer, upstreamDemand, upstreamState, upstreamSubscription
Constructor and Description |
---|
JacksonCoreProcessor(boolean streamArray,
com.fasterxml.jackson.core.JsonFactory jsonFactory,
JsonStreamConfig deserializationConfig)
Creates a new JacksonProcessor.
|
Modifier and Type | Method and Description |
---|---|
protected void |
doOnComplete()
Implement
Subscriber.onComplete() . |
boolean |
needMoreInput() |
protected void |
onUpstreamMessage(byte[] message)
Called when an message is received from the upstream
Subscriber . |
currentDownstreamSubscriber, doOnError, doOnNext, doOnSubscribe, getDownstreamSubscriber, subscribe, subscribeDownstream
newDownstreamSubscription, onComplete, onError, onNext, onSubscribe, provideDownstreamSubscription
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
onComplete, onError, onNext, onSubscribe
public JacksonCoreProcessor(boolean streamArray, com.fasterxml.jackson.core.JsonFactory jsonFactory, @NonNull 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()
SingleThreadedBufferingSubscriber
Subscriber.onComplete()
.doOnComplete
in class SingleThreadedBufferingProcessor<byte[],JsonNode>
protected void onUpstreamMessage(byte[] message)
SingleThreadedBufferingProcessor
Subscriber
.onUpstreamMessage
in class SingleThreadedBufferingProcessor<byte[],JsonNode>
message
- The message