Class StreamTestKit


  • public class StreamTestKit
    extends java.lang.Object
    • 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.

        Parameters:
        block - (undocumented)
        materializer - (undocumented)
        Returns:
        (undocumented)
      • stopAllChildren

        public static void stopAllChildren​(ActorSystem sys,
                                           ActorRef supervisor)
        INTERNAL API
      • assertNoChildren

        public static void assertNoChildren​(ActorSystem sys,
                                            ActorRef supervisor)
        INTERNAL API
      • printDebugDump

        public static void printDebugDump​(ActorRef streamSupervisor,
                                          scala.concurrent.ExecutionContext ec)
        INTERNAL API
      • snapshotString

        public static java.lang.String snapshotString​(StreamSnapshotImpl snapshot)
        INTERNAL API