reactor.test.publisher

Class PublisherProbe.DefaultPublisherProbe<T>

java.lang.Object

java.util.concurrent.atomic.AtomicLongArray

reactor.test.publisher.PublisherProbe.DefaultPublisherProbe<T>

All Implemented Interfaces:

Serializable, PublisherProbe<T>

Enclosing interface:

PublisherProbe<T>

public static final class PublisherProbe.DefaultPublisherProbe<T>
extends AtomicLongArray
implements PublisherProbe<T>

See Also:

Serialized Form

Nested Class Summary

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

PublisherProbe.DefaultPublisherProbe<T>

Method Summary

Modifier and Type	Method and Description
Flux<T>	flux() Return a Flux version of the probe.
Mono<T>	mono() Return a Mono version of the probe.
long	subscribeCount()
boolean	wasCancelled()
boolean	wasRequested()
boolean	wasSubscribed()

Methods inherited from class java.util.concurrent.atomic.AtomicLongArray

accumulateAndGet, addAndGet, compareAndSet, decrementAndGet, get, getAndAccumulate, getAndAdd, getAndDecrement, getAndIncrement, getAndSet, getAndUpdate, incrementAndGet, lazySet, length, set, toString, updateAndGet, weakCompareAndSet

Methods inherited from class java.lang.Object

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

Methods inherited from interface reactor.test.publisher.PublisherProbe

assertWasCancelled, assertWasNotCancelled, assertWasNotRequested, assertWasNotSubscribed, assertWasRequested, assertWasSubscribed, empty, of

Method Detail

mono

public Mono<T> mono()

Description copied from interface: PublisherProbe

Return a Mono version of the probe. Note all calls to mono() and PublisherProbe.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.

Specified by:

mono in interface PublisherProbe<T>

Returns:

a Mono version of the probe.

flux

public Flux<T> flux()

Description copied from interface: PublisherProbe

Return a Flux version of the probe. Note all calls to PublisherProbe.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.

Specified by:

flux in interface PublisherProbe<T>

Returns:

a Flux version of the probe.

wasSubscribed

public boolean wasSubscribed()

Specified by:

wasSubscribed in interface PublisherProbe<T>

Returns:

true if the probe was subscribed to at least once.

subscribeCount

public long subscribeCount()

Specified by:

subscribeCount in interface PublisherProbe<T>

Returns:

how many times probe was subscribed

wasCancelled

public boolean wasCancelled()

Specified by:

wasCancelled in interface PublisherProbe<T>

Returns:

true if the probe was cancelled to at least once.

wasRequested

public boolean wasRequested()

Specified by:

wasRequested in interface PublisherProbe<T>

Returns:

true if the probe was requested at least once.