reactor.test

接口 StepVerifier.LastStep

所有已知子接口:

StepVerifier.FirstStep<T>, StepVerifier.Step<T>

封闭接口:

StepVerifier

public static interface StepVerifier.LastStep

Define a builder for terminal states.

方法概要

限定符和类型	方法和说明
StepVerifier	consumeErrorWith(java.util.function.Consumer<java.lang.Throwable> consumer) Expect an error and consume with the given consumer.
StepVerifier	expectComplete() Expect the completion signal.
StepVerifier	expectError() Expect an unspecified error.
StepVerifier	expectError(java.lang.Class<? extends java.lang.Throwable> clazz) Expect an error of the specified type.
StepVerifier	expectErrorMatches(java.util.function.Predicate<java.lang.Throwable> predicate) Expect an error and evaluate with the given predicate.
StepVerifier	expectErrorMessage(java.lang.String errorMessage) Expect an error with the specified message.
StepVerifier	expectErrorSatisfies(java.util.function.Consumer<java.lang.Throwable> assertionConsumer) Expect an error and assert it via assertion(s) provided as a Consumer.
StepVerifier	expectTimeout(java.time.Duration duration) 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).
StepVerifier	thenCancel() Cancel the underlying subscription.
java.time.Duration	verifyComplete() Trigger the verification, expecting a completion signal as terminal event.
java.time.Duration	verifyError() Trigger the verification, expecting an unspecified error as terminal event.
java.time.Duration	verifyError(java.lang.Class<? extends java.lang.Throwable> clazz) Trigger the verification, expecting an error of the specified type as terminal event.
java.time.Duration	verifyErrorMatches(java.util.function.Predicate<java.lang.Throwable> predicate) Trigger the verification, expecting an error that matches the given predicate as terminal event.
java.time.Duration	verifyErrorMessage(java.lang.String errorMessage) Trigger the verification, expecting an error with the specified message as terminal event.
java.time.Duration	verifyErrorSatisfies(java.util.function.Consumer<java.lang.Throwable> assertionConsumer) Trigger the verification, expecting an error as terminal event which gets asserted via assertion(s) provided as a Consumer.
default java.time.Duration	verifyTimeout(java.time.Duration duration) Trigger the verification, expecting that the Publisher under test doesn't terminate but rather times out after the provided Duration.

方法详细资料

consumeErrorWith

StepVerifier consumeErrorWith(java.util.function.Consumer<java.lang.Throwable> consumer)

Expect an error and consume with the given consumer. Any AssertionErrors thrown by the consumer will be rethrown during verification.

参数:

consumer - the consumer for the exception

返回:

the built verification

expectError

StepVerifier expectError()

Expect an unspecified error.

返回:

the built verification scenario, ready to be verified

另请参阅:

Subscriber.onError(Throwable)

expectError

StepVerifier expectError(java.lang.Class<? extends java.lang.Throwable> clazz)

Expect an error of the specified type.

参数:

clazz - the expected error type

返回:

the built verification scenario, ready to be verified

另请参阅:

Subscriber.onError(Throwable)

expectErrorMessage

StepVerifier expectErrorMessage(java.lang.String errorMessage)

Expect an error with the specified message.

参数:

errorMessage - the expected error message

返回:

the built verification scenario, ready to be verified

另请参阅:

Subscriber.onError(Throwable)

expectErrorMatches

StepVerifier expectErrorMatches(java.util.function.Predicate<java.lang.Throwable> predicate)

Expect an error and evaluate with the given predicate.

参数:

predicate - the predicate to test on the next received error

返回:

the built verification scenario, ready to be verified

另请参阅:

Subscriber.onError(Throwable)

expectErrorSatisfies

StepVerifier expectErrorSatisfies(java.util.function.Consumer<java.lang.Throwable> assertionConsumer)

Expect an error and assert it via assertion(s) provided as a Consumer. Any AssertionError thrown by the consumer has its message propagated through a new StepVerifier-specific AssertionError.

参数:

assertionConsumer - the consumer that applies assertion(s) on the next received error

返回:

the built verification scenario, ready to be verified

另请参阅:

Subscriber.onError(Throwable)

expectTimeout

StepVerifier expectTimeout(java.time.Duration duration)

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

This is equivalent to appending the timeout operator to the publisher and expecting a TimeoutException onError signal, while also triggering a wait to ensure unexpected signals are detected.

参数:

duration - the Duration for which no new event is expected

