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