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