public class TestSinkStage$
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static TestSinkStage$ |
MODULE$
Static reference to the singleton instance of this Scala object.
|
Constructor and Description |
---|
TestSinkStage$() |
Modifier and Type | Method and Description |
---|---|
<T,M> Sink<T,M> |
apply(GraphStageWithMaterializedValue<SinkShape<T>,M> stageUnderTest,
TestProbe probe)
Creates a sink out of the
stageUnderTest that will inform the probe
of graph stage events and callbacks by sending it the various messages found under
GraphStageMessages . |
public static final TestSinkStage$ MODULE$
public <T,M> Sink<T,M> apply(GraphStageWithMaterializedValue<SinkShape<T>,M> stageUnderTest, TestProbe probe)
stageUnderTest
that will inform the probe
of graph stage 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.
stageUnderTest
- (undocumented)probe
- (undocumented)