Package org.apache.pekko.stream.testkit.javadsl

Class StreamTestKit$

java.lang.Object

org.apache.pekko.stream.testkit.javadsl.StreamTestKit$

public class StreamTestKit$
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final StreamTestKit$	MODULE$	Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor	Description
StreamTestKit$()

Method Summary

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.
void	assertAllStagesStopped(Materializer mat, Duration overrideTimeout)	Assert that there are no stages running under a given materializer.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

MODULE$

public static final StreamTestKit$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Details

StreamTestKit$

public StreamTestKit$()

Method Details

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(Materializer mat,
 Duration overrideTimeout)

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 with an overridden duration that ignores stream.testkit.all-stages-stopped-timeout.

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.