t

akka.stream.snapshot

RunningInterpreter

sealed trait RunningInterpreter extends InterpreterSnapshot

A stream interpreter that is running/has been started

Annotations
@DoNotInherit()
Source
MaterializerState.scala
Linear Supertypes
InterpreterSnapshot, AnyRef, Any
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. RunningInterpreter
  2. InterpreterSnapshot
  3. AnyRef
  4. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Abstract Value Members

  1. abstract def connections: [ConnectionSnapshot]

    Each connection between logics in the interpreter

  2. abstract def logics: [LogicSnapshot]

    Each of the materialized graph stage logics running inside the interpreter

    Each of the materialized graph stage logics running inside the interpreter

    Definition Classes
    → InterpreterSnapshot
  3. abstract def runningLogicsCount: Int

    Total number of non-stopped logics in the interpreter

  4. abstract def stoppedLogics: [LogicSnapshot]

    All logics that has completed and is no longer executing