Module io.inverno.mod.base
Package io.inverno.mod.base.converter

Interface ReactiveDecoder<From,To>

Type Parameters:
From - the encoded type
To - the decoded type
All Superinterfaces:
Decoder<From,To>
All Known Subinterfaces:
MediaTypeConverter<From>, ReactiveConverter<A,B>
All Known Implementing Classes:
ByteBufConverter, JacksonByteBufConverter, JacksonStringConverter, JsonByteBufMediaTypeConverter, JsonStringMediaTypeConverter, NdJsonByteBufMediaTypeConverter, NdJsonStringMediaTypeConverter, TextByteBufMediaTypeConverter, TextStringMediaTypeConverter
public interface ReactiveDecoder<From,To> extends Decoder<From,To>

A reactive decoder.

Since:
1.0
Author:
Jeremy Kuhn
See Also:

  • Method Summary

    Modifier and Type
    Method
    Description
    <T extends To>
    Flux<T>
    decodeMany(Publisher<From> value, Class<T> type)
    Decodes the specified stream of values whose type is represented by the specified class into a flux stream of values.
    <T extends To>
    Flux<T>
    decodeMany(Publisher<From> value, Type type)
    Decodes the specified stream of values whose type is the specified type into a flux stream of values.
    <T extends To>
    Mono<T>
    decodeOne(Publisher<From> value, Class<T> type)
    Decodes the specified stream of values whose type is represented by the specified class into a mono stream of values.
    <T extends To>
    Mono<T>
    decodeOne(Publisher<From> value, Type type)
    Decodes the specified stream of values whose type is the specified type into a mono stream of value.

    Methods inherited from interface io.inverno.mod.base.converter.Decoder

    decode, decode

  • Method Details

    • decodeOne

      <T extends To> Mono<T> decodeOne(Publisher<From> value, Class<T> type)

      Decodes the specified stream of values whose type is represented by the specified class into a mono stream of values.

      Type Parameters:
      T - the type of the decoded object
      Parameters:
      value - the stream of values to decode
      type - the class of the decoded object
      Returns:
      a mono emitting the decoded value

    • decodeOne

      <T extends To> Mono<T> decodeOne(Publisher<From> value, Type type)

      Decodes the specified stream of values whose type is the specified type into a mono stream of value.

      Type Parameters:
      T - the type of the decoded object
      Parameters:
      value - the stream of values to decode
      type - the type of the decoded object
      Returns:
      a mono emitting the decoded value

    • decodeMany

      <T extends To> Flux<T> decodeMany(Publisher<From> value, Class<T> type)

      Decodes the specified stream of values whose type is represented by the specified class into a flux stream of values.

      Type Parameters:
      T - the type of the decoded object
      Parameters:
      value - the stream of values to decode
      type - the class of the decoded object
      Returns:
      a flux emitting the decoded values

    • decodeMany

      <T extends To> Flux<T> decodeMany(Publisher<From> value, Type type)

      Decodes the specified stream of values whose type is the specified type into a flux stream of values.

      Type Parameters:
      T - the type of the decoded object
      Parameters:
      value - the stream of values to decode
      type - the type of the decoded object
      Returns:
      a flux emitting the decoded values