Package reactor.test

Interface StepVerifier.FirstStep<T>

Type Parameters:

T - the type of values that the subscriber contains

All Superinterfaces:

StepVerifier.LastStep, StepVerifier.Step<T>

Enclosing interface:

StepVerifier

public static interface StepVerifier.FirstStep<T>
extends StepVerifier.Step<T>

Define a builder for explicitly expecting an initializing Subscription as first signal.

If StepVerifier.FirstStep expectations are not used, the produced StepVerifier keeps a first expectation that will be checking if the first signal is a Subscription.

Method Summary

Modifier and Type	Method	Description
default StepVerifier.FirstStep<T>	enableConditionalSupport(@Nullable 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.
StepVerifier.Step<T>	expectFusion()	Expect the source Publisher to run with Reactor Fusion flow optimization.
StepVerifier.Step<T>	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>	expectFusion(int requested, int expected)	Expect the source Publisher to run with Reactor Fusion flow optimization.
StepVerifier.Step<T>	expectNoFusionSupport()	Expect the source Publisher to NOT run with Reactor Fusion flow optimization.
StepVerifier.Step<T>	expectSubscription()	Expect a Subscription.
StepVerifier.Step<T>	expectSubscriptionMatches(Predicate<? super Subscription> predicate)	Expect a Subscription and evaluate with the given predicate.

Methods inherited from interface reactor.test.StepVerifier.LastStep

consumeErrorWith, expectComplete, expectError, expectError, expectErrorMatches, expectErrorMessage, expectErrorSatisfies, expectTimeout, thenCancel, verifyComplete, verifyError, verifyError, verifyErrorMatches, verifyErrorMessage, verifyErrorSatisfies, verifyTimeout

Methods inherited from interface reactor.test.StepVerifier.Step

as, assertNext, consumeNextWith, consumeRecordedWith, consumeSubscriptionWith, expectAccessibleContext, expectNext, expectNext, expectNext, expectNext, expectNext, expectNext, expectNext, expectNextCount, expectNextMatches, expectNextSequence, expectNoAccessibleContext, expectNoEvent, expectRecordedMatches, recordWith, then, thenAwait, thenAwait, thenConsumeWhile, thenConsumeWhile, thenRequest

Method Details

enableConditionalSupport

default StepVerifier.FirstStep<T> enableConditionalSupport(@Nullable 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. Set to null to deactivate (the default).

Parameters:

tryOnNextPredicate - the Predicate to use for conditional tryOnNext path

Returns:

the verifier for final StepVerifier.verify() call

expectFusion

StepVerifier.Step<T> expectFusion()

Expect the source Publisher to run with Reactor Fusion flow optimization. It will be requesting Fuseable.ANY fusion mode.

Returns:

this builder

See Also:

• Fuseable

expectFusion

StepVerifier.Step<T> 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.

Parameters:

requested - the requested and expected fusion mode

Returns:

this builder

See Also:

• Fuseable

expectFusion

StepVerifier.Step<T> expectFusion(int requested,
 int expected)

Expect the source Publisher to run with Reactor Fusion flow optimization. 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.

Parameters:

requested - the requested fusion mode

expected - the expected fusion mode

Returns:

this builder

See Also:

• Fuseable

expectNoFusionSupport

StepVerifier.Step<T> expectNoFusionSupport()

Expect the source Publisher to NOT run with Reactor Fusion flow optimization. It will check if publisher is Fuseable or subscription is a Fuseable.QueueSubscription.

Returns:

this builder

See Also:

• Fuseable

expectSubscription

StepVerifier.Step<T> expectSubscription()

Expect a Subscription. Effectively behave as the default implicit Subscription expectation.

Returns:

this builder

See Also:

• Subscriber.onSubscribe(Subscription)

expectSubscriptionMatches

StepVerifier.Step<T> expectSubscriptionMatches(Predicate<? super Subscription> predicate)

Expect a Subscription and evaluate with the given predicate.

Parameters:

predicate - the predicate to test on the received Subscription

Returns:

this builder

See Also:

• Subscriber.onSubscribe(Subscription)