Package akka.stream.snapshot

Class MaterializerState

java.lang.Object

akka.stream.snapshot.MaterializerState

public class MaterializerState
extends java.lang.Object

Dump stream snapshots of all streams of the given materializer.

Constructor Summary

Constructors

Constructor	Description
MaterializerState()

Method Summary

Modifier and Type	Method	Description
static scala.concurrent.Future<StreamSnapshot>	requestFromChild(ActorRef child)	INTERNAL API
static scala.concurrent.Future<scala.collection.immutable.Seq<StreamSnapshot>>	requestFromSupervisor(ActorRef supervisor, scala.concurrent.ExecutionContext ec)	INTERNAL API
static scala.concurrent.Future<scala.collection.immutable.Seq<StreamSnapshot>>	streamSnapshots(Materializer mat)

Methods inherited from class java.lang.Object

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

Constructor Detail

MaterializerState

public MaterializerState()

Method Detail

streamSnapshots

public static scala.concurrent.Future<scala.collection.immutable.Seq<StreamSnapshot>> streamSnapshots(Materializer mat)

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