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