Package akka.stream.impl.fusing
Class GraphInterpreterShell
- java.lang.Object
-
- akka.stream.impl.fusing.GraphInterpreterShell
-
public final class GraphInterpreterShell extends java.lang.Object
param: promise Will be completed upon processing the event, or failed if processing the event throws if the event isn't ever processed the promise (the operator stops) is failed elsewhere
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description class
GraphInterpreterShell.Abort
class
GraphInterpreterShell.Abort$
class
GraphInterpreterShell.AsyncInput
param: promise Will be completed upon processing the event, or failed if processing the event throws if the event isn't ever processed the promise (the operator stops) is failed elsewhereclass
GraphInterpreterShell.AsyncInput$
class
GraphInterpreterShell.ResumeShell
class
GraphInterpreterShell.ResumeShell$
-
Constructor Summary
Constructors Constructor Description GraphInterpreterShell(GraphInterpreter.Connection[] connections, GraphStageLogic[] logics, ActorMaterializerSettings settings, Attributes attributes, ExtendedActorMaterializer mat)
-
Method Summary
-
-
-
Constructor Detail
-
GraphInterpreterShell
public GraphInterpreterShell(GraphInterpreter.Connection[] connections, GraphStageLogic[] logics, ActorMaterializerSettings settings, Attributes attributes, ExtendedActorMaterializer mat)
-
-
Method Detail
-
Abort
public GraphInterpreterShell.Abort$ Abort()
-
AsyncInput
public GraphInterpreterShell.AsyncInput$ AsyncInput()
-
ResumeShell
public GraphInterpreterShell.ResumeShell$ ResumeShell()
-
connections
public GraphInterpreter.Connection[] connections()
-
connections_$eq
public void connections_$eq(GraphInterpreter.Connection[] x$1)
-
init
public int init(ActorRef self, SubFusingActorMaterializerImpl subMat, scala.Function1<java.lang.Object,scala.runtime.BoxedUnit> enqueueToShortCircuit, int eventLimit)
-
interpreter
public GraphInterpreter interpreter()
-
isInitialized
public boolean isInitialized()
-
isTerminated
public boolean isTerminated()
-
log
public LoggingAdapter log()
-
logics
public GraphStageLogic[] logics()
-
logics_$eq
public void logics_$eq(GraphStageLogic[] x$1)
-
mat
public ExtendedActorMaterializer mat()
-
processEvent
public int processEvent(ActorGraphInterpreter.BoundaryEvent event, int eventLimit)
-
resume
public GraphInterpreterShell.ResumeShell resume()
-
runBatch
public int runBatch(int actorEventLimit)
-
sendResume
public void sendResume(boolean sendResume)
-
shellEventLimit
public int shellEventLimit()
-
subscribeArrived
public void subscribeArrived()
-
toSnapshot
public InterpreterSnapshot toSnapshot()
-
tryAbort
public void tryAbort(java.lang.Throwable ex)
Attempts to abort execution, by first propagating the reason given until either - the interpreter successfully finishes - the event limit is reached - a new error is encountered- Parameters:
ex
- (undocumented)
-
-