StreamTestKit

java.lang.Object

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

public class StreamTestKit extends Object

Constructor Summary

Constructors

Constructor

Description

StreamTestKit()
Method Summary

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.

static 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

Constructor Details
- StreamTestKit
  
  public StreamTestKit()
Method Details
- 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(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 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.