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() . |