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

Method Summary

Modifier and Type	Method and Description
DeflateDecompressorBase.DecompressorParsingLogic	createLogic(Attributes attr)

Methods inherited from class akka.stream.impl.io.compression.DeflateDecompressorBase

addAttributes, async, createLogicAndMaterializedValue, initialAttributes, module, named, shape, withAttributes

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

DeflateDecompressor

public DeflateDecompressor(int maxBytesPerChunk)

Method Detail

createLogic

public DeflateDecompressorBase.DecompressorParsingLogic createLogic(Attributes attr)

Specified by:

createLogic in class DeflateDecompressorBase