Package org.apache.pekko.stream.snapshot

Class MaterializerState$

java.lang.Object

org.apache.pekko.stream.snapshot.MaterializerState$

public class MaterializerState$
extends 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 final MaterializerState$	MODULE$	Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor	Description
MaterializerState$()

Method Summary

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 Details

MODULE$

public static final MaterializerState$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Details

MaterializerState$

public MaterializerState$()

Method Details

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.