Package org.apache.pekko.stream.testkit
Class TestSubscriber
java.lang.Object
org.apache.pekko.stream.testkit.TestSubscriber
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic classImplementation ofSubscriberthat allows various assertions.static classstatic classstatic final classstatic classstatic final classstatic classstatic final classstatic classstatic classSingle subscription tracking forTestSubscriber.ManualProbe.static classstatic interface -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionstatic <T> TestSubscriber.ManualProbe<T>manualProbe(ActorSystem system) Probe that implementsSubscriberinterface.static <T> TestSubscriber.Probe<T>probe(ActorSystem system)
-
Constructor Details
-
TestSubscriber
public TestSubscriber()
-
-
Method Details
-
manualProbe
Probe that implementsSubscriberinterface. -
probe
-