akka.stream.impl.io

Class ByteStringParser.ParsingLogic

java.lang.Object

akka.stream.stage.GraphStageLogic

akka.stream.impl.io.ByteStringParser.ParsingLogic

All Implemented Interfaces:

InHandler, OutHandler

Direct Known Subclasses:

DeflateDecompressorBase.DecompressorParsingLogic

Enclosing class:

ByteStringParser<T>

public class ByteStringParser.ParsingLogic
extends GraphStageLogic
implements InHandler, OutHandler

Nested Class Summary

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 and Description
ParsingLogic()

Method Summary

Modifier and Type	Method and Description
void	onPull() Called when the output port has received a pull, and therefore ready to emit an element, i.e.
void	onPush() Called when the input port has a new element available.
void	onUpstreamFinish() Called when the input port is finished.
protected int	recursionLimit()
protected void	startWith(ByteStringParser.ParseStep<T> step)

Methods inherited from class akka.stream.stage.GraphStageLogic

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, postStop, preStart, pull, push, read, read, readN, readN, setHandler, setHandler, setHandlers, setKeepGoing, stageActor, stageId, 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

ParsingLogic

public ParsingLogic()

Method Detail

startWith

protected final void startWith(ByteStringParser.ParseStep<T> step)

recursionLimit

protected int recursionLimit()

onPull

public void onPull()

Description copied from interface: OutHandler

Called when the output port has received a pull, and therefore ready to emit an element, i.e. GraphStageLogic.push() is now allowed to be called on this port.

Specified by:

onPull in interface OutHandler

onPush

public void onPush()

Description copied from interface: InHandler

Called when the input port has a new element available. The actual element can be retrieved via the GraphStageLogic.grab() method.

Specified by:

onPush in interface InHandler

onUpstreamFinish

public void onUpstreamFinish()

Description copied from interface: InHandler

Called when the input port is finished. After this callback no other callbacks will be called for this port.

Specified by:

onUpstreamFinish in interface InHandler