Package akka.stream.testkit

Class TestSinkStage$

java.lang.Object

akka.stream.testkit.TestSinkStage$

public class TestSinkStage$
extends java.lang.Object

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.

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
TestSinkStage$()

Method Summary

Modifier and Type	Method	Description
<T,M> Sink<T,M>	apply(GraphStageWithMaterializedValue<SinkShape<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 TestSinkStage$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

TestSinkStage$

public TestSinkStage$()

Method Detail

apply

public <T,M> Sink<T,M> apply(GraphStageWithMaterializedValue<SinkShape<T>,M> stageUnderTest,
                                         TestProbe probe)