Package akka.stream.snapshot
Interface RunningInterpreter
-
- All Superinterfaces:
InterpreterSnapshot
public interface RunningInterpreter extends InterpreterSnapshot
A stream interpreter that is running/has been started
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description scala.collection.immutable.Seq<ConnectionSnapshot>connections()Each connection between logics in the interpreter that is not closed on both ends yetscala.collection.immutable.Seq<LogicSnapshot>logics()Each of the materialized graph stage logics running inside the interpreter.intrunningLogicsCount()Total number of non-stopped logics in the interpreterscala.collection.immutable.Seq<LogicSnapshot>stoppedLogics()All logics that have completed and are no longer executing.
-
-
-
Method Detail
-
connections
scala.collection.immutable.Seq<ConnectionSnapshot> connections()
Each connection between logics in the interpreter that is not closed on both ends yet
-
logics
scala.collection.immutable.Seq<LogicSnapshot> logics()
Each of the materialized graph stage logics running inside the interpreter. Logics that already stopped are released by the interpreter and show up as a placeholder without name or attributes.- Specified by:
logicsin interfaceInterpreterSnapshot
-
runningLogicsCount
int runningLogicsCount()
Total number of non-stopped logics in the interpreter
-
stoppedLogics
scala.collection.immutable.Seq<LogicSnapshot> stoppedLogics()
All logics that have completed and are no longer executing. Released by the interpreter, so they carry neither name nor attributes, seelogics()
-
-