public class TestSubscriber
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static class |
TestSubscriber.ManualProbe<I>
Implementation of
Subscriber that allows various assertions. |
static class |
TestSubscriber.OnComplete$ |
static class |
TestSubscriber.OnError |
static class |
TestSubscriber.OnError$ |
static class |
TestSubscriber.OnNext<I> |
static class |
TestSubscriber.OnNext$ |
static class |
TestSubscriber.OnSubscribe |
static class |
TestSubscriber.OnSubscribe$ |
static class |
TestSubscriber.Probe<T>
Single subscription tracking for
TestSubscriber.ManualProbe . |
static interface |
TestSubscriber.SubscriberEvent |
Constructor and Description |
---|
TestSubscriber() |
Modifier and Type | Method and Description |
---|---|
static <T> TestSubscriber.ManualProbe<T> |
manualProbe(ActorSystem system)
Probe that implements
Subscriber interface. |
static <T> TestSubscriber.Probe<T> |
probe(ActorSystem system) |
public static <T> TestSubscriber.ManualProbe<T> manualProbe(ActorSystem system)
Subscriber
interface.system
- (undocumented)public static <T> TestSubscriber.Probe<T> probe(ActorSystem system)