Package akka.stream.testkit.scaladsl

Class StreamTestKit

  • public class StreamTestKit
extends java.lang.Object

    • Constructor Summary

      Constructors 
      Constructor Description
      StreamTestKit()  

    • Method Summary

      All Methods Static Methods Concrete Methods 
      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.

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • StreamTestKit

        public StreamTestKit()

    • Method Detail

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

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