Interface FlowableDecoder

  • All Superinterfaces:
    Indexed<String>

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

      All Methods Instance Methods Abstract Methods 
      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.
      String getKey()
      Returns the coding that the decoder supports, as it would appear in the Content-Encoding header.
    • Field Detail

    • Method Detail

      • 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.