Skip navigation links
Reactor Addons: javadoc
A C D E F G H I L M N P R S T V W 

A

advanceTime() - Method in class reactor.test.scheduler.VirtualTimeScheduler
Triggers any tasks that have not yet been executed and that are scheduled to be executed at or before this VirtualTimeScheduler's present time.
advanceTimeBy(Duration) - Method in class reactor.test.scheduler.VirtualTimeScheduler
Moves the VirtualTimeScheduler's clock forward by a specified amount of time.
advanceTimeTo(Instant) - Method in class reactor.test.scheduler.VirtualTimeScheduler
Moves the VirtualTimeScheduler's clock to a particular moment in time.
as(String) - Method in interface reactor.test.StepVerifier.Step
Set a description for the previous verification step.
assertCancelled() - Method in class reactor.test.publisher.TestPublisher
Asserts that this publisher has had at least one subscriber that has been cancelled.
assertCancelled(int) - Method in class reactor.test.publisher.TestPublisher
Asserts that this publisher has had at least n subscribers that have been cancelled.
assertMinRequested(long) - Method in class reactor.test.publisher.TestPublisher
Assert that the current minimum request of all this publisher's subscribers is >= n.
assertNext(Consumer<? super T>) - Method in interface reactor.test.StepVerifier.Step
Expect an element and consume it with the given consumer, usually performing assertions on it (eg.
assertNoRequestOverflow() - Method in class reactor.test.publisher.TestPublisher
Asserts that this publisher has had no subscriber with request overflow.
assertNoSubscribers() - Method in class reactor.test.publisher.TestPublisher
Asserts that this publisher has no subscribers.
assertNotCancelled() - Method in class reactor.test.publisher.TestPublisher
Asserts that this publisher has had no cancelled subscribers.
assertRequestOverflow() - Method in class reactor.test.publisher.TestPublisher
Asserts that this publisher has had subscriber that saw request overflow, that is received an onNext event despite having a requested amount of 0 at the time.
assertSubscribers() - Method in class reactor.test.publisher.TestPublisher
Asserts that this publisher has subscribers.
assertSubscribers(int) - Method in class reactor.test.publisher.TestPublisher
Asserts that this publisher has exactly n subscribers.

C

checkUnderRequesting(boolean) - Method in class reactor.test.StepVerifierOptions
Activate or deactivate the StepVerifier check of request amount being too low.
compareTo(StageUtils.Node) - Method in class reactor.test.util.StageUtils.Node
 
complete() - Method in class reactor.test.publisher.TestPublisher
Triggers completion of this publisher.
consumeErrorWith(Consumer<Throwable>) - Method in interface reactor.test.StepVerifier.LastStep
Expect an error and consume with the given consumer.
consumeNextWith(Consumer<? super T>) - Method in interface reactor.test.StepVerifier.Step
Expect an element and consume with the given consumer.
consumeRecordedWith(Consumer<? super Collection<T>>) - Method in interface reactor.test.StepVerifier.Step
Expect a recording session started via StepVerifier.Step.recordWith(java.util.function.Supplier<? extends java.util.Collection<T>>) and consume with the given consumer.
consumeSubscriptionWith(Consumer<? super Subscription>) - Method in interface reactor.test.StepVerifier.Step
Expect a Subscription and consume with the given consumer.
create() - Static method in class reactor.test.publisher.TestPublisher
Create a standard TestPublisher.
create() - Static method in class reactor.test.scheduler.VirtualTimeScheduler
Create a new VirtualTimeScheduler without enabling it.
create(Publisher<? extends T>) - Static method in interface reactor.test.StepVerifier
Prepare a new StepVerifier in an uncontrolled environment: Expect non-virtual blocking wait via StepVerifier.Step.thenAwait().
create(Publisher<? extends T>, long) - Static method in interface reactor.test.StepVerifier
Prepare a new StepVerifier in an uncontrolled environment: Expect non-virtual blocking wait via StepVerifier.Step.thenAwait().
create(Publisher<? extends T>, StepVerifierOptions) - Static method in interface reactor.test.StepVerifier
Prepare a new StepVerifier in an uncontrolled environment: Expect non-virtual blocking wait via StepVerifier.Step.thenAwait().
create() - Static method in class reactor.test.StepVerifierOptions
Create a new default set of options for a StepVerifier that can be tuned using the various available non-getter methods (which can be chained).
createEdgeTo(StageUtils.Node) - Method in class reactor.test.util.StageUtils.Node
 
createEdgeTo(StageUtils.Node, StageUtils.Edge.Type) - Method in class reactor.test.util.StageUtils.Node
 
createEdgeTo(String, StageUtils.Edge.Type) - Method in class reactor.test.util.StageUtils.Node
 
createForAll() - Static method in class reactor.test.scheduler.VirtualTimeScheduler
Create a new VirtualTimeScheduler without enabling it.
createGraph() - Static method in class reactor.test.util.StageUtils
Create an empty graph
createGraph(boolean) - Static method in class reactor.test.util.StageUtils
Create an empty graph
createNoncompliant(TestPublisher.Violation, TestPublisher.Violation...) - Static method in class reactor.test.publisher.TestPublisher
Create a noncompliant TestPublisher with a given set of reactive streams spec violations that will be overlooked.
createWorker() - Method in class reactor.test.scheduler.VirtualTimeScheduler
 

D

dispose() - Method in class reactor.test.scheduler.VirtualTimeScheduler
 

E

Edge(String, String, StageUtils.Edge.Type) - Constructor for class reactor.test.util.StageUtils.Edge
 
emit(T...) - Method in class reactor.test.publisher.TestPublisher
Combine emitting items and completing this publisher.
enable(boolean) - Static method in class reactor.test.scheduler.VirtualTimeScheduler
Deprecated.
use VirtualTimeScheduler.getOrSet(boolean) alias instead, will be removed in 3.1.0
enable(VirtualTimeScheduler) - Static method in class reactor.test.scheduler.VirtualTimeScheduler
Deprecated.
use VirtualTimeScheduler.getOrSet(VirtualTimeScheduler) instead, will be removed in 3.1.0
equals(Object) - Method in class reactor.test.util.StageUtils.Edge
 
equals(Object) - Method in class reactor.test.util.StageUtils.Node
 
error(Throwable) - Method in class reactor.test.publisher.TestPublisher
Triggers an error signal to the subscribers.
expectComplete() - Method in interface reactor.test.StepVerifier.LastStep
Expect the completion signal.
expectError() - Method in interface reactor.test.StepVerifier.LastStep
Expect an unspecified error.
expectError(Class<? extends Throwable>) - Method in interface reactor.test.StepVerifier.LastStep
Expect an error of the specified type.
expectErrorMatches(Predicate<Throwable>) - Method in interface reactor.test.StepVerifier.LastStep
Expect an error and evaluate with the given predicate.
expectErrorMessage(String) - Method in interface reactor.test.StepVerifier.LastStep
Expect an error with the specified message.
expectFusion() - Method in interface reactor.test.StepVerifier.FirstStep
Expect the source Publisher to run with Reactor Fusion flow optimization.
expectFusion(int) - Method in interface reactor.test.StepVerifier.FirstStep
Expect the source Publisher to run the requested Reactor Fusion mode from any of these modes : Fuseable.NONE, Fuseable.SYNC, Fuseable.ASYNC, Fuseable.ANY, Fuseable.THREAD_BARRIER.
expectFusion(int, int) - Method in interface reactor.test.StepVerifier.FirstStep
Expect the source Publisher to run with Reactor Fusion flow optimization.
expectNext(T...) - Method in interface reactor.test.StepVerifier.Step
Expect the next elements received to be equal to the given values.
expectNextCount(long) - Method in interface reactor.test.StepVerifier.Step
Expect an element count starting from the last expectation or onSubscribe.
expectNextMatches(Predicate<? super T>) - Method in interface reactor.test.StepVerifier.Step
Expect an element and evaluate with the given predicate.
expectNextSequence(Iterable<? extends T>) - Method in interface reactor.test.StepVerifier.Step
Expect the next elements to match the given Iterable until its iterator depletes.
expectNoEvent(Duration) - Method in interface reactor.test.StepVerifier.FirstStep
Expect no Subscription or any other event for the given duration.
expectNoEvent(Duration) - Method in interface reactor.test.StepVerifier.Step
Expect that no event has been observed by the verifier.
expectNoFusionSupport() - Method in interface reactor.test.StepVerifier.FirstStep
Expect the source Publisher to NOT run with Reactor Fusion flow optimization.
expectRecordedMatches(Predicate<? super Collection<T>>) - Method in interface reactor.test.StepVerifier.Step
Expect and end a recording session started via StepVerifier.Step.recordWith(java.util.function.Supplier<? extends java.util.Collection<T>>) and consume with the given consumer.
expectSubscription() - Method in interface reactor.test.StepVerifier.FirstStep
Expect a Subscription.
expectSubscriptionMatches(Predicate<? super Subscription>) - Method in interface reactor.test.StepVerifier.FirstStep
Expect a Subscription and evaluate with the given predicate.

F

flux() - Method in class reactor.test.publisher.TestPublisher
Convenience method to wrap this TestPublisher to a Flux.

G

get() - Static method in class reactor.test.scheduler.VirtualTimeScheduler
The current VirtualTimeScheduler assigned in Schedulers
getBuffered(Object) - Static method in class reactor.test.util.StageUtils
 
getBuffered() - Method in class reactor.test.util.StageUtils.Node
 
getCapacity(Object) - Static method in class reactor.test.util.StageUtils
 
getCapacity() - Method in class reactor.test.util.StageUtils.Node
 
getEdges() - Method in class reactor.test.util.StageUtils.Graph
 
getExpectedUpstream(Object) - Static method in class reactor.test.util.StageUtils
 
getExpectedUpstream() - Method in class reactor.test.util.StageUtils.Node
 
getFailedState(Object) - Static method in class reactor.test.util.StageUtils
 
getFailedState() - Method in class reactor.test.util.StageUtils.Node
 
getFrom() - Method in class reactor.test.util.StageUtils.Edge
 
getGroup(Object) - Static method in class reactor.test.util.StageUtils
 
getGroup() - Method in class reactor.test.util.StageUtils.Node
 
getId() - Method in class reactor.test.util.StageUtils.Edge
 
getId() - Method in class reactor.test.util.StageUtils.Node
 
getIdOrDefault(Object) - Static method in class reactor.test.util.StageUtils
 
getInitialRequest() - Method in class reactor.test.StepVerifierOptions
 
getName(Object) - Static method in class reactor.test.util.StageUtils
 
getName() - Method in class reactor.test.util.StageUtils.Node
 
getNodes() - Method in class reactor.test.util.StageUtils.Graph
 
getOrSet(boolean) - Static method in class reactor.test.scheduler.VirtualTimeScheduler
Assign a single newly created VirtualTimeScheduler to all or timed-only Schedulers.Factory factories.
getOrSet(VirtualTimeScheduler) - Static method in class reactor.test.scheduler.VirtualTimeScheduler
Assign an externally created VirtualTimeScheduler to the relevant Schedulers.Factory factories, depending on how it was created (see VirtualTimeScheduler.createForAll() and VirtualTimeScheduler.create()).
getPeriod() - Method in class reactor.test.util.StageUtils.Node
 
getRequestedDownstream(Object) - Static method in class reactor.test.util.StageUtils
 
getRequestedDownstream() - Method in class reactor.test.util.StageUtils.Node
 
getTimedPeriod(Object) - Static method in class reactor.test.util.StageUtils
 
getTo() - Method in class reactor.test.util.StageUtils.Edge
 
getType() - Method in class reactor.test.util.StageUtils.Edge
 
getUpstreamLimit(Object) - Static method in class reactor.test.util.StageUtils
 
getUpstreamLimit() - Method in class reactor.test.util.StageUtils.Node
 
getVirtualTimeSchedulerSupplier() - Method in class reactor.test.StepVerifierOptions
 

H

hasDownstream(Object) - Static method in class reactor.test.util.StageUtils
 
hasDownstreams(Object) - Static method in class reactor.test.util.StageUtils
 
hasDropped(Object...) - Method in interface reactor.test.StepVerifier.Assertions
Assert that the tested publisher has dropped at least all of the provided elements to the Hooks.onNextDropped(Consumer) hook, in any order.
hasDroppedElements() - Method in interface reactor.test.StepVerifier.Assertions
Assert that the tested publisher has dropped at least one element to the Hooks.onNextDropped(Consumer) hook.
hasDroppedErrorMatching(Predicate<Throwable>) - Method in interface reactor.test.StepVerifier.Assertions
Assert that the tested publisher has dropped exactly one error matching the given predicate to the Hooks.onErrorDropped(Consumer) hook.
hasDroppedErrorOfType(Class<? extends Throwable>) - Method in interface reactor.test.StepVerifier.Assertions
Assert that the tested publisher has dropped exactly one error of the given type to the Hooks.onErrorDropped(Consumer) hook.
hasDroppedErrors() - Method in interface reactor.test.StepVerifier.Assertions
Assert that the tested publisher has dropped at least one error to the Hooks.onErrorDropped(Consumer) hook.
hasDroppedErrors(int) - Method in interface reactor.test.StepVerifier.Assertions
Assert that the tested publisher has dropped exactly n errors to the Hooks.onErrorDropped(Consumer) hook.
hasDroppedErrorsMatching(Predicate<Collection<Throwable>>) - Method in interface reactor.test.StepVerifier.Assertions
Assert that the tested publisher has dropped one or more errors to the Hooks.onErrorDropped(Consumer) hook, and check that the collection of errors matches a predicate.
hasDroppedErrorsSatisfying(Consumer<Collection<Throwable>>) - Method in interface reactor.test.StepVerifier.Assertions
Assert that the tested publisher has dropped one or more errors to the Hooks.onErrorDropped(Consumer) hook, and assert them as a collection.
hasDroppedErrorWithMessage(String) - Method in interface reactor.test.StepVerifier.Assertions
Assert that the tested publisher has dropped exactly one error with the exact provided message to the Hooks.onErrorDropped(Consumer) hook.
hasDroppedErrorWithMessageContaining(String) - Method in interface reactor.test.StepVerifier.Assertions
Assert that the tested publisher has dropped exactly one error with a message containing the provided string to the Hooks.onErrorDropped(Consumer) hook.
hasDroppedExactly(Object...) - Method in interface reactor.test.StepVerifier.Assertions
Assert that the tested publisher has dropped all of the provided elements to the Hooks.onNextDropped(Consumer) hook, in any order, and that no other elements were dropped.
hasFeedbackLoop(Object) - Static method in class reactor.test.util.StageUtils
 
hashCode() - Method in class reactor.test.util.StageUtils.Edge
 
hashCode() - Method in class reactor.test.util.StageUtils.Node
 
hasOperatorErrorMatching(Predicate<Throwable>) - Method in interface reactor.test.StepVerifier.Assertions
Assert that the tested publisher has triggered the onOperatorError hook exactly once and the error matches the given predicate.
hasOperatorErrorOfType(Class<? extends Throwable>) - Method in interface reactor.test.StepVerifier.Assertions
Assert that the tested publisher has triggered the onOperatorError hook exactly once and the error is of the given type.
hasOperatorErrors() - Method in interface reactor.test.StepVerifier.Assertions
Assert that the tested publisher has triggered the onOperatorError hook at least once.
hasOperatorErrors(int) - Method in interface reactor.test.StepVerifier.Assertions
Assert that the tested publisher has triggered the onOperatorError hook exactly n times.
hasOperatorErrorsMatching(Predicate<Collection<Tuple2<Throwable, ?>>>) - Method in interface reactor.test.StepVerifier.Assertions
Assert that the tested publisher has triggered the onOperatorError hook once or more, and check that the collection of errors and their optionally associated data matches a predicate.
hasOperatorErrorsSatisfying(Consumer<Collection<Tuple2<Throwable, ?>>>) - Method in interface reactor.test.StepVerifier.Assertions
Assert that the tested publisher has triggered the onOperatorError hook once or more, and assert the errors and optionally associated data as a collection.
hasOperatorErrorWithMessage(String) - Method in interface reactor.test.StepVerifier.Assertions
Assert that the tested publisher has triggered the onOperatorError hook exactly once and the error has the exact provided message.
hasOperatorErrorWithMessageContaining(String) - Method in interface reactor.test.StepVerifier.Assertions
Assert that the tested publisher has triggered the onOperatorError hook exactly once, with the error message containing the provided string.
hasSubscription(Object) - Static method in class reactor.test.util.StageUtils
 
hasUpstream(Object) - Static method in class reactor.test.util.StageUtils
 
hasUpstreams(Object) - Static method in class reactor.test.util.StageUtils
 

I

initialRequest(long) - Method in class reactor.test.StepVerifierOptions
Set the amount the StepVerifier should request initially.
isActive() - Method in class reactor.test.util.StageUtils.Node
 
isCancellable(Object) - Static method in class reactor.test.util.StageUtils
 
isCancelled() - Method in class reactor.test.util.StageUtils.Node
 
isCheckUnderRequesting() - Method in class reactor.test.StepVerifierOptions
 
isContained(Object) - Static method in class reactor.test.util.StageUtils
 
isCyclic() - Method in class reactor.test.util.StageUtils.Graph
 
isDefinedId() - Method in class reactor.test.util.StageUtils.Node
 
isDisposed() - Method in class reactor.test.scheduler.VirtualTimeScheduler
 
isEnabledOnAllSchedulers() - Method in class reactor.test.scheduler.VirtualTimeScheduler
 
isFactory(Object) - Static method in class reactor.test.util.StageUtils
 
isFactory() - Method in class reactor.test.util.StageUtils.Node
 
isFactoryEnabled() - Static method in class reactor.test.scheduler.VirtualTimeScheduler
Return true if there is a VirtualTimeScheduler currently used by the Schedulers factory (ie it has been enabled), false otherwise (ie it has been reset).
isInner() - Method in class reactor.test.util.StageUtils.Node
 
isLogging(Object) - Static method in class reactor.test.util.StageUtils
 
isLogging() - Method in class reactor.test.util.StageUtils.Node
 
isReference() - Method in class reactor.test.util.StageUtils.Node
 
isTerminated() - Method in class reactor.test.util.StageUtils.Node
 

L

log() - Method in interface reactor.test.StepVerifier
Activate debug logging of a description of the test scenario, as well as some details about certain verification steps.

M

mergeWith(StageUtils.Graph) - Method in class reactor.test.util.StageUtils.Graph
Merge this instance with an external graph thus overriding any overlapping local keys.
mono() - Method in class reactor.test.publisher.TestPublisher
Convenience method to wrap this TestPublisher to a Mono.

N

next(T) - Method in class reactor.test.publisher.TestPublisher
Send 1 onNext signal to the subscribers.
next(T, T...) - Method in class reactor.test.publisher.TestPublisher
Send 1-n onNext signals to the subscribers.
Node(String, String, Object, String) - Constructor for class reactor.test.util.StageUtils.Node
 
now(TimeUnit) - Method in class reactor.test.scheduler.VirtualTimeScheduler
 

P

prettyPrint(Object) - Static method in class reactor.test.util.StageUtils
Introspect the passed object and return a JSON representation as a String.
print(Object) - Static method in class reactor.test.util.StageUtils
Introspect the passed object and return a JSON representation as a String.
print(Object, boolean) - Static method in class reactor.test.util.StageUtils
Introspect the passed object and return a JSON representation as a String.
property(String, Object) - Static method in class reactor.test.util.StageUtils
Parse and encode a property as a json map entry.

R

reactor.test - package reactor.test
 
reactor.test.publisher - package reactor.test.publisher
 
reactor.test.scheduler - package reactor.test.scheduler
 
reactor.test.util - package reactor.test.util
 
recordWith(Supplier<? extends Collection<T>>) - Method in interface reactor.test.StepVerifier.Step
Start a recording session storing Subscriber.onNext(Object) values in the supplied Collection.
removeTerminatedNodes() - Method in class reactor.test.util.StageUtils.Graph
Clear unreferenced nodes from a graph
reset() - Static method in class reactor.test.scheduler.VirtualTimeScheduler
Re-assign the default Reactor Core Schedulers factories.

S

scan(Object) - Static method in class reactor.test.util.StageUtils
Create a "Nodes" and "Links" complete representation of a given component if available
scan(Object, boolean) - Static method in class reactor.test.util.StageUtils
Create a "Nodes" and "Links" complete representation of a given component if available
schedule(Runnable) - Method in class reactor.test.scheduler.VirtualTimeScheduler
 
schedule(Runnable, long, TimeUnit) - Method in class reactor.test.scheduler.VirtualTimeScheduler
 
schedulePeriodically(Runnable, long, long, TimeUnit) - Method in class reactor.test.scheduler.VirtualTimeScheduler
 
set(VirtualTimeScheduler) - Static method in class reactor.test.scheduler.VirtualTimeScheduler
Assign an externally created VirtualTimeScheduler to the relevant Schedulers.Factory factories, depending on how it was created (see VirtualTimeScheduler.createForAll() and VirtualTimeScheduler.create()).
shutdown() - Method in class reactor.test.scheduler.VirtualTimeScheduler
 
StageUtils - Class in reactor.test.util
Navigate and introspect Loopback, Receiver, MultiReceiver, MultiProducer and Producer.
StageUtils() - Constructor for class reactor.test.util.StageUtils
 
StageUtils.Edge - Class in reactor.test.util
A relationship between 2 concrete or virtual node references
StageUtils.Edge.Type - Enum in reactor.test.util
 
StageUtils.Graph - Class in reactor.test.util
 
StageUtils.Node - Class in reactor.test.util
A logical view representation of an introspected reference from StageUtils.scan(Object)
StepVerifier - Interface in reactor.test
A StepVerifier is a verifiable, blocking script usually produced by terminal expectations of the said script.
StepVerifier.Assertions - Interface in reactor.test
Exposes post-verification state assertions.
StepVerifier.FirstStep<T> - Interface in reactor.test
Define a builder for explicitly expecting an initializing Subscription as first signal.
StepVerifier.LastStep - Interface in reactor.test
Define a builder for terminal states.
StepVerifier.Step<T> - Interface in reactor.test
Define a builder for expecting main sequence individual signals.
StepVerifierOptions - Class in reactor.test
Options for a StepVerifier, including the initial request amount, VirtualTimeScheduler supplier and toggles for some checks.
subscan(Object) - Static method in class reactor.test.util.StageUtils
Create a "Nodes" and "Links" downstream representation of a given component if available
subscan(Object, boolean) - Static method in class reactor.test.util.StageUtils
Create a "Nodes" and "Links" downstream representation of a given component if available

T

TestPublisher<T> - Class in reactor.test.publisher
A Publisher that you can directly manipulate, triggering onNext, onComplete and onError events, for testing purposes.
TestPublisher() - Constructor for class reactor.test.publisher.TestPublisher
 
TestPublisher.Violation - Enum in reactor.test.publisher
Possible misbehavior for a TestPublisher.
then(Runnable) - Method in interface reactor.test.StepVerifier.Step
Run an arbitrary task scheduled after previous expectations or tasks.
thenAwait() - Method in interface reactor.test.StepVerifier.Step
Mark a Pause in the expectation evaluation.
thenAwait(Duration) - Method in interface reactor.test.StepVerifier.Step
Pause the expectation evaluation for a given Duration.
thenCancel() - Method in interface reactor.test.StepVerifier.LastStep
Cancel the underlying subscription.
thenConsumeWhile(Predicate<T>) - Method in interface reactor.test.StepVerifier.Step
Consume further onNext signals as long as they match a predicate.
thenConsumeWhile(Predicate<T>, Consumer<T>) - Method in interface reactor.test.StepVerifier.Step
Consume further onNext signals using a provided Consumer as long as they match a Predicate.
thenRequest(long) - Method in interface reactor.test.StepVerifier.Step
Request the given amount of elements from the upstream Publisher.
toJSON() - Method in class reactor.test.util.StageUtils.Node
 
toJSON(int) - Method in class reactor.test.util.StageUtils.Node
 
tookLessThan(Duration) - Method in interface reactor.test.StepVerifier.Assertions
Assert that the whole verification took strictly less than the provided duration to execute.
tookMoreThan(Duration) - Method in interface reactor.test.StepVerifier.Assertions
Assert that the whole verification took strictly more than the provided duration to execute.
toString() - Method in class reactor.test.util.StageUtils.Edge
 
toString(boolean) - Method in class reactor.test.util.StageUtils.Graph
 
toString() - Method in class reactor.test.util.StageUtils.Graph
 
toString() - Method in class reactor.test.util.StageUtils.Node
 

V

value() - Method in class reactor.test.util.StageUtils.Node
 
valueOf(String) - Static method in enum reactor.test.publisher.TestPublisher.Violation
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum reactor.test.util.StageUtils.Edge.Type
Returns the enum constant of this type with the specified name.
values() - Static method in enum reactor.test.publisher.TestPublisher.Violation
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum reactor.test.util.StageUtils.Edge.Type
Returns an array containing the constants of this enum type, in the order they are declared.
verify() - Method in interface reactor.test.StepVerifier
Verify the signals received by this subscriber.
verify(Duration) - Method in interface reactor.test.StepVerifier
Verify the signals received by this subscriber.
verifyComplete() - Method in interface reactor.test.StepVerifier.LastStep
Trigger the verification, expecting a completion signal as terminal event.
verifyError() - Method in interface reactor.test.StepVerifier.LastStep
Trigger the verification, expecting an unspecified error as terminal event.
verifyError(Class<? extends Throwable>) - Method in interface reactor.test.StepVerifier.LastStep
Trigger the verification, expecting an error of the specified type as terminal event.
verifyErrorMatches(Predicate<Throwable>) - Method in interface reactor.test.StepVerifier.LastStep
Trigger the verification, expecting an error that matches the given predicate as terminal event.
verifyErrorMessage(String) - Method in interface reactor.test.StepVerifier.LastStep
Trigger the verification, expecting an error with the specified messagee as terminal event.
verifyThenAssertThat() - Method in interface reactor.test.StepVerifier
Verifies the signals received by this subscriber, then exposes various assertion methods on the final state.
VirtualTimeScheduler - Class in reactor.test.scheduler
A TimedScheduler that uses a virtual clock, allowing to manipulate time (eg.
VirtualTimeScheduler(boolean) - Constructor for class reactor.test.scheduler.VirtualTimeScheduler
 
virtualTimeSchedulerSupplier(Supplier<? extends VirtualTimeScheduler>) - Method in class reactor.test.StepVerifierOptions
Set a supplier for a VirtualTimeScheduler, which is mandatory for a StepVerifier to work with virtual time.

W

withVirtualTime(Supplier<? extends Publisher<? extends T>>) - Static method in interface reactor.test.StepVerifier
Prepare a new StepVerifier in a controlled environment using VirtualTimeScheduler to schedule and expect virtual wait via StepVerifier.Step.thenAwait().
withVirtualTime(long, Supplier<? extends Publisher<? extends T>>) - Static method in interface reactor.test.StepVerifier
Deprecated.
to be removed in 3.1.0 for parameter ordering harmonization. Please use StepVerifier.withVirtualTime(Supplier, long) instead.
withVirtualTime(Supplier<? extends Publisher<? extends T>>, long) - Static method in interface reactor.test.StepVerifier
Prepare a new StepVerifier in a controlled environment using VirtualTimeScheduler to schedule and expect virtual wait via StepVerifier.Step.thenAwait().
withVirtualTime(long, Supplier<? extends Publisher<? extends T>>, Supplier<? extends VirtualTimeScheduler>) - Static method in interface reactor.test.StepVerifier
Deprecated.
to be removed in 3.1.0 for parameter ordering harmonization. Please use StepVerifier.withVirtualTime(Supplier, Supplier, long) instead.
withVirtualTime(Supplier<? extends Publisher<? extends T>>, Supplier<? extends VirtualTimeScheduler>, long) - Static method in interface reactor.test.StepVerifier
Create a new StepVerifier in a parameterized environment using passed VirtualTimeScheduler to schedule and expect virtual wait via StepVerifier.Step.thenAwait().
withVirtualTime(Supplier<? extends Publisher<? extends T>>, StepVerifierOptions) - Static method in interface reactor.test.StepVerifier
Create a new StepVerifier in a parameterized environment using passed VirtualTimeScheduler to schedule and expect virtual wait via StepVerifier.Step.thenAwait().
A C D E F G H I L M N P R S T V W 
Skip navigation links
Reactor Addons: javadoc