reactor.test

接口 StepVerifier.FirstStep<T>

类型参数:

T - the type of values that the subscriber contains

所有超级接口:

StepVerifier.LastStep, StepVerifier.Step<T>

封闭接口:

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.

方法概要

限定符和类型	方法和说明
default StepVerifier.FirstStep<T>	enableConditionalSupport(java.util.function.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(java.util.function.Predicate<? super org.reactivestreams.Subscription> predicate) Expect a Subscription and evaluate with the given predicate.

从接口继承的方法 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

从接口继承的方法 reactor.test.StepVerifier.LastStep

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

方法详细资料

enableConditionalSupport

default StepVerifier.FirstStep<T> enableConditionalSupport(@Nullable
                                                           java.util.function.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).

参数:

tryOnNextPredicate - the Predicate to use for conditional tryOnNext path

返回:

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.

返回:

this builder

另请参阅:

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.

参数:

requested - the requested and expected fusion mode

返回:

this builder

另请参阅:

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.

参数:

requested - the requested fusion mode

expected - the expected fusion mode

返回:

this builder

另请参阅:

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.

返回:

this builder

另请参阅:

Fuseable

expectSubscription

StepVerifier.Step<T> expectSubscription()

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

返回:

this builder

另请参阅:

Subscriber.onSubscribe(Subscription)

expectSubscriptionMatches

StepVerifier.Step<T> expectSubscriptionMatches(java.util.function.Predicate<? super org.reactivestreams.Subscription> predicate)

Expect a Subscription and evaluate with the given predicate.

参数:

predicate - the predicate to test on the received Subscription

返回:

this builder

另请参阅:

Subscriber.onSubscribe(Subscription)