Class TestSinkStage<T,​M>

  • All Implemented Interfaces:
    Graph<SinkShape<T>,​M>

    public class TestSinkStage<T,​M>
    extends GraphStageWithMaterializedValue<SinkShape<T>,​M>
    Creates a sink 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 ending with the sink while still being able to assert internal events.