Package akka.stream.testkit.javadsl
Class TestSink
- java.lang.Object
-
- akka.stream.testkit.javadsl.TestSink
-
public class TestSink extends java.lang.Object
Java API
-
-
Constructor Summary
Constructors Constructor Description TestSink()
-
Method Summary
All Methods Static Methods Concrete Methods Deprecated Methods Modifier and Type Method Description static <T> Sink<T,TestSubscriber.Probe<T>>
create(ClassicActorSystemProvider system)
A Sink that materialized to aTestSubscriber.Probe
.static <T> Sink<T,TestSubscriber.Probe<T>>
probe(ActorSystem system)
Deprecated.Use `TestSink.create` with ClassicActorSystemProvider instead.
-
-
-
Method Detail
-
probe
public static <T> Sink<T,TestSubscriber.Probe<T>> probe(ActorSystem system)
Deprecated.Use `TestSink.create` with ClassicActorSystemProvider instead. Since 2.7.0.A Sink that materialized to aTestSubscriber.Probe
.
-
create
public static <T> Sink<T,TestSubscriber.Probe<T>> create(ClassicActorSystemProvider system)
A Sink that materialized to aTestSubscriber.Probe
.
-
-