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
All Methods Instance Methods Abstract Methods Concrete Methods 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
-
-
-
-
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 classGraphStageLogic
-
-