Package akka.stream.testkit

Class TestSourceStage$

java.lang.Object

akka.stream.testkit.TestSourceStage$

public class TestSourceStage$
extends java.lang.Object

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.

Field Summary

Fields

Modifier and Type	Field	Description
static 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)

Methods inherited from class java.lang.Object

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

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)