Package akka.stream.impl.io.compression
Class GzipDecompressor
- java.lang.Object
-
- akka.stream.stage.GraphStageWithMaterializedValue<S,NotUsed>
-
- akka.stream.stage.GraphStage<FlowShape<ByteString,T>>
-
- akka.stream.impl.io.ByteStringParser<ByteString>
-
- akka.stream.impl.io.compression.DeflateDecompressorBase
-
- akka.stream.impl.io.compression.GzipDecompressor
-
- All Implemented Interfaces:
Graph<FlowShape<ByteString,ByteString>,NotUsed>
public class GzipDecompressor extends DeflateDecompressorBase
Reading the header bytes
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class akka.stream.impl.io.compression.DeflateDecompressorBase
DeflateDecompressorBase.DecompressorParsingLogic
-
Nested classes/interfaces inherited from class akka.stream.impl.io.ByteStringParser
ByteStringParser.ByteReader, ByteStringParser.FinishedParser$, ByteStringParser.ParseResult<T>, ByteStringParser.ParseResult$, ByteStringParser.ParseStep<T>, ByteStringParser.ParsingException, ByteStringParser.ParsingLogic
-
-
Constructor Summary
Constructors Constructor Description GzipDecompressor(int maxBytesPerChunk)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description DeflateDecompressorBase.DecompressorParsingLogic
createLogic(Attributes attr)
static ByteString
Header()
-
Methods inherited from class akka.stream.impl.io.ByteStringParser
CompactionThreshold, initialAttributes, NeedMoreData, shape
-
Methods inherited from class akka.stream.stage.GraphStage
createLogicAndMaterializedValue
-
Methods inherited from class akka.stream.stage.GraphStageWithMaterializedValue
createLogicAndMaterializedValue, traversalBuilder, withAttributes
-
-
-
-
Method Detail
-
Header
public static ByteString Header()
-
createLogic
public DeflateDecompressorBase.DecompressorParsingLogic createLogic(Attributes attr)
- Specified by:
createLogic
in classGraphStage<FlowShape<ByteString,ByteString>>
-
-