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

Class StreamTestKit$

java.lang.Object
org.apache.pekko.stream.testkit.scaladsl.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
    <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.
    <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

  • 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 <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 <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.