Package org.apache.pekko.stream.snapshot

Interface StreamSnapshot

public interface StreamSnapshot
A snapshot of one running stream

Not for user extension

  • Method Summary

    Modifier and Type
    Method
    Description
    scala.collection.immutable.Seq<RunningInterpreter>
    activeInterpreters()
    Running interpreters
    scala.collection.immutable.Seq<UninitializedInterpreter>
    newShells()
    Interpreters that has been created but not yet initialized - the stream is not yet running

  • Method Details

    • 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