Package org.apache.pekko.stream.testkit

Class TestPublisher

java.lang.Object

org.apache.pekko.stream.testkit.TestPublisher

public class TestPublisher
extends Object

Provides factory methods for various Publishers.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	TestPublisher.CancelSubscription
static class	TestPublisher.CancelSubscription$
static class	TestPublisher.ManualProbe<I>
static class	TestPublisher.ManualProbe$
static class	TestPublisher.Probe<T>	Single subscription and demand tracking for TestPublisher.ManualProbe.
static class	TestPublisher.Probe$
static interface	TestPublisher.PublisherEvent
static final class	TestPublisher.RequestMore
static class	TestPublisher.RequestMore$
static final class	TestPublisher.Subscribe
static class	TestPublisher.Subscribe$
static class	TestPublisher.SubscriptionDone$

Constructor Summary

Constructors

Constructor	Description
TestPublisher()

Method Summary

Modifier and Type	Method	Description
static <T> org.reactivestreams.Publisher<T>	empty()	Publisher that signals complete to subscribers, after handing a void subscription.
static <T> org.reactivestreams.Publisher<T>	error(Throwable cause)	Publisher that signals error to subscribers immediately after handing out subscription.
static <T> org.reactivestreams.Publisher<T>	lazyEmpty()	Publisher that subscribes the subscriber and completes after the first request.
static <T> org.reactivestreams.Publisher<T>	lazyError(Throwable cause)	Publisher that subscribes the subscriber and signals error after the first request.
static <T> TestPublisher.ManualProbe<T>	manualProbe(boolean autoOnSubscribe, ActorSystem system)	Probe that implements Publisher interface.
static <T> boolean	manualProbe$default$1()
static <T> TestPublisher.Probe<T>	probe(long initialPendingRequests, ActorSystem system)	Probe that implements Publisher interface and tracks demand.
static <T> long	probe$default$1()

Methods inherited from class java.lang.Object

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

Constructor Details

TestPublisher

public TestPublisher()

Method Details

empty

public static <T> org.reactivestreams.Publisher<T> empty()

Publisher that signals complete to subscribers, after handing a void subscription.

lazyEmpty

public static <T> org.reactivestreams.Publisher<T> lazyEmpty()

Publisher that subscribes the subscriber and completes after the first request.

error

public static <T> org.reactivestreams.Publisher<T> error(Throwable cause)

Publisher that signals error to subscribers immediately after handing out subscription.

lazyError

public static <T> org.reactivestreams.Publisher<T> lazyError(Throwable cause)

Publisher that subscribes the subscriber and signals error after the first request.

manualProbe

public static <T> TestPublisher.ManualProbe<T> manualProbe(boolean autoOnSubscribe,
 ActorSystem system)

Probe that implements Publisher interface.

manualProbe$default$1

public static <T> boolean manualProbe$default$1()

probe

public static <T> TestPublisher.Probe<T> probe(long initialPendingRequests,
 ActorSystem system)

Probe that implements Publisher interface and tracks demand.

probe$default$1

public static <T> long probe$default$1()