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 interpreterscala.collection.immutable.Seq<LogicSnapshot>logics()Each of the materialized graph stage logics running inside the interpreterintrunningLogicsCount()Total number of non-stopped logics in the interpreterscala.collection.immutable.Seq<LogicSnapshot>stoppedLogics()All logics that has completed and is no longer executing 
 - 
 
- 
- 
Method Detail
- 
connections
scala.collection.immutable.Seq<ConnectionSnapshot> connections()
Each connection between logics in the interpreter 
- 
logics
scala.collection.immutable.Seq<LogicSnapshot> logics()
Each of the materialized graph stage logics running inside the interpreter- 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 has completed and is no longer executing 
 - 
 
 -