Package org.apache.pekko.stream.testkit

Class TestSourceStage$

java.lang.Object

org.apache.pekko.stream.testkit.TestSourceStage$

public class TestSourceStage$
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final TestSourceStage$	MODULE$	Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor	Description
TestSourceStage$()

Method Summary

Modifier and Type	Method	Description
<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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

MODULE$

public static final TestSourceStage$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Details

TestSourceStage$

public TestSourceStage$()

Method Details

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.