程序包 | 说明 |
---|---|
reactor.test |
Main test components supporting the testing and assertion of publishers.
|
限定符和类型 | 方法和说明 |
---|---|
static <T> StepVerifier.FirstStep<T> |
StepVerifier.create(org.reactivestreams.Publisher<? extends T> publisher)
Prepare a new
StepVerifier in an uncontrolled environment:
StepVerifier.Step.thenAwait() will block in real time. |
static <T> StepVerifier.FirstStep<T> |
StepVerifier.create(org.reactivestreams.Publisher<? extends T> publisher,
long n)
Prepare a new
StepVerifier in an uncontrolled environment:
StepVerifier.Step.thenAwait() will block in real time. |
static <T> StepVerifier.FirstStep<T> |
StepVerifier.create(org.reactivestreams.Publisher<? extends T> publisher,
StepVerifierOptions options)
Prepare a new
StepVerifier in an uncontrolled environment:
StepVerifier.Step.thenAwait() will block in real time. |
default StepVerifier.FirstStep<T> |
StepVerifier.FirstStep.enableConditionalSupport(java.util.function.Predicate<? super T> tryOnNextPredicate)
Provide a
Predicate that will turn this StepVerifier's subscribers into
Fuseable.ConditionalSubscriber and drive the Fuseable.ConditionalSubscriber.tryOnNext(Object)
behavior of these subscribers. |
static <T> StepVerifier.FirstStep<T> |
StepVerifier.withVirtualTime(java.util.function.Supplier<? extends org.reactivestreams.Publisher<? extends T>> scenarioSupplier)
Prepare a new
StepVerifier in a controlled environment using
VirtualTimeScheduler to manipulate a virtual clock via
StepVerifier.Step.thenAwait() . |
static <T> StepVerifier.FirstStep<T> |
StepVerifier.withVirtualTime(java.util.function.Supplier<? extends org.reactivestreams.Publisher<? extends T>> scenarioSupplier,
long n)
Prepare a new
StepVerifier in a controlled environment using
VirtualTimeScheduler to manipulate a virtual clock via
StepVerifier.Step.thenAwait() . |
static <T> StepVerifier.FirstStep<T> |
StepVerifier.withVirtualTime(java.util.function.Supplier<? extends org.reactivestreams.Publisher<? extends T>> scenarioSupplier,
StepVerifierOptions options)
Prepare a new
StepVerifier in a controlled environment using
a user-provided VirtualTimeScheduler to manipulate a virtual clock via
StepVerifier.Step.thenAwait() . |
static <T> StepVerifier.FirstStep<T> |
StepVerifier.withVirtualTime(java.util.function.Supplier<? extends org.reactivestreams.Publisher<? extends T>> scenarioSupplier,
java.util.function.Supplier<? extends VirtualTimeScheduler> vtsLookup,
long n)
Prepare a new
StepVerifier in a controlled environment using
a user-provided VirtualTimeScheduler to manipulate a virtual clock via
StepVerifier.Step.thenAwait() . |