Class StreamTestKit
- java.lang.Object
-
- org.apache.pekko.stream.testkit.javadsl.StreamTestKit
-
public class StreamTestKit extends java.lang.Object
-
-
Constructor Summary
Constructors Constructor Description StreamTestKit()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static void
assertAllStagesStopped(ClassicActorSystemProvider system)
Assert that there are no stages running under a given system's materializer.static void
assertAllStagesStopped(Materializer mat)
Assert that there are no stages running under a given materializer.
-
-
-
Method Detail
-
assertAllStagesStopped
public static void assertAllStagesStopped(Materializer mat)
Assert that there are no stages running under a given materializer. Usually this assertion is run after a test-case to check that all of the stages have terminated successfully.
-
assertAllStagesStopped
public static void assertAllStagesStopped(ClassicActorSystemProvider system)
Assert that there are no stages running under a given system's materializer. Usually this assertion is run after a test-case to check that all of the stages have terminated successfully.
-
-