Package org.apache.pekko.stream.testkit.scaladsl

Class TestSource

java.lang.Object

org.apache.pekko.stream.testkit.scaladsl.TestSource

public class TestSource
extends java.lang.Object

Factory methods for test sources.

Constructor Summary

Constructors

Constructor	Description
TestSource()

Method Summary

Modifier and Type	Method	Description
static <T> Source<T,TestPublisher.Probe<T>>	apply(ClassicActorSystemProvider system)	A Source that materializes to a pekko.stream.testkit.TestPublisher.
static <T> Source<T,TestPublisher.Probe<T>>	probe(ActorSystem system)	Deprecated. Use `TestSource.apply` with implicit ClassicActorSystemProvider instead of ActorSystem.

Methods inherited from class java.lang.Object

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

Constructor Detail

TestSource

public TestSource()

Method Detail

probe

public static <T> Source<T,TestPublisher.Probe<T>> probe(ActorSystem system)

Deprecated.

Use `TestSource.apply` with implicit ClassicActorSystemProvider instead of ActorSystem. Since 1.3.0.

A Source that materializes to a pekko.stream.testkit.TestPublisher.

apply

public static <T> Source<T,TestPublisher.Probe<T>> apply(ClassicActorSystemProvider system)

A Source that materializes to a pekko.stream.testkit.TestPublisher.