Class 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 NonBlockingJsonParser internally allowing the parsing of JSON from an incoming stream of bytes in a non-blocking manner
Since:
1.0
Author:
Graeme Rocher