Skip navigation links
Reactor Addons: javadoc
A C D E F G H I L M N 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.
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
Deprecated.
behavior will change to be that of VirtualTimeScheduler.createForAll() in 3.1.0
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).
createForAll() - Static method in class reactor.test.scheduler.VirtualTimeScheduler
Deprecated.
will be removed in 3.1.0, AT WHICH POINT the `create()` method will influence ALL schedulers
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

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
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