public class TestPublisher
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static class |
TestPublisher.CancelSubscription |
static class |
TestPublisher.CancelSubscription$ |
static class |
TestPublisher.ManualProbe<I>
Implementation of
Publisher that allows various assertions. |
static class |
TestPublisher.ManualProbe$ |
static class |
TestPublisher.Probe<T>
Single subscription and demand tracking for
TestPublisher.ManualProbe . |
static interface |
TestPublisher.PublisherEvent |
static class |
TestPublisher.RequestMore |
static class |
TestPublisher.RequestMore$ |
static class |
TestPublisher.Subscribe |
static class |
TestPublisher.Subscribe$ |
Constructor and Description |
---|
TestPublisher() |
Modifier and Type | Method and 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(java.lang.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(java.lang.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> TestPublisher.Probe<T> |
probe(long initialPendingRequests,
ActorSystem system)
Probe that implements
Publisher interface and tracks demand. |
public static <T> org.reactivestreams.Publisher<T> empty()
public static <T> org.reactivestreams.Publisher<T> lazyEmpty()
public static <T> org.reactivestreams.Publisher<T> error(java.lang.Throwable cause)
cause
- (undocumented)public static <T> org.reactivestreams.Publisher<T> lazyError(java.lang.Throwable cause)
cause
- (undocumented)public static <T> TestPublisher.ManualProbe<T> manualProbe(boolean autoOnSubscribe, ActorSystem system)
Publisher
interface.autoOnSubscribe
- (undocumented)system
- (undocumented)public static <T> TestPublisher.Probe<T> probe(long initialPendingRequests, ActorSystem system)
Publisher
interface and tracks demand.initialPendingRequests
- (undocumented)system
- (undocumented)