Class JacksonProcessor

All Implemented Interfaces:
Completable, Emitter<byte[]>, Processor<byte[],com.fasterxml.jackson.databind.JsonNode>, Publisher<com.fasterxml.jackson.databind.JsonNode>, Subscriber<byte[]>

public class JacksonProcessor extends SingleThreadedBufferingProcessor<byte[],com.fasterxml.jackson.databind.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
  • Constructor Details

    • JacksonProcessor

      public JacksonProcessor(com.fasterxml.jackson.core.JsonFactory jsonFactory, boolean streamArray, @Nullable @Nullable com.fasterxml.jackson.databind.DeserializationConfig deserializationConfig)
      Creates a new JacksonProcessor.
      Parameters:
      jsonFactory - The JSON factory
      streamArray - Whether arrays should be streamed
      deserializationConfig - The jackson deserialization configuration
    • JacksonProcessor

      public JacksonProcessor(com.fasterxml.jackson.core.JsonFactory jsonFactory, boolean streamArray)
      Creates a new JacksonProcessor.
      Parameters:
      jsonFactory - The JSON factory
      streamArray - Whether arrays should be streamed
    • JacksonProcessor

      public JacksonProcessor(com.fasterxml.jackson.core.JsonFactory jsonFactory, com.fasterxml.jackson.databind.DeserializationConfig deserializationConfig)
      Construct with given JSON factory.
      Parameters:
      jsonFactory - To configure and construct reader (aka parser, JsonParser) and writer (aka generator, JsonGenerator) instances.
      deserializationConfig - The jackson deserialization configuration
    • JacksonProcessor

      public JacksonProcessor(com.fasterxml.jackson.core.JsonFactory jsonFactory)
      Construct with given JSON factory.
      Parameters:
      jsonFactory - To configure and construct reader (aka parser, JsonParser) and writer (aka generator, JsonGenerator) instances.
    • JacksonProcessor

      public JacksonProcessor(com.fasterxml.jackson.databind.DeserializationConfig deserializationConfig)
      Construct with default JSON factory.
      Parameters:
      deserializationConfig - The jackson deserialization configuration
    • JacksonProcessor

      public JacksonProcessor()
      Default constructor.
  • Method Details