TestSinkStage

java.lang.Object
- akka.stream.stage.GraphStageWithMaterializedValue<SinkShape<T>,M>
- - akka.stream.testkit.TestSinkStage<T,M>

All Implemented Interfaces:: Graph<SinkShape<T>,M>

public class TestSinkStage<T,M>
extends GraphStageWithMaterializedValue<SinkShape<T>,M>

Nested Class Summary
- Nested classes/interfaces inherited from interface akka.stream.Graph
  Graph.GraphMapMatVal<S extends Shape,M>

Constructor Summary

Constructors
Constructor Description

TestSinkStage(GraphStageWithMaterializedValue<SinkShape<T>,M> stageUnderTest, TestProbe probe)

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`static <T,M> Sink<T,M>`	`apply(GraphStageWithMaterializedValue<SinkShape<T>,M> stageUnderTest, TestProbe probe)`	Creates a sink out of the `stageUnderTest` that will inform the `probe` of operator events and callbacks by sending it the various messages found under `GraphStageMessages`.
`scala.Tuple2<GraphStageLogic,M>`	`createLogicAndMaterializedValue(Attributes inheritedAttributes)`
`Inlet<T>`	`in()`
`SinkShape<T>`	`shape()`	The shape of a graph is all that is externally visible: its inlets and outlets.

Methods inherited from class akka.stream.stage.GraphStageWithMaterializedValue
createLogicAndMaterializedValue, initialAttributes, traversalBuilder, withAttributes

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface akka.stream.Graph
addAttributes, async, async, async, named

- Constructor Detail
  - TestSinkStage
```
public TestSinkStage(GraphStageWithMaterializedValue<SinkShape<T>,M> stageUnderTest,
                     TestProbe probe)
```
- Method Detail
  - apply
```
public static <T,M> Sink<T,M> apply(GraphStageWithMaterializedValue<SinkShape<T>,M> stageUnderTest,
                                                TestProbe probe)
```
    Creates a sink 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 ending with the sink while still being able to assert internal events.
  - in
```
public Inlet<T> in()
```
  - shape
```
public SinkShape<T> shape()
```
    Description copied from interface: Graph
    
    The shape of a graph is all that is externally visible: its inlets and outlets.
  - createLogicAndMaterializedValue
```
public scala.Tuple2<GraphStageLogic,M> createLogicAndMaterializedValue(Attributes inheritedAttributes)
```
    Specified by:
    
    createLogicAndMaterializedValue in class GraphStageWithMaterializedValue<SinkShape<T>,M>