akka.stream.testkit

Class TestSinkStage$

java.lang.Object

akka.stream.testkit.TestSinkStage$

public class TestSinkStage$
extends java.lang.Object

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
TestSinkStage$()

Method Summary

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

Creates a sink 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 ending with the sink while still being able to assert internal events.

Parameters:

stageUnderTest - (undocumented)

probe - (undocumented)

Returns:

(undocumented)