Class Jackson2JsonDecoder

All Implemented Interfaces:
Decoder<Object>, HttpMessageDecoder<Object>

public class Jackson2JsonDecoder extends AbstractJackson2Decoder
Decode a byte stream into JSON and convert to Object's with Jackson 2.x, leveraging non-blocking parsing.
Since:
5.0
Author:
Sebastien Deleuze, Rossen Stoyanchev
See Also:
  • Constructor Details

    • Jackson2JsonDecoder

      public Jackson2JsonDecoder()
    • Jackson2JsonDecoder

      public Jackson2JsonDecoder(ObjectMapper mapper, MimeType... mimeTypes)
  • Method Details

    • processInput

      protected reactor.core.publisher.Flux<DataBuffer> processInput(Publisher<DataBuffer> input, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)
      Description copied from class: AbstractJackson2Decoder
      Process the input publisher into a flux. Default implementation returns Flux.from(Publisher), but subclasses can choose to customize this behavior.
      Overrides:
      processInput in class AbstractJackson2Decoder
      Parameters:
      input - the DataBuffer input stream to process
      elementType - the expected type of elements in the output stream
      mimeType - the MIME type associated with the input stream (optional)
      hints - additional information about how to do encode
      Returns:
      the processed flux