public final class GraphInterpreterShell
extends java.lang.Object
Constructor and Description |
---|
GraphInterpreterShell(GraphInterpreter.GraphAssembly assembly,
GraphInterpreter.Connection[] connections,
GraphStageLogic[] logics,
Shape shape,
ActorMaterializerSettings settings,
ExtendedActorMaterializer mat) |
Modifier and Type | Method and Description |
---|---|
void |
dumpWaits() |
int |
init(ActorRef self,
SubFusingActorMaterializerImpl subMat,
scala.Function1<java.lang.Object,scala.runtime.BoxedUnit> enqueueToShortCircuit,
int eventLimit) |
GraphInterpreter |
interpreter() |
boolean |
isInitialized() |
boolean |
isTerminated() |
LoggingAdapter |
log() |
ExtendedActorMaterializer |
mat() |
int |
receive(ActorGraphInterpreter.BoundaryEvent event,
int eventLimit) |
int |
runBatch(int actorEventLimit) |
void |
sendResume(boolean sendResume) |
int |
shellEventLimit() |
java.lang.String |
toString() |
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
|
public GraphInterpreterShell(GraphInterpreter.GraphAssembly assembly, GraphInterpreter.Connection[] connections, GraphStageLogic[] logics, Shape shape, ActorMaterializerSettings settings, ExtendedActorMaterializer mat)
public ExtendedActorMaterializer mat()
public LoggingAdapter log()
public GraphInterpreter interpreter()
public void dumpWaits()
public int shellEventLimit()
public boolean isInitialized()
public int init(ActorRef self, SubFusingActorMaterializerImpl subMat, scala.Function1<java.lang.Object,scala.runtime.BoxedUnit> enqueueToShortCircuit, int eventLimit)
public int receive(ActorGraphInterpreter.BoundaryEvent event, int eventLimit)
public boolean isTerminated()
public void sendResume(boolean sendResume)
public int runBatch(int actorEventLimit)
public void tryAbort(java.lang.Throwable ex)
ex
- (undocumented)public java.lang.String toString()
toString
in class java.lang.Object