reactor.test.publisher

类 PublisherProbe.DefaultPublisherProbe<T>

java.lang.Object

java.util.concurrent.atomic.AtomicLongArray

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

所有已实现的接口:

java.io.Serializable, PublisherProbe<T>

封闭接口:

PublisherProbe<T>

public static final class PublisherProbe.DefaultPublisherProbe<T>
extends java.util.concurrent.atomic.AtomicLongArray
implements PublisherProbe<T>

另请参阅:

序列化表格

嵌套类概要

从接口继承的嵌套类/接口 reactor.test.publisher.PublisherProbe

PublisherProbe.DefaultPublisherProbe<T>

方法概要

限定符和类型	方法和说明
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()

从类继承的方法 java.util.concurrent.atomic.AtomicLongArray

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

从类继承的方法 java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

从接口继承的方法 reactor.test.publisher.PublisherProbe

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

方法详细资料

mono

public Mono<T> mono()

从接口复制的说明: 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.

指定者:

mono 在接口中 PublisherProbe<T>

返回:

a Mono version of the probe.

flux

public Flux<T> flux()

从接口复制的说明: 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.

指定者:

flux 在接口中 PublisherProbe<T>

返回:

a Flux version of the probe.

wasSubscribed

public boolean wasSubscribed()

指定者:

wasSubscribed 在接口中 PublisherProbe<T>

返回:

true if the probe was subscribed to at least once.

subscribeCount

public long subscribeCount()

指定者:

subscribeCount 在接口中 PublisherProbe<T>

返回:

how many times probe was subscribed

wasCancelled

public boolean wasCancelled()

指定者:

wasCancelled 在接口中 PublisherProbe<T>

返回:

true if the probe was cancelled to at least once.

wasRequested

public boolean wasRequested()

指定者:

wasRequested 在接口中 PublisherProbe<T>

返回:

true if the probe was requested at least once.