akka.stream.impl.fusing

Class GraphInterpreterShell

java.lang.Object

akka.stream.impl.fusing.GraphInterpreterShell

public final class GraphInterpreterShell
extends java.lang.Object

INTERNAL API

Constructor Summary

Constructors

Constructor and Description
GraphInterpreterShell(GraphInterpreter.GraphAssembly assembly, GraphInterpreter.Connection[] connections, GraphStageLogic[] logics, Shape shape, ActorMaterializerSettings settings, ExtendedActorMaterializer mat)

Method Summary

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

GraphInterpreterShell

public GraphInterpreterShell(GraphInterpreter.GraphAssembly assembly,
                             GraphInterpreter.Connection[] connections,
                             GraphStageLogic[] logics,
                             Shape shape,
                             ActorMaterializerSettings settings,
                             ExtendedActorMaterializer mat)

Method Detail

mat

public ExtendedActorMaterializer mat()

log

public LoggingAdapter log()

interpreter

public GraphInterpreter interpreter()

dumpWaits

public void dumpWaits()

shellEventLimit

public int shellEventLimit()

isInitialized

public boolean isInitialized()

init

public int init(ActorRef self,
                SubFusingActorMaterializerImpl subMat,
                scala.Function1<java.lang.Object,scala.runtime.BoxedUnit> enqueueToShortCircuit,
                int eventLimit)

receive

public int receive(ActorGraphInterpreter.BoundaryEvent event,
                   int eventLimit)

isTerminated

public boolean isTerminated()

sendResume

public void sendResume(boolean sendResume)

runBatch

public int runBatch(int actorEventLimit)

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)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object