Package akka.http.scaladsl.coding
Class GzipDecompressor
java.lang.Object
akka.stream.stage.GraphStageWithMaterializedValue<S,akka.NotUsed>
akka.stream.stage.GraphStage<akka.stream.FlowShape<akka.util.ByteString,T>>
akka.stream.impl.io.ByteStringParser<akka.util.ByteString>
akka.http.scaladsl.coding.DeflateDecompressorBase
akka.http.scaladsl.coding.GzipDecompressor
- All Implemented Interfaces:
akka.stream.Graph<akka.stream.FlowShape<akka.util.ByteString,
akka.util.ByteString>, akka.NotUsed>
Internal API
-
Nested Class Summary
Nested classes/interfaces inherited from class akka.http.scaladsl.coding.DeflateDecompressorBase
DeflateDecompressorBase.Inflate
Nested classes/interfaces inherited from class akka.stream.impl.io.ByteStringParser
akka.stream.impl.io.ByteStringParser.ByteReader, akka.stream.impl.io.ByteStringParser.FinishedParser$, akka.stream.impl.io.ByteStringParser.ParseResult<T extends Object>, akka.stream.impl.io.ByteStringParser.ParseResult$, akka.stream.impl.io.ByteStringParser.ParseStep<T extends Object>, akka.stream.impl.io.ByteStringParser.ParsingException, akka.stream.impl.io.ByteStringParser.ParsingLogic
Nested classes/interfaces inherited from interface akka.stream.Graph
akka.stream.Graph.GraphMapMatVal<S extends akka.stream.Shape,
M extends Object> -
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionakka.stream.impl.io.ByteStringParser<akka.util.ByteString>.akka.stream.impl.io.ByteStringParser.ParsingLogic
createLogic
(akka.stream.Attributes attr) static akka.util.ByteString
Header()
INTERNAL APIMethods inherited from class akka.stream.impl.io.ByteStringParser
akka$stream$impl$io$ByteStringParser$$bytesIn, akka$stream$impl$io$ByteStringParser$$objOut, CompactionThreshold, initialAttributes, NeedMoreData, shape
Methods inherited from class akka.stream.stage.GraphStage
createLogicAndMaterializedValue
Methods inherited from class akka.stream.stage.GraphStageWithMaterializedValue
addAttributes, async, async, async, createLogicAndMaterializedValue, getAttributes, named, traversalBuilder, withAttributes
-
Constructor Details
-
GzipDecompressor
public GzipDecompressor(int maxBytesPerChunk)
-
-
Method Details
-
Header
public static akka.util.ByteString Header()INTERNAL API -
createLogic
public akka.stream.impl.io.ByteStringParser<akka.util.ByteString>.akka.stream.impl.io.ByteStringParser.ParsingLogic createLogic(akka.stream.Attributes attr) - Specified by:
createLogic
in classakka.stream.stage.GraphStage<akka.stream.FlowShape<akka.util.ByteString,
akka.util.ByteString>>
-