Package akka.stream.impl.io.compression

Class DeflateDecompressorBase.DecompressorParsingLogic

java.lang.Object

akka.stream.stage.GraphStageLogic

akka.stream.impl.io.ByteStringParser.ParsingLogic

akka.stream.impl.io.compression.DeflateDecompressorBase.DecompressorParsingLogic

All Implemented Interfaces:

InHandler, OutHandler

Enclosing class:

DeflateDecompressorBase

public abstract class DeflateDecompressorBase.DecompressorParsingLogic
extends ByteStringParser.ParsingLogic

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	DeflateDecompressorBase.DecompressorParsingLogic.Inflate

Nested classes/interfaces inherited from class akka.stream.stage.GraphStageLogic

GraphStageLogic.ConditionalTerminateInput, GraphStageLogic.ConditionalTerminateOutput, GraphStageLogic.EagerTerminateInput$, GraphStageLogic.EagerTerminateOutput$, GraphStageLogic.IgnoreTerminateInput$, GraphStageLogic.IgnoreTerminateOutput$, GraphStageLogic.StageActor, GraphStageLogic.StageActorRef$, GraphStageLogic.StageActorRefNotInitializedException, GraphStageLogic.StageActorRefNotInitializedException$, GraphStageLogic.SubSinkInlet<T>, GraphStageLogic.SubSourceOutlet<T>, GraphStageLogic.TotallyIgnorantInput$

Constructor Summary

Constructors

Constructor	Description
DecompressorParsingLogic()

Method Summary

Modifier and Type	Method	Description
abstract void	afterBytesRead(byte[] buffer, int offset, int length)
abstract ByteStringParser.ParseStep<ByteString>	afterInflate()
abstract java.util.zip.Inflater	inflater()
abstract DeflateDecompressorBase.DecompressorParsingLogic.Inflate	inflating()
void	postStop()	Invoked after processing of external events stopped because the operator is about to stop or fail.

Methods inherited from class akka.stream.impl.io.ByteStringParser.ParsingLogic

onPull, onPush, onUpstreamFinish, recursionLimit, startWith

Methods inherited from class akka.stream.stage.GraphStageLogic

abortEmitting, abortReading, afterPostStop, attributes, attributes_$eq, beforePreStart, cancel, cancelStage, complete, completeStage, conditionalTerminateInput, conditionalTerminateOutput, createAsyncCallback, eagerTerminateInput, eagerTerminateOutput, emit, emit, emit, emitMultiple, emitMultiple, emitMultiple, emitMultiple, emitMultiple, emitMultiple, fail, failStage, getAsyncCallback, getEagerStageActor, getHandler, getHandler, getStageActor, grab, handlers, hasBeenPulled, ignoreTerminateInput, ignoreTerminateOutput, inCount, inHandler, interpreter, interpreter_$eq, isAvailable, isAvailable, isClosed, isClosed, materializer, NoPromise, onFeedbackDispatched, originalStage, originalStage_$eq, outCount, outHandler, passAlong, passAlong$default$3, passAlong$default$4, passAlong$default$5, portToConn, preStart, pull, push, read, read, readN, readN, setHandler, setHandler, setHandlers, setKeepGoing, stageActor, stageActorName, stageId, stageId_$eq, subFusingMaterializer, totallyIgnorantInput, tryPull

Methods inherited from class java.lang.Object

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

Methods inherited from interface akka.stream.stage.InHandler

onUpstreamFailure

Methods inherited from interface akka.stream.stage.OutHandler

onDownstreamFinish

Constructor Detail

DecompressorParsingLogic

public DecompressorParsingLogic()

Method Detail

afterBytesRead

public abstract void afterBytesRead(byte[] buffer,
                                    int offset,
                                    int length)

afterInflate

public abstract ByteStringParser.ParseStep<ByteString> afterInflate()

inflater

public abstract java.util.zip.Inflater inflater()

inflating

public abstract DeflateDecompressorBase.DecompressorParsingLogic.Inflate inflating()

postStop

public void postStop()

Description copied from class: GraphStageLogic

Invoked after processing of external events stopped because the operator is about to stop or fail.

Overrides:

postStop in class GraphStageLogic