TestSourceStage$

java.lang.Object
- akka.stream.testkit.TestSourceStage$

public class TestSourceStage$
extends java.lang.Object

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

All Methods Instance Methods Concrete Methods
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 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 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.