akka.stream.testkit

Class TestSourceStage$

java.lang.Object

akka.stream.testkit.TestSourceStage$

public class TestSourceStage$
extends java.lang.Object

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
TestSourceStage$()

Method Summary

Modifier and Type	Method and 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 graph stage 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 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)

Creates a source out of the 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 starting with the source while still being able to assert internal events.

Parameters:

stageUnderTest - (undocumented)

probe - (undocumented)

Returns:

(undocumented)