Class TestSource$
- java.lang.Object
-
- org.apache.pekko.stream.testkit.scaladsl.TestSource$
-
public class TestSource$ extends java.lang.Object
Factory methods for test sources.
-
-
Field Summary
Fields Modifier and Type Field Description static TestSource$
MODULE$
Static reference to the singleton instance of this Scala object.
-
Constructor Summary
Constructors Constructor Description TestSource$()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description <T> Source<T,TestPublisher.Probe<T>>
apply(ClassicActorSystemProvider system)
A Source that materializes to apekko.stream.testkit.TestPublisher.Probe
.<T> Source<T,TestPublisher.Probe<T>>
probe(ActorSystem system)
A Source that materializes to apekko.stream.testkit.TestPublisher.Probe
.
-
-
-
Field Detail
-
MODULE$
public static final TestSource$ MODULE$
Static reference to the singleton instance of this Scala object.
-
-
Method Detail
-
probe
public <T> Source<T,TestPublisher.Probe<T>> probe(ActorSystem system)
A Source that materializes to apekko.stream.testkit.TestPublisher.Probe
.
-
apply
public <T> Source<T,TestPublisher.Probe<T>> apply(ClassicActorSystemProvider system)
A Source that materializes to apekko.stream.testkit.TestPublisher.Probe
.
-
-