Interface FlowableDecoder

All Superinterfaces:
Indexed<String>

public interface FlowableDecoder extends Indexed<String>
Decodes an HTTP message entity flow.
  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    static final Map<String,FlowableDecoder>
    Mapping of supported codings to associated decoders.
  • Method Summary

    Modifier and Type
    Method
    Description
    io.reactivex.rxjava3.core.Flowable<ByteBuffer>
    decode(io.reactivex.rxjava3.core.Flowable<ByteBuffer> in)
    Returns an instance of a flowable that decodes the specified input.
    Returns the coding that the decoder supports, as it would appear in the Content-Encoding header.
  • Field Details

  • Method Details

    • getKey

      String getKey()
      Returns the coding that the decoder supports, as it would appear in the Content-Encoding header.
      Specified by:
      getKey in interface Indexed<String>
      Returns:
      The coding that the decoder supports, as it would appear in the Content-Encoding header.
    • decode

      io.reactivex.rxjava3.core.Flowable<ByteBuffer> decode(io.reactivex.rxjava3.core.Flowable<ByteBuffer> in)
      Returns an instance of a flowable that decodes the specified input. If in contains an error, the error will be propagated.
      Parameters:
      in - The flowable to be decoded.
      Returns:
      a flowable exposing the decoded content.