Package org.apache.pekko.http.scaladsl.coding

Interface Decoder

All Known Subinterfaces:
Coder, StreamDecoder
All Known Implementing Classes:
Deflate, Deflate$, Gzip, Gzip$, NoCoding$
public interface Decoder

  • Method Summary

    Modifier and Type
    Method
    Description
    scala.concurrent.Future<org.apache.pekko.util.ByteString>
    decode(org.apache.pekko.util.ByteString input, org.apache.pekko.stream.Materializer mat)
     
    <T> T
    decodeData(T t, DataMapper<T> mapper)
     
    org.apache.pekko.http.scaladsl.coding.Decoder.message
    decodeMessage(HttpMessage message)
     
    org.apache.pekko.stream.scaladsl.Flow<org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString,org.apache.pekko.NotUsed>
    decoderFlow()
     
    HttpEncoding
    encoding()
     
    int
    maxBytesPerChunk()
     
    Decoder
    withMaxBytesPerChunk(int maxBytesPerChunk)
     

  • Method Details

    • encoding

      HttpEncoding encoding()

    • decodeMessage

      org.apache.pekko.http.scaladsl.coding.Decoder.message decodeMessage(HttpMessage message)

    • decodeData

      <T> T decodeData(T t, DataMapper<T> mapper)

    • maxBytesPerChunk

      int maxBytesPerChunk()

    • withMaxBytesPerChunk

      Decoder withMaxBytesPerChunk(int maxBytesPerChunk)

    • decoderFlow

      org.apache.pekko.stream.scaladsl.Flow<org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString,org.apache.pekko.NotUsed> decoderFlow()

    • decode

      scala.concurrent.Future<org.apache.pekko.util.ByteString> decode(org.apache.pekko.util.ByteString input, org.apache.pekko.stream.Materializer mat)