Class MaterializerState


  • public class MaterializerState
    extends java.lang.Object
    Debug utility to dump the running streams of a materializers in a structure describing the graph layout and "waits-on" relationships.

    Some of the data extracted may be off unless the stream has settled, for example in when deadlocked, but the structure should be valid regardless. Extracting the information often will have an impact on the performance of the running streams.

    • Constructor Detail

      • MaterializerState

        public MaterializerState()
    • Method Detail

      • streamSnapshots

        public static scala.concurrent.Future<scala.collection.immutable.Seq<StreamSnapshot>> streamSnapshots​(ActorSystem system)
        Dump stream snapshots of all streams of the default system materializer.
      • streamSnapshots

        public static scala.concurrent.Future<scala.collection.immutable.Seq<StreamSnapshot>> streamSnapshots​(Materializer mat)
        Dump stream snapshots of all streams of the given materializer.
      • requestFromSupervisor

        public static scala.concurrent.Future<scala.collection.immutable.Seq<StreamSnapshot>> requestFromSupervisor​(ActorRef supervisor,
                                                                                                                    scala.concurrent.ExecutionContext ec)
        INTERNAL API
      • requestFromChild

        public static scala.concurrent.Future<StreamSnapshot> requestFromChild​(ActorRef child)
        INTERNAL API