Package org.apache.pekko.stream.testkit

Class TestSinkStage$

java.lang.Object

org.apache.pekko.stream.testkit.TestSinkStage$

public class TestSinkStage$
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final 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)	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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

MODULE$

public static final TestSinkStage$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Details

TestSinkStage$

public TestSinkStage$()

Method Details

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 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.