reactor.test.publisher

接口 PublisherProbe<T>

所有已知实现类:

PublisherProbe.DefaultPublisherProbe, TestPublisher

public interface PublisherProbe<T>

A test utility that allow to easily obtain an instrumented Publisher (Mono or Flux) for tests involving control flow. For instance, you might have a Mono.switchIfEmpty(Mono) and you want to make sure that your code branched into the "if empty" case. The contract of this interface does not cover what signals the Publisher emits, although factory methods of(Publisher) and empty() produce probes that do emit signals like a common sequence.

The PublisherProbe acts as a probe capturing subscription, cancellation and request events. Later, it can be used post completion to check if that particular probe was hit.

Even though TestPublisher implements PublisherProbe, prefer creating probes through the static empty() and of(Publisher) methods. This is because the TestPublisher exposes assertions from PublisherProbe but still requires you to 1) use the TestPublisher emit methods and 2) use the TestPublisher.Violation.CLEANUP_ON_TERMINATE in order for these assertions to be usable post-completion...

作者:

Simon Baslé

嵌套类概要

嵌套类

限定符和类型	接口和说明
static class	PublisherProbe.DefaultPublisherProbe<T>

方法概要

限定符和类型	方法和说明
default void	assertWasCancelled() Check that the probe was cancelled at least once, or throw an AssertionError.
default void	assertWasNotCancelled() Check that the probe was never cancelled, or throw an AssertionError.
default void	assertWasNotRequested() Check that the probe was never requested, or throw an AssertionError.
default void	assertWasNotSubscribed() Check that the probe was never subscribed to, or throw an AssertionError.
default void	assertWasRequested() Check that the probe was requested at least once, or throw an AssertionError.
default void	assertWasSubscribed() Check that the probe was subscribed to at least once, or throw an AssertionError.
static <T> PublisherProbe<T>	empty() Create a PublisherProbe of which flux() and mono() versions will simply complete, capturing subscription, cancellation and request events around them.
Flux<T>	flux() Return a Flux version of the probe.
Mono<T>	mono() Return a Mono version of the probe.
static <T> PublisherProbe<T>	of(org.reactivestreams.Publisher<? extends T> source) Create a PublisherProbe out of a Publisher, ensuring that its flux() and mono() versions will propagate signals from this publisher while capturing subscription, cancellation and request events around it.
long	subscribeCount()
boolean	wasCancelled()
boolean	wasRequested()
boolean	wasSubscribed()

方法详细资料

assertWasNotSubscribed

default void assertWasNotSubscribed()

Check that the probe was never subscribed to, or throw an AssertionError.

assertWasSubscribed

default void assertWasSubscribed()

Check that the probe was subscribed to at least once, or throw an AssertionError.

assertWasNotCancelled

default void assertWasNotCancelled()

Check that the probe was never cancelled, or throw an AssertionError.

assertWasCancelled

default void assertWasCancelled()

Check that the probe was cancelled at least once, or throw an AssertionError.

assertWasNotRequested

default void assertWasNotRequested()

Check that the probe was never requested, or throw an AssertionError.

assertWasRequested

default void assertWasRequested()

Check that the probe was requested at least once, or throw an AssertionError.

mono

Mono<T> mono()

Return a Mono version of the probe. Note all calls to mono() and flux() are backed by the same PublisherProbe and as such influence a single state.

If the probe was created out of a Publisher, the Flux will forward the signals from this publisher (up to one Subscriber.onNext(Object) though). Otherwise it will simply complete.

返回:

a Mono version of the probe.

flux

Flux<T> flux()

Return a Flux version of the probe. Note all calls to mono() and flux() are backed by the same PublisherProbe and as such influence a single state.

If the probe was created out of a Publisher, the Flux will forward the signals from this publisher Otherwise it will simply complete.

返回:

a Flux version of the probe.

wasSubscribed

boolean wasSubscribed()

返回:

true if the probe was subscribed to at least once.

subscribeCount

long subscribeCount()

返回:

how many times probe was subscribed

wasCancelled

boolean wasCancelled()

返回:

true if the probe was cancelled to at least once.

wasRequested

boolean wasRequested()

返回:

true if the probe was requested at least once.

of

static <T> PublisherProbe<T> of(org.reactivestreams.Publisher<? extends T> source)

Create a PublisherProbe out of a Publisher, ensuring that its flux() and mono() versions will propagate signals from this publisher while capturing subscription, cancellation and request events around it.

类型参数:

T - the type of the source publisher.

参数:

source - the source publisher to mimic and probe.

返回:

a probe that mimics the publisher.

empty

static <T> PublisherProbe<T> empty()

Create a PublisherProbe of which flux() and mono() versions will simply complete, capturing subscription, cancellation and request events around them.

类型参数:

T - the type of the empty probe.

返回:

a probe that mimics an empty publisher.