public class TestSource
extends java.lang.Object
Constructor and Description |
---|
TestSource() |
Modifier and Type | Method and Description |
---|---|
static <T> Source<T,TestPublisher.Probe<T>> |
probe(ActorSystem system)
A Source that materializes to a
TestPublisher.Probe . |
public static <T> Source<T,TestPublisher.Probe<T>> probe(ActorSystem system)
TestPublisher.Probe
.system
- (undocumented)