public class TestSink
extends java.lang.Object
Constructor and Description |
---|
TestSink() |
Modifier and Type | Method and Description |
---|---|
static <T> Sink<T,TestSubscriber.Probe<T>> |
probe(ActorSystem system)
A Sink that materialized to a
TestSubscriber.Probe . |
public static <T> Sink<T,TestSubscriber.Probe<T>> probe(ActorSystem system)
TestSubscriber.Probe
.system
- (undocumented)