reactor.test.publisher

Class TestPublisher<T>

java.lang.Object

reactor.test.publisher.TestPublisher<T>

All Implemented Interfaces:

Publisher<T>, PublisherProbe<T>

public abstract class TestPublisher<T>
extends Object
implements Publisher<T>, PublisherProbe<T>

A Publisher that you can directly manipulate, triggering onNext, onComplete and onError events, for testing purposes. You can assert the state of the publisher using its assertXXX methods, usually inside a StepVerifier's then callback.

The TestPublisher can also be made more lenient towards the RS spec and allow "spec violations", as enumerated in TestPublisher.Violation. Use the createNoncompliant(Violation, Violation...) factory method to create such a misbehaving publisher.

TestPublisher are generally hot, directly propagating signals to currently subscribed downstreams and only replaying the first termination signal to subsequent subscribers. TestPublishers are also generally not safe to use from multiple parallel threads.

Author:

Simon Basle

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TestPublisher.Violation Possible misbehavior for a TestPublisher.

Nested classes/interfaces inherited from interface reactor.test.publisher.PublisherProbe

PublisherProbe.DefaultPublisherProbe<T>

Constructor Summary

Constructors

Constructor and Description
TestPublisher()

Method Summary

Modifier and Type	Method and Description
abstract TestPublisher<T>	assertCancelled() Asserts that this publisher has had at least one subscriber that has been cancelled.
abstract TestPublisher<T>	assertCancelled(int n) Asserts that this publisher has had at least n subscribers that have been cancelled.
abstract TestPublisher<T>	assertMinRequested(long n) Assert that the current minimum request of all this publisher's subscribers is >= n.
abstract TestPublisher<T>	assertNoRequestOverflow() Asserts that this publisher has had no subscriber with request overflow.
abstract TestPublisher<T>	assertNoSubscribers() Asserts that this publisher has no subscribers.
abstract TestPublisher<T>	assertNotCancelled() Asserts that this publisher has had no cancelled subscribers.
abstract TestPublisher<T>	assertRequestOverflow() Asserts that this publisher has had subscriber that saw request overflow, that is received an onNext event despite having a requested amount of 0 at the time.
abstract TestPublisher<T>	assertSubscribers() Asserts that this publisher has subscribers.
abstract TestPublisher<T>	assertSubscribers(int n) Asserts that this publisher has exactly n subscribers.
abstract TestPublisher<T>	complete() Triggers completion of this publisher.
static <T> TestPublisher<T>	create() Create a standard hot TestPublisher.
static <T> TestPublisher<T>	createCold() Create a cold TestPublisher, which can be subscribed to by multiple subscribers.
static <T> TestPublisher<T>	createNoncompliant(TestPublisher.Violation first, TestPublisher.Violation... rest) Create a noncompliant hot TestPublisher with a given set of reactive streams spec violations that will be overlooked.
TestPublisher<T>	emit(T... values) Combine emitting items and completing this publisher.
abstract TestPublisher<T>	error(Throwable t) Triggers an error signal to the subscribers.
abstract Flux<T>	flux() Convenience method to wrap this TestPublisher to a Flux.
abstract Mono<T>	mono() Convenience method to wrap this TestPublisher to a Mono.
abstract TestPublisher<T>	next(T value) Send 1 onNext signal to the subscribers.
TestPublisher<T>	next(T first, T... rest) Send 1-n onNext signals to the subscribers.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.reactivestreams.Publisher

subscribe

Methods inherited from interface reactor.test.publisher.PublisherProbe

assertWasCancelled, assertWasNotCancelled, assertWasNotRequested, assertWasNotSubscribed, assertWasRequested, assertWasSubscribed, empty, of, wasCancelled, wasRequested, wasSubscribed

Constructor Detail

TestPublisher

public TestPublisher()

Method Detail

create

public static <T> TestPublisher<T> create()

Create a standard hot TestPublisher.

Type Parameters:

T - the type of the publisher

Returns:

the new TestPublisher

createNoncompliant

public static <T> TestPublisher<T> createNoncompliant(TestPublisher.Violation first,
                                                      TestPublisher.Violation... rest)

