public abstract class DeflateDecompressorBase.DecompressorParsingLogic extends ByteStringParser.ParsingLogic
Modifier and Type | Class and Description |
---|---|
class |
DeflateDecompressorBase.DecompressorParsingLogic.Inflate |
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 and Description |
---|
DecompressorParsingLogic() |
Modifier and Type | Method and 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 stage is about to stop or fail.
|
onPull, onPush, onUpstreamFinish, recursionLimit, startWith
abortEmitting, abortReading, afterPostStop, beforePreStart, cancel, complete, completeStage, conditionalTerminateInput, conditionalTerminateOutput, createAsyncCallback, eagerTerminateInput, eagerTerminateOutput, emit, emit, emit, emitMultiple, emitMultiple, emitMultiple, emitMultiple, emitMultiple, emitMultiple, fail, failStage, getAsyncCallback, getHandler, getHandler, getStageActor, grab, handlers, hasBeenPulled, ignoreTerminateInput, ignoreTerminateOutput, inCount, interpreter, isAvailable, isAvailable, isClosed, isClosed, materializer, outCount, passAlong, portToConn, preStart, pull, push, read, read, readN, readN, setHandler, setHandler, setHandlers, setKeepGoing, stageActor, stageId, subFusingMaterializer, totallyIgnorantInput, tryPull
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
onUpstreamFailure
onDownstreamFinish
public abstract java.util.zip.Inflater inflater()
public abstract ByteStringParser.ParseStep<ByteString> afterInflate()
public abstract void afterBytesRead(byte[] buffer, int offset, int length)
public abstract DeflateDecompressorBase.DecompressorParsingLogic.Inflate inflating()
public void postStop()
GraphStageLogic
postStop
in class GraphStageLogic