public class DeflateDecompressor extends DeflateDecompressorBase
DeflateDecompressorBase.Inflate
org.apache.pekko.stream.impl.io.ByteStringParser.ByteReader, org.apache.pekko.stream.impl.io.ByteStringParser.FinishedParser$, org.apache.pekko.stream.impl.io.ByteStringParser.ParseResult<T>, org.apache.pekko.stream.impl.io.ByteStringParser.ParseResult$, org.apache.pekko.stream.impl.io.ByteStringParser.ParseStep<T>, org.apache.pekko.stream.impl.io.ByteStringParser.ParsingException, org.apache.pekko.stream.impl.io.ByteStringParser.ParsingLogic
Constructor and Description |
---|
DeflateDecompressor(int maxBytesPerChunk) |
Modifier and Type | Method and Description |
---|---|
org.apache.pekko.stream.impl.io.ByteStringParser.ParsingLogic |
createLogic(org.apache.pekko.stream.Attributes attr) |
CompactionThreshold, initialAttributes, NeedMoreData, org$apache$pekko$stream$impl$io$ByteStringParser$$bytesIn, org$apache$pekko$stream$impl$io$ByteStringParser$$objOut, shape
createLogicAndMaterializedValue
addAttributes, async, async, async, createLogicAndMaterializedValue, getAttributes, named, traversalBuilder, withAttributes
public org.apache.pekko.stream.impl.io.ByteStringParser.ParsingLogic createLogic(org.apache.pekko.stream.Attributes attr)
createLogic
in class org.apache.pekko.stream.stage.GraphStage<org.apache.pekko.stream.FlowShape<org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString>>