Create a noncompliant hot TestPublisher with a given set of reactive streams spec violations that will be overlooked.

Type Parameters:

T - the type of the publisher

Parameters:

first - the first allowed TestPublisher.Violation

rest - additional optional violations

Returns:

the new noncompliant TestPublisher

createCold

public static <T> TestPublisher<T> createCold()

Create a cold TestPublisher, which can be subscribed to by multiple subscribers. It caches the next(Object) events and replays them to all subscribers upon subscription.

Note that this type of Publisher isn't

Type Parameters:

T - the type of the publisher

Returns:

the new TestPublisher

flux

public abstract Flux<T> flux()

Convenience method to wrap this TestPublisher to a Flux.

Specified by:

flux in interface PublisherProbe<T>

Returns:

a Flux version of the probe.

mono

public abstract Mono<T> mono()

Convenience method to wrap this TestPublisher to a Mono.

Specified by:

mono in interface PublisherProbe<T>

Returns:

a Mono version of the probe.

assertMinRequested

public abstract TestPublisher<T> assertMinRequested(long n)

Assert that the current minimum request of all this publisher's subscribers is >= n.

Parameters:

n - the expected minimum request

Returns:

this TestPublisher for chaining.

assertSubscribers

public abstract TestPublisher<T> assertSubscribers()

Asserts that this publisher has subscribers.

Returns:

this TestPublisher for chaining.

assertSubscribers

public abstract TestPublisher<T> assertSubscribers(int n)

Asserts that this publisher has exactly n subscribers.

Parameters:

n - the expected number of subscribers

Returns:

this TestPublisher for chaining.

assertNoSubscribers

public abstract TestPublisher<T> assertNoSubscribers()

Asserts that this publisher has no subscribers.

Returns:

this TestPublisher for chaining.

assertCancelled

public abstract TestPublisher<T> assertCancelled()

Asserts that this publisher has had at least one subscriber that has been cancelled.

Returns:

this TestPublisher for chaining.

assertCancelled

public abstract TestPublisher<T> assertCancelled(int n)

Asserts that this publisher has had at least n subscribers that have been cancelled.

Parameters:

n - the expected number of subscribers to have been cancelled.

Returns:

this TestPublisher for chaining.

assertNotCancelled

public abstract TestPublisher<T> assertNotCancelled()

Asserts that this publisher has had no cancelled subscribers.

Returns:

this TestPublisher for chaining.

assertRequestOverflow

public abstract TestPublisher<T> assertRequestOverflow()

Asserts that this publisher has had subscriber that saw request overflow, that is received an onNext event despite having a requested amount of 0 at the time.

Returns:

this TestPublisher for chaining.

assertNoRequestOverflow

public abstract TestPublisher<T> assertNoRequestOverflow()

Asserts that this publisher has had no subscriber with request overflow. Request overflow is receiving an onNext event despite having a requested amount of 0 at that time.

Returns:

this TestPublisher for chaining.

next

public abstract TestPublisher<T> next(@Nullable
                                      T value)

Send 1 onNext signal to the subscribers.

Parameters:

value - the item to emit (can be null if the relevant TestPublisher.Violation is set)

Returns:

this TestPublisher for chaining.

error

public abstract TestPublisher<T> error(Throwable t)

Triggers an error signal to the subscribers.

Parameters:

t - the Throwable to trigger

Returns:

this TestPublisher for chaining.

complete

public abstract TestPublisher<T> complete()

Triggers completion of this publisher.

Returns:

this TestPublisher for chaining.

next

@SafeVarargs
public final TestPublisher<T> next(@Nullable
                                                T first,
                                                T... rest)

Send 1-n onNext signals to the subscribers.

Parameters:

first - the first item to emit

rest - the optional remaining items to emit

Returns:

this TestPublisher for chaining.

See Also:

next

emit

@SafeVarargs
public final TestPublisher<T> emit(T... values)

Combine emitting items and completing this publisher.

Parameters:

values - the values to emit to subscribers

Returns:

this TestPublisher for chaining.

See Also:

next, complete