| Package | Description |
|---|---|
| reactor.test |
Main test components supporting the testing and assertion of publishers.
|
| Modifier and Type | Method and Description |
|---|---|
static <T> StepVerifier.FirstStep<T> |
StepVerifier.create(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(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(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(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(Supplier<? extends 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(Supplier<? extends 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(Supplier<? extends 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(Supplier<? extends Publisher<? extends T>> scenarioSupplier,
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(). |