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

INTERNAL API

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 and Description
GzipDecompressor(int maxBytesPerChunk)

Method Summary

Modifier and Type	Method and Description
static Graph<S,M>	addAttributes(Attributes attr)
static Graph<S,M>	async()
DeflateDecompressorBase.DecompressorParsingLogic	createLogic(Attributes attr)
static scala.Tuple2<GraphStageLogic,NotUsed>	createLogicAndMaterializedValue(Attributes inheritedAttributes)
static ByteString	Header()
static Attributes	initialAttributes()
static StreamLayout.Module	module()
static Graph<S,M>	named(java.lang.String name)
static FlowShape<ByteString,T>	shape()
static Graph<S,M>	withAttributes(Attributes attr)

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

module, withAttributes

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface akka.stream.Graph

addAttributes, async, named

Constructor Detail

GzipDecompressor

public GzipDecompressor(int maxBytesPerChunk)

Method Detail

Header

public static ByteString Header()

named

public static Graph<S,M> named(java.lang.String name)

async

public static Graph<S,M> async()

addAttributes

public static Graph<S,M> addAttributes(Attributes attr)

module

public static final StreamLayout.Module module()

withAttributes

public static final Graph<S,M> withAttributes(Attributes attr)

createLogicAndMaterializedValue

public static final scala.Tuple2<GraphStageLogic,NotUsed> createLogicAndMaterializedValue(Attributes inheritedAttributes)

initialAttributes

public static Attributes initialAttributes()

shape

public static final FlowShape<ByteString,T> shape()

createLogic

public DeflateDecompressorBase.DecompressorParsingLogic createLogic(Attributes attr)

Specified by:

createLogic in class DeflateDecompressorBase