- 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
-
- advanceTimeTo(Instant) - Method in class reactor.test.scheduler.VirtualTimeScheduler
-
- apply(Object, Function<Object, String>) - Method in interface reactor.test.ValueFormatters.Extractor
-
- arrayExtractor(Class<T[]>) - Static method in class reactor.test.ValueFormatters
-
Default array extractor that use the [CONVERTED1, CONVERTED2]
representation.
- 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.
- assertMaxRequested(long) - Method in class reactor.test.publisher.TestPublisher
-
Assert that the current maximum request of all this publisher's subscribers
is <= n
.
- 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.
- assertThat(Consumer<Context>) - Method in interface reactor.test.StepVerifier.ContextExpectations
-
Apply custom assertions to the propagated Context
.
- assertWasCancelled() - Method in interface reactor.test.publisher.PublisherProbe
-
Check that the probe was cancelled at least once, or throw an AssertionError
.
- assertWasNotCancelled() - Method in interface reactor.test.publisher.PublisherProbe
-
Check that the probe was never cancelled, or throw an AssertionError
.
- assertWasNotRequested() - Method in interface reactor.test.publisher.PublisherProbe
-
Check that the probe was never requested, or throw an AssertionError
.
- assertWasNotSubscribed() - Method in interface reactor.test.publisher.PublisherProbe
-
Check that the probe was never subscribed to, or throw an AssertionError
.
- assertWasRequested() - Method in interface reactor.test.publisher.PublisherProbe
-
Check that the probe was requested at least once, or throw an AssertionError
.
- assertWasSubscribed() - Method in interface reactor.test.publisher.PublisherProbe
-
Check that the probe was subscribed to at least once, or throw an AssertionError
.
- emit(T...) - Method in class reactor.test.publisher.TestPublisher
-
Combine emitting items and completing this publisher.
- empty() - Static method in interface reactor.test.publisher.PublisherProbe
-
- enableCaptureWith(Logger) - Static method in class reactor.test.util.LoggerUtils
-
Set the logger used for capturing.
- enableCaptureWith(Logger, boolean) - Static method in class reactor.test.util.LoggerUtils
-
Set the logger used for capturing, an optionally suppress log messages from original logger.
- enableConditionalSupport(Predicate<? super T>) - Method in interface reactor.test.StepVerifier.FirstStep
-
Provide a Predicate
that will turn this StepVerifier's subscribers into
Fuseable.ConditionalSubscriber
and drive the Fuseable.ConditionalSubscriber.tryOnNext(Object)
behavior of these subscribers.
- error(Throwable) - Method in class reactor.test.publisher.TestPublisher
-
Triggers an
error
signal to the subscribers.
- error(String) - Method in class reactor.test.util.TestLogger
-
- error(String, Object...) - Method in class reactor.test.util.TestLogger
-
- error(String, Throwable) - Method in class reactor.test.util.TestLogger
-
- expectAccessibleContext() - Method in interface reactor.test.StepVerifier.Step
-
Expect that after the
Subscription
step, a
Context
has been
propagated.
- 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.
- expectErrorSatisfies(Consumer<Throwable>) - Method in interface reactor.test.StepVerifier.LastStep
-
Expect an error and assert it via assertion(s) provided as a Consumer
.
- 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 element received to be equal to the given value.
- expectNext(T, T) - Method in interface reactor.test.StepVerifier.Step
-
Expect the next elements received to be equal to the given values.
- expectNext(T, T, T) - Method in interface reactor.test.StepVerifier.Step
-
Expect the next elements received to be equal to the given values.
- expectNext(T, T, T, T) - Method in interface reactor.test.StepVerifier.Step
-
Expect the next elements received to be equal to the given values.
- expectNext(T, T, T, T, T) - Method in interface reactor.test.StepVerifier.Step
-
Expect the next elements received to be equal to the given values.
- expectNext(T, T, T, T, T, T) - Method in interface reactor.test.StepVerifier.Step
-
Expect the next elements received to be equal to the given values.
- 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 to received count
elements, starting from the previous
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.
- expectNoAccessibleContext() - Method in interface reactor.test.StepVerifier.Step
-
Expect that NO
Context
was propagated after the
Subscription
phase, which usually indicates that the sequence under test doesn't contain
Reactor operators (i.e.
- expectNoEvent(Duration) - Method in interface reactor.test.StepVerifier.Step
-
Expect that no event has been observed by the verifier for the length of
the provided Duration
.
- 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
-
- expectSubscription() - Method in interface reactor.test.StepVerifier.FirstStep
-
- expectSubscriptionMatches(Predicate<? super Subscription>) - Method in interface reactor.test.StepVerifier.FirstStep
-
Expect a
Subscription
and evaluate with the given predicate.
- expectTerminalError() - Method in interface reactor.test.subscriber.TestSubscriber
-
- expectTerminalSignal() - Method in interface reactor.test.subscriber.TestSubscriber
-
- expectTimeout(Duration) - Method in interface reactor.test.StepVerifier.LastStep
-
Verify that the
Publisher
under test doesn't terminate but
rather times out after the provided
Duration
(a timeout implying
a cancellation of the source).
- explode(CONTAINER) - Method in interface reactor.test.ValueFormatters.Extractor
-
Explode the container into a
Stream
of
Object
, each of which
is a candidate for individual
String
conversion by a
ValueFormatters.ToStringConverter
when applied as a
BiFunction
.
- extractor(ValueFormatters.Extractor<T>) - Method in class reactor.test.StepVerifierOptions
-
- hasDiscarded(Object...) - Method in interface reactor.test.StepVerifier.Assertions
-
Assert that the tested publisher has discarded at least all of the provided
elements to the discard
hook, in any order.
- hasDiscardedElements() - Method in interface reactor.test.StepVerifier.Assertions
-
Assert that the tested publisher has discarded at least one element to the
discard
hook.
- hasDiscardedElementsMatching(Predicate<Collection<Object>>) - Method in interface reactor.test.StepVerifier.Assertions
-
Assert that the tested publisher has discarded one or more elements to the
discard
hook,
and check that the collection of discarded elements matches a predicate.
- hasDiscardedElementsSatisfying(Consumer<Collection<Object>>) - Method in interface reactor.test.StepVerifier.Assertions
-
Assert that the tested publisher has discarded one or more elements to the
discard
hook, and assert them as a collection.
- hasDiscardedExactly(Object...) - Method in interface reactor.test.StepVerifier.Assertions
-
Assert that the tested publisher has discarded all of the provided elements to
the discard
hook,
in any order, and that no other elements were dropped.
- 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.
- hasKey(Object) - Method in interface reactor.test.StepVerifier.ContextExpectations
-
Check that the propagated Context
contains a value for the given key.
- hasNotDiscardedElements() - Method in interface reactor.test.StepVerifier.Assertions
-
Assert that the tested publisher has not discarded any element to the
discard
hook.
- hasNotDroppedElements() - Method in interface reactor.test.StepVerifier.Assertions
-
Assert that the tested publisher has not dropped any element to the
Hooks.onNextDropped(Consumer)
hook.
- hasNotDroppedErrors() - Method in interface reactor.test.StepVerifier.Assertions
-
Assert that the tested publisher has not dropped any error to the
Hooks.onErrorDropped(Consumer)
hook.
- 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<Optional<Throwable>, Optional<?>>>>) - 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<Optional<Throwable>, Optional<?>>>>) - 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.
- hasSize(int) - Method in interface reactor.test.StepVerifier.ContextExpectations
-
Check that the propagated Context
is of the given size.