Class TestSourceStage$


  • public class TestSourceStage$
    extends java.lang.Object
    • Field Detail

      • MODULE$

        public static final TestSourceStage$ MODULE$
        Static reference to the singleton instance of this Scala object.
    • Constructor Detail

      • TestSourceStage$

        public TestSourceStage$()
    • Method Detail

      • apply

        public <T,​M> Source<T,​M> apply​(GraphStageWithMaterializedValue<SourceShape<T>,​M> stageUnderTest,
                                                   TestProbe probe)
        Creates a source out of the stageUnderTest that will inform the probe of operator events and callbacks by sending it the various messages found under GraphStageMessages.

        This allows for creation of a "normal" stream starting with the source while still being able to assert internal events.