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

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

      • Methods inherited from class java.lang.Object

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

    • Field Detail

      • MODULE$

        public static final StreamTestKit$ MODULE$
        Static reference to the singleton instance of this Scala object.

    • Constructor Detail

      • StreamTestKit$

        public StreamTestKit$()

    • Method Detail

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

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