返回:

the built verification scenario, ready to be verified

expectComplete

StepVerifier expectComplete()

Expect the completion signal.

返回:

the built verification scenario, ready to be verified

另请参阅:

Subscriber.onComplete()

thenCancel

StepVerifier thenCancel()

Cancel the underlying subscription. This happens sequentially after the previous step.

Note that time-manipulating operators like StepVerifier.Step.expectNoEvent(Duration) are detected and waited for before cancellation occurs.

返回:

the built verification scenario, ready to be verified

另请参阅:

Subscription.cancel()

verifyError

java.time.Duration verifyError()

Trigger the verification, expecting an unspecified error as terminal event.

This is a convenience method that calls StepVerifier.verify() in addition to the expectation. Explicitly use the expect method and verification method separately if you need something more specific (like activating logging or changing the default timeout).

返回:

the actual Duration the verification took.

另请参阅:

expectError(), StepVerifier.verify(), Subscriber.onError(Throwable)

verifyError

java.time.Duration verifyError(java.lang.Class<? extends java.lang.Throwable> clazz)

Trigger the verification, expecting an error of the specified type as terminal event.

This is a convenience method that calls StepVerifier.verify() in addition to the expectation. Explicitly use the expect method and verification method separately if you need something more specific (like activating logging or changing the default timeout).

参数:

clazz - the expected error type

返回:

the actual Duration the verification took.

另请参阅:

expectError(Class), StepVerifier.verify(), Subscriber.onError(Throwable)

verifyErrorMessage

java.time.Duration verifyErrorMessage(java.lang.String errorMessage)

Trigger the verification, expecting an error with the specified message as terminal event.

This is a convenience method that calls StepVerifier.verify() in addition to the expectation. Explicitly use the expect method and verification method separately if you need something more specific (like activating logging or changing the default timeout).

参数:

errorMessage - the expected error message

返回:

the actual Duration the verification took.

另请参阅:

expectErrorMessage(String), StepVerifier.verify(), Subscriber.onError(Throwable)

verifyErrorMatches

java.time.Duration verifyErrorMatches(java.util.function.Predicate<java.lang.Throwable> predicate)

Trigger the verification, expecting an error that matches the given predicate as terminal event.

This is a convenience method that calls StepVerifier.verify() in addition to the expectation. Explicitly use the expect method and verification method separately if you need something more specific (like activating logging or changing the default timeout).

参数:

predicate - the predicate to test on the next received error

返回:

the actual Duration the verification took.

另请参阅:

expectErrorMatches(Predicate), StepVerifier.verify(), Subscriber.onError(Throwable)

verifyTimeout

default java.time.Duration verifyTimeout(java.time.Duration duration)

Trigger the verification, expecting that the Publisher under test doesn't terminate but rather times out after the provided Duration. A timeout implies a cancellation of the source.

This is a convenience method that calls StepVerifier.verify() in addition to expectTimeout(Duration). The later is equivalent to appending the timeout operator to the publisher and expecting a TimeoutException onError signal, while also triggering a wait to ensure unexpected signals are detected.

参数:

duration - the Duration for which no new event is expected

返回:

the actual Duration the verification took.

另请参阅:

expectTimeout(Duration), StepVerifier.verify()

verifyErrorSatisfies

java.time.Duration verifyErrorSatisfies(java.util.function.Consumer<java.lang.Throwable> assertionConsumer)

Trigger the verification, expecting an error as terminal event which gets asserted via assertion(s) provided as a Consumer. Any AssertionError thrown by the consumer has its message propagated through a new StepVerifier-specific AssertionError.

This is a convenience method that calls StepVerifier.verify() in addition to the expectation. Explicitly use the expect method and verification method separately if you need something more specific (like activating logging or changing the default timeout).

参数:

assertionConsumer - the consumer that applies assertion(s) on the next received error

返回:

the actual Duration the verification took.

另请参阅:

expectErrorSatisfies(Consumer), StepVerifier.verify(), Subscriber.onError(Throwable)

verifyComplete

java.time.Duration verifyComplete()

Trigger the verification, expecting a completion signal as terminal event.

This is a convenience method that calls StepVerifier.verify() in addition to the expectation. Explicitly use the expect method and verification method separately if you need something more specific (like activating logging or changing the default timeout).

返回:

the actual Duration the verification took.

另请参阅:

expectComplete(), StepVerifier.verify(), Subscriber.onComplete()