Package akka.stream.impl.fusing

Class GraphInterpreterShell

java.lang.Object

akka.stream.impl.fusing.GraphInterpreterShell

public final class GraphInterpreterShell
extends java.lang.Object

INTERNAL API

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 elsewhere
class	GraphInterpreterShell.AsyncInput$
class	GraphInterpreterShell.ResumeShell
class	GraphInterpreterShell.ResumeShell$

Constructor Summary

Constructors

Constructor	Description
GraphInterpreterShell(GraphInterpreter.Connection[] connections, GraphStageLogic[] logics, Attributes attributes, ExtendedActorMaterializer mat)

Method Summary

Modifier and Type	Method	Description
GraphInterpreterShell.Abort$	Abort()
GraphInterpreterShell.AsyncInput$	AsyncInput()
Attributes	attributes()
GraphInterpreter.Connection[]	connections()
void	connections_$eq(GraphInterpreter.Connection[] x$1)
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()
GraphStageLogic[]	logics()
void	logics_$eq(GraphStageLogic[] x$1)
ExtendedActorMaterializer	mat()
int	processEvent(ActorGraphInterpreter.BoundaryEvent event, int eventLimit)
GraphInterpreterShell.ResumeShell	resume()
GraphInterpreterShell.ResumeShell$	ResumeShell()
int	runBatch(int actorEventLimit)
void	sendResume(boolean sendResume)
int	shellEventLimit()
void	subscribeArrived()
InterpreterSnapshot	toSnapshot()
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, toString, wait, wait, wait

Constructor Detail

GraphInterpreterShell

public GraphInterpreterShell(GraphInterpreter.Connection[] connections,
                             GraphStageLogic[] logics,
                             Attributes attributes,
                             ExtendedActorMaterializer mat)

Method Detail

Abort

public GraphInterpreterShell.Abort$ Abort()

AsyncInput

public GraphInterpreterShell.AsyncInput$ AsyncInput()

ResumeShell

public GraphInterpreterShell.ResumeShell$ ResumeShell()

attributes

public Attributes attributes()

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