Package org.apache.pekko.stream.testkit

Class TestSubscriber

java.lang.Object

org.apache.pekko.stream.testkit.TestSubscriber

public class TestSubscriber
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TestSubscriber.ManualProbe<I>	Implementation of Subscriber that allows various assertions.
static class	TestSubscriber.ManualProbe$
static class	TestSubscriber.OnComplete$
static final class	TestSubscriber.OnError
static class	TestSubscriber.OnError$
static final class	TestSubscriber.OnNext<I>
static class	TestSubscriber.OnNext$
static final class	TestSubscriber.OnSubscribe
static class	TestSubscriber.OnSubscribe$
static class	TestSubscriber.Probe<T>	Single subscription tracking for TestSubscriber.ManualProbe.
static class	TestSubscriber.Probe$
static interface	TestSubscriber.SubscriberEvent

Constructor Summary

Constructors

Constructor	Description
TestSubscriber()

Method Summary

Modifier and Type	Method	Description
static <T> TestSubscriber.ManualProbe<T>	manualProbe(ActorSystem system)	Probe that implements Subscriber interface.
static <T> TestSubscriber.Probe<T>	probe(ActorSystem system)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

TestSubscriber

public TestSubscriber()

Method Details

manualProbe

public static <T> TestSubscriber.ManualProbe<T> manualProbe(ActorSystem system)

Probe that implements Subscriber interface.

probe

public static <T> TestSubscriber.Probe<T> probe(ActorSystem system)