Class StreamTestKit$
- java.lang.Object
-
- org.apache.pekko.stream.testkit.javadsl.StreamTestKit$
-
public class StreamTestKit$ extends java.lang.Object
-
-
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 void
assertAllStagesStopped(ClassicActorSystemProvider system)
Assert that there are no stages running under a given system's materializer.void
assertAllStagesStopped(Materializer mat)
Assert that there are no stages running under a given materializer.
-
-
-
Field Detail
-
MODULE$
public static final StreamTestKit$ MODULE$
Static reference to the singleton instance of this Scala object.
-
-
Method Detail
-
assertAllStagesStopped
public 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 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.
-
-