Package akka.stream.testkit
Class TestSinkStage$
- java.lang.Object
-
- akka.stream.testkit.TestSinkStage$
-
public class TestSinkStage$ extends java.lang.Object
-
-
Field Summary
Fields Modifier and Type Field Description static TestSinkStage$
MODULE$
Static reference to the singleton instance of this Scala object.
-
Constructor Summary
Constructors Constructor Description TestSinkStage$()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description <T,M>
Sink<T,M>apply(GraphStageWithMaterializedValue<SinkShape<T>,M> stageUnderTest, TestProbe probe)
Creates a sink out of thestageUnderTest
that will inform theprobe
of operator events and callbacks by sending it the various messages found underGraphStageMessages
.
-
-
-
Field Detail
-
MODULE$
public static final TestSinkStage$ MODULE$
Static reference to the singleton instance of this Scala object.
-
-
Method Detail
-
apply
public <T,M> Sink<T,M> apply(GraphStageWithMaterializedValue<SinkShape<T>,M> stageUnderTest, TestProbe probe)
Creates a sink out of thestageUnderTest
that will inform theprobe
of operator events and callbacks by sending it the various messages found underGraphStageMessages
.This allows for creation of a "normal" stream ending with the sink while still being able to assert internal events.
-
-