Class StreamTestKit$


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

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

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

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

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

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