Class JacksonCoreProcessor

java.lang.Object

io.micronaut.core.async.subscriber.SingleThreadedBufferingSubscriber<byte[]>

io.micronaut.core.async.processor.SingleThreadedBufferingProcessor<byte[],JsonNode>

io.micronaut.jackson.core.parser.JacksonCoreProcessor

All Implemented Interfaces:

Completable, Emitter<byte[]>, Processor<byte[],JsonNode>, Publisher<JsonNode>, Subscriber<byte[]>

@Internal
public class JacksonCoreProcessor
extends SingleThreadedBufferingProcessor<byte[],JsonNode>

A Reactive streams publisher that publishes a JsonNode once the JSON has been fully consumed. Uses NonBlockingByteArrayJsonParser internally allowing the parsing of JSON from an incoming stream of bytes in a non-blocking manner

Since:

1.0

Author:

Graeme Rocher

Nested Class Summary

Nested classes/interfaces inherited from class SingleThreadedBufferingSubscriber

SingleThreadedBufferingSubscriber.BackPressureState, SingleThreadedBufferingSubscriber.DownstreamSubscription

Field Summary

Fields inherited from class SingleThreadedBufferingSubscriber

upstreamBuffer, upstreamDemand, upstreamState, upstreamSubscription

Constructor Summary

Constructors

Constructor	Description
JacksonCoreProcessor(boolean streamArray, tools.jackson.core.TokenStreamFactory jsonFactory, JsonStreamConfig deserializationConfig)	Creates a new JacksonProcessor.

Method Summary

Modifier and Type	Method	Description
protected void	doOnComplete()	Implement Subscriber.onComplete().
boolean	needMoreInput()
protected void	onUpstreamMessage(byte[] message)	Called when a message is received from the upstream Subscriber.

Methods inherited from class SingleThreadedBufferingProcessor

currentDownstreamSubscriber, doOnError, doOnNext, doOnSubscribe, getDownstreamSubscriber, subscribe, subscribeDownstream

Methods inherited from class SingleThreadedBufferingSubscriber

newDownstreamSubscription, onComplete, onError, onNext, onSubscribe, provideDownstreamSubscription

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface Subscriber

onComplete, onError, onNext, onSubscribe

Constructor Details

JacksonCoreProcessor

public JacksonCoreProcessor(boolean streamArray,
 tools.jackson.core.TokenStreamFactory jsonFactory,
 JsonStreamConfig deserializationConfig)

Creates a new JacksonProcessor.

Parameters:

streamArray - Whether arrays should be streamed

jsonFactory - Factory to use for creating the parser

deserializationConfig - The deserialization configuration (in particular bignum handling)

Method Details

needMoreInput

public boolean needMoreInput()

Returns:

Whether more input is needed

doOnComplete

protected void doOnComplete()

Description copied from class: SingleThreadedBufferingSubscriber

Implement Subscriber.onComplete().

Overrides:

doOnComplete in class SingleThreadedBufferingProcessor<byte[],JsonNode>

onUpstreamMessage

protected void onUpstreamMessage(byte[] message)

Description copied from class: SingleThreadedBufferingProcessor

Called when a message is received from the upstream Subscriber.

Specified by:

onUpstreamMessage in class SingleThreadedBufferingProcessor<byte[],JsonNode>

Parameters:

message - The message