Modifier and Type | Method and Description |
---|---|
akka.stream.scaladsl.Flow<akka.util.ByteString,akka.util.ByteString,akka.NotUsed> |
decoderFlow() |
int |
maxBytesPerChunk() |
scala.Function0<akka.stream.stage.GraphStage<akka.stream.FlowShape<akka.util.ByteString,akka.util.ByteString>>> |
newDecompressorStage(int maxBytesPerChunk) |
Decoder |
withMaxBytesPerChunk(int newMaxBytesPerChunk) |
decode, decode, decodeData, decodeMessage, encoding
akka.stream.scaladsl.Flow<akka.util.ByteString,akka.util.ByteString,akka.NotUsed> decoderFlow()
decoderFlow
in interface Decoder
int maxBytesPerChunk()
maxBytesPerChunk
in interface Decoder
scala.Function0<akka.stream.stage.GraphStage<akka.stream.FlowShape<akka.util.ByteString,akka.util.ByteString>>> newDecompressorStage(int maxBytesPerChunk)
Decoder withMaxBytesPerChunk(int newMaxBytesPerChunk)
withMaxBytesPerChunk
in interface Decoder