o

akka.stream.snapshot

MaterializerState

object MaterializerState

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.

Source
MaterializerState.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. MaterializerState
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Value Members

  1. def streamSnapshots(mat: Materializer): Future[Seq[StreamSnapshot]]

    Dump stream snapshots of all streams of the given materializer.

    Dump stream snapshots of all streams of the given materializer.

    Annotations
    @ApiMayChange()