Package akka.stream.impl.io.compression

Class DeflateDecompressor

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.DeflateDecompressor

All Implemented Interfaces:

Graph<FlowShape<ByteString,ByteString>,NotUsed>

public class DeflateDecompressor
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	Description
DeflateDecompressor(int maxBytesPerChunk)
DeflateDecompressor(int maxBytesPerChunk, boolean nowrap)

Method Summary

Modifier and Type	Method	Description
DeflateDecompressorBase.DecompressorParsingLogic	createLogic(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

createLogicAndMaterializedValue, traversalBuilder, 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, async, async, named

Constructor Detail

DeflateDecompressor

public DeflateDecompressor(int maxBytesPerChunk,
                           boolean nowrap)

DeflateDecompressor

public DeflateDecompressor(int maxBytesPerChunk)

Method Detail

createLogic

public DeflateDecompressorBase.DecompressorParsingLogic createLogic(Attributes attr)

Specified by:

createLogic in class GraphStage<FlowShape<ByteString,ByteString>>