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

Interface Encoder

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

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.pekko.util.ByteString
    encode(org.apache.pekko.util.ByteString input)
    Deprecated.
    synchronous compression with `encode` is not supported in the future any more, use `encodeAsync` instead.
    scala.concurrent.Future<org.apache.pekko.util.ByteString>
    encodeAsync(org.apache.pekko.util.ByteString input, org.apache.pekko.stream.Materializer mat)
     
    <T> T
    encodeData(T t, DataMapper<T> mapper)
     
    org.apache.pekko.http.scaladsl.coding.Encoder.message
    encodeMessage(HttpMessage message)
     
    org.apache.pekko.stream.scaladsl.Flow<org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString,org.apache.pekko.NotUsed>
    encoderFlow()
     
    HttpEncoding
    encoding()
     
    scala.Function1<HttpMessage,Object>
    messageFilter()
     
    Compressor
    newCompressor()
     
    org.apache.pekko.stream.stage.GraphStage<org.apache.pekko.stream.FlowShape<org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString>>
    singleUseEncoderFlow()
     

  • Method Details

    • encoding

      HttpEncoding encoding()

    • messageFilter

      scala.Function1<HttpMessage,Object> messageFilter()

    • encodeMessage

      org.apache.pekko.http.scaladsl.coding.Encoder.message encodeMessage(HttpMessage message)

    • encodeData

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

    • encoderFlow

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

    • encode

      org.apache.pekko.util.ByteString encode(org.apache.pekko.util.ByteString input)
      Deprecated.
      synchronous compression with `encode` is not supported in the future any more, use `encodeAsync` instead. Since Akka HTTP 10.2.0.

    • encodeAsync

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

    • newCompressor

      Compressor newCompressor()

    • singleUseEncoderFlow

      org.apache.pekko.stream.stage.GraphStage<org.apache.pekko.stream.FlowShape<org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString>> singleUseEncoderFlow()