Class StreamTestKit
- java.lang.Object
-
- org.apache.pekko.stream.testkit.scaladsl.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 <T> T
assertAllStagesStopped(scala.Function0<T> block, Materializer materializer)
Asserts that after the given code block is ran, no stages are left over that were created by the given materializer.
-
-
-
Method Detail
-
assertAllStagesStopped
public static <T> T assertAllStagesStopped(scala.Function0<T> block, Materializer materializer)
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.
-
-