Package org.apache.pekko.stream.testkit.scaladsl

Class StreamTestKit

java.lang.Object
org.apache.pekko.stream.testkit.scaladsl.StreamTestKit
public class StreamTestKit extends Object

  • Constructor Summary

    Constructors
    Constructor
    Description
    StreamTestKit()
     

  • Method Summary

    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 with an overridden duration that ignores stream.testkit.all-stages-stopped-timeout.
    static <T> T
    assertAllStagesStopped(scala.Function0<T> block, scala.concurrent.duration.FiniteDuration overrideTimeout, Materializer materializer)
    Asserts that after the given code block is ran, no stages are left over that were created by the 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 <T> T assertAllStagesStopped(scala.Function0<T> block, scala.concurrent.duration.FiniteDuration overrideTimeout, 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.

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

      This assertion is useful to check that all of the stages have terminated successfully.