Package akka.stream.testkit.scaladsl
Class StreamTestKit$
- java.lang.Object
-
- akka.stream.testkit.scaladsl.StreamTestKit$
-
public class StreamTestKit$ extends java.lang.Object
Asserts that after the given code block is ran, no stages are left over that were created by the given materializer.This assertion is useful to check that all of the stages have terminated successfully.
-
-
Field Summary
Fields Modifier and Type Field Description static StreamTestKit$
MODULE$
Static reference to the singleton instance of this Scala object.
-
Constructor Summary
Constructors Constructor Description StreamTestKit$()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description <T> T
assertAllStagesStopped(scala.Function0<T> block, Materializer materializer)
void
assertNoChildren(ActorSystem sys, ActorRef supervisor)
INTERNAL APIvoid
printDebugDump(ActorRef streamSupervisor, scala.concurrent.ExecutionContext ec)
INTERNAL APIjava.lang.String
snapshotString(StreamSnapshotImpl snapshot)
INTERNAL APIvoid
stopAllChildren(ActorSystem sys, ActorRef supervisor)
INTERNAL API
-
-
-
Field Detail
-
MODULE$
public static final StreamTestKit$ MODULE$
Static reference to the singleton instance of this Scala object.
-
-
Method Detail
-
assertAllStagesStopped
public <T> T assertAllStagesStopped(scala.Function0<T> block, Materializer materializer)
-
stopAllChildren
public void stopAllChildren(ActorSystem sys, ActorRef supervisor)
INTERNAL API
-
assertNoChildren
public void assertNoChildren(ActorSystem sys, ActorRef supervisor)
INTERNAL API
-
printDebugDump
public void printDebugDump(ActorRef streamSupervisor, scala.concurrent.ExecutionContext ec)
INTERNAL API
-
snapshotString
public java.lang.String snapshotString(StreamSnapshotImpl snapshot)
INTERNAL API
-
-