Class TestSource
java.lang.Object
org.apache.pekko.stream.testkit.javadsl.TestSource
Java API
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionstatic <T> Source<T,TestPublisher.Probe<T>> create(ClassicActorSystemProvider system) A Source that materializes to apekko.stream.testkit.TestPublisher.Probe.static <T> Source<T,TestPublisher.Probe<T>> probe(ActorSystem system) A Source that materializes to apekko.stream.testkit.TestPublisher.Probe.
-
Constructor Details
-
TestSource
public TestSource()
-
-
Method Details
-
probe
A Source that materializes to apekko.stream.testkit.TestPublisher.Probe. -
create
A Source that materializes to apekko.stream.testkit.TestPublisher.Probe.
-