Uses of Interface
reactor.test.StepVerifier.Step

Packages that use StepVerifier.Step

Package	Description
reactor.test	Main test components supporting the testing and assertion of publishers.

Uses of StepVerifier.Step in reactor.test

Subinterfaces of StepVerifier.Step in reactor.test

Modifier and Type	Interface and Description
static interface	StepVerifier.FirstStep<T> Define a builder for explicitly expecting an initializing Subscription as first signal.

Methods in reactor.test that return StepVerifier.Step

Modifier and Type	Method and Description
StepVerifier.Step<T>	StepVerifier.Step.as(String description) Set a description for the previous verification step.
default StepVerifier.Step<T>	StepVerifier.Step.assertNext(Consumer<? super T> assertionConsumer) Expect an element and consume it with the given consumer, usually performing assertions on it (eg.
StepVerifier.Step<T>	StepVerifier.Step.consumeNextWith(Consumer<? super T> consumer) Expect an element and consume with the given consumer.Any AssertionErrors thrown by the consumer will be rethrown during verification.
StepVerifier.Step<T>	StepVerifier.Step.consumeRecordedWith(Consumer<? super Collection<T>> consumer) Expect a recording session started via recordWith(java.util.function.Supplier<? extends java.util.Collection<T>>), end it and verify it by applying the given consumer.
StepVerifier.Step<T>	StepVerifier.Step.consumeSubscriptionWith(Consumer<? super Subscription> consumer) Expect a Subscription and consume with the given consumer.
StepVerifier.Step<T>	StepVerifier.FirstStep.expectFusion() Expect the source Publisher to run with Reactor Fusion flow optimization.
StepVerifier.Step<T>	StepVerifier.FirstStep.expectFusion(int requested) 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.
StepVerifier.Step<T>	StepVerifier.FirstStep.expectFusion(int requested, int expected) Expect the source Publisher to run with Reactor Fusion flow optimization.
StepVerifier.Step<T>	StepVerifier.Step.expectNext(T... ts) Expect the next elements received to be equal to the given values.
StepVerifier.Step<T>	StepVerifier.Step.expectNext(T t) Expect the next element received to be equal to the given value.
StepVerifier.Step<T>	StepVerifier.Step.expectNext(T t1, T t2) Expect the next elements received to be equal to the given values.
StepVerifier.Step<T>	StepVerifier.Step.expectNext(T t1, T t2, T t3) Expect the next elements received to be equal to the given values.
StepVerifier.Step<T>	StepVerifier.Step.expectNext(T t1, T t2, T t3, T t4) Expect the next elements received to be equal to the given values.
StepVerifier.Step<T>	StepVerifier.Step.expectNext(T t1, T t2, T t3, T t4, T t5) Expect the next elements received to be equal to the given values.
StepVerifier.Step<T>	StepVerifier.Step.expectNext(T t1, T t2, T t3, T t4, T t5, T t6) Expect the next elements received to be equal to the given values.
StepVerifier.Step<T>	StepVerifier.Step.expectNextCount(long count) Expect to received count elements, starting from the previous expectation or onSubscribe.
StepVerifier.Step<T>	StepVerifier.Step.expectNextMatches(Predicate<? super T> predicate) Expect an element and evaluate with the given predicate.
StepVerifier.Step<T>	StepVerifier.Step.expectNextSequence(Iterable<? extends T> iterable) Expect the next elements to match the given Iterable until its iterator depletes.
StepVerifier.Step<T>	StepVerifier.Step.expectNoAccessibleContext() 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.
StepVerifier.Step<T>	StepVerifier.Step.expectNoEvent(Duration duration) Expect that no event has been observed by the verifier for the length of the provided Duration.
StepVerifier.Step<T>	StepVerifier.FirstStep.expectNoFusionSupport() Expect the source Publisher to NOT run with Reactor Fusion flow optimization.
StepVerifier.Step<T>	StepVerifier.Step.expectRecordedMatches(Predicate<? super Collection<T>> predicate) Expect a recording session started via recordWith(java.util.function.Supplier<? extends java.util.Collection<T>>), end it and verify it by ensuring the provided predicate matches.
StepVerifier.Step<T>	StepVerifier.FirstStep.expectSubscription() Expect a Subscription.
StepVerifier.Step<T>	StepVerifier.FirstStep.expectSubscriptionMatches(Predicate<? super Subscription> predicate) Expect a Subscription and evaluate with the given predicate.
StepVerifier.Step<T>	StepVerifier.Step.recordWith(Supplier<? extends Collection<T>> supplier) Start a recording session storing Subscriber.onNext(Object) values in the supplied Collection.
StepVerifier.Step<T>	StepVerifier.ContextExpectations.then() Add the context checks set up by this StepVerifier.ContextExpectations as a StepVerifier expectation, and return the current StepVerifier.Step in order to build further sequence expectations and ultimately verify the sequence.
StepVerifier.Step<T>	StepVerifier.Step.then(Runnable task) Run an arbitrary task scheduled after previous expectations or tasks.
default StepVerifier.Step<T>	StepVerifier.Step.thenAwait() Mark a Pause in the expectation evaluation.
StepVerifier.Step<T>	StepVerifier.Step.thenAwait(Duration timeshift) Pause the expectation evaluation for a given Duration.
StepVerifier.Step<T>	StepVerifier.Step.thenConsumeWhile(Predicate<T> predicate) Consume further onNext signals as long as they match a predicate.
StepVerifier.Step<T>	StepVerifier.Step.thenConsumeWhile(Predicate<T> predicate, Consumer<T> consumer) Consume further onNext signals using a provided Consumer as long as they match a Predicate.
StepVerifier.Step<T>	StepVerifier.Step.thenRequest(long n) Request the given amount of elements from the upstream Publisher.