Package akka.stream.testkit
Class TestSubscriber
- java.lang.Object
-
- akka.stream.testkit.TestSubscriber
-
public class TestSubscriber extends java.lang.Object
Probe that implementsSubscriber
interface.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
TestSubscriber.ManualProbe<I>
Expect and return aSubscription
.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>
static interface
TestSubscriber.SubscriberEvent
-
Constructor Summary
Constructors Constructor Description TestSubscriber()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static <T> TestSubscriber.ManualProbe<T>
manualProbe(ActorSystem system)
static <T> TestSubscriber.Probe<T>
probe(ActorSystem system)
-
-
-
Method Detail
-
manualProbe
public static <T> TestSubscriber.ManualProbe<T> manualProbe(ActorSystem system)
-
probe
public static <T> TestSubscriber.Probe<T> probe(ActorSystem system)
-
-