Package org.apache.pekko.stream.snapshot

Interface StreamSnapshot

  • public interface StreamSnapshot
    A snapshot of one running stream

    Not for user extension

    • Method Detail

      • activeInterpreters

        scala.collection.immutable.Seq<RunningInterpreter> activeInterpreters()
        Running interpreters

      • newShells

        scala.collection.immutable.Seq<UninitializedInterpreter> newShells()
        Interpreters that has been created but not yet initialized - the stream is not yet running