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.
-
-
Constructor Summary
Constructors Constructor Description StreamTestKit()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static <T> T
assertAllStagesStopped(scala.Function0<T> block, Materializer materializer)
static void
assertNoChildren(ActorSystem sys, ActorRef supervisor)
INTERNAL APIstatic void
printDebugDump(ActorRef streamSupervisor, scala.concurrent.ExecutionContext ec)
INTERNAL APIstatic java.lang.String
snapshotString(StreamSnapshotImpl snapshot)
INTERNAL APIstatic void
stopAllChildren(ActorSystem sys, ActorRef supervisor)
INTERNAL API
-
-
-
Method Detail
-
assertAllStagesStopped
public static <T> T assertAllStagesStopped(scala.Function0<T> block, Materializer materializer)
-
stopAllChildren
public static void stopAllChildren(ActorSystem sys, ActorRef supervisor)
INTERNAL API
-
assertNoChildren
public static void assertNoChildren(ActorSystem sys, ActorRef supervisor)
INTERNAL API
-
printDebugDump
public static void printDebugDump(ActorRef streamSupervisor, scala.concurrent.ExecutionContext ec)
INTERNAL API
-
snapshotString
public static java.lang.String snapshotString(StreamSnapshotImpl snapshot)
INTERNAL API
-
-