Package akka.stream.testkit.scaladsl
Class TestSource
- java.lang.Object
-
- akka.stream.testkit.scaladsl.TestSource
-
public class TestSource extends java.lang.Object
Factory methods for test sources.
-
-
Constructor Summary
Constructors Constructor Description TestSource()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static <T> Source<T,TestPublisher.Probe<T>>
apply(ClassicActorSystemProvider system)
A Source that materializes to aTestPublisher.Probe
.static <T> Source<T,TestPublisher.Probe<T>>
probe(ActorSystem system)
A Source that materializes to aTestPublisher.Probe
.
-
-
-
Method Detail
-
probe
public static <T> Source<T,TestPublisher.Probe<T>> probe(ActorSystem system)
A Source that materializes to aTestPublisher.Probe
.
-
apply
public static <T> Source<T,TestPublisher.Probe<T>> apply(ClassicActorSystemProvider system)
A Source that materializes to aTestPublisher.Probe
.
-
-