Package org.apache.pekko.stream.snapshot

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.

    • Field Summary

      Fields 
      Modifier and Type Field Description
      static MaterializerState$ MODULE$
      Static reference to the singleton instance of this Scala object.

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      scala.concurrent.Future<scala.collection.immutable.Seq<StreamSnapshot>> streamSnapshots​(ActorSystem system)
      Dump stream snapshots of all streams of the default system materializer.
      scala.concurrent.Future<scala.collection.immutable.Seq<StreamSnapshot>> streamSnapshots​(Materializer mat)
      Dump stream snapshots of all streams of the given materializer.

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Field Detail

      • MODULE$

        public static final MaterializerState$ MODULE$
        Static reference to the singleton instance of this Scala object.

    • Constructor Detail

      • MaterializerState$

        public MaterializerState$()

    • Method Detail

      • streamSnapshots

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

      • streamSnapshots

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