Interface CompletableLastStep
-
- All Known Subinterfaces:
CompletableFirstStep
public interface CompletableLastStep
Provides the ability to express expectations for the terminal signals (e.g.onComplete
oronError
) of aCompletableSource.Subscriber
.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description StepVerifier
expectComplete()
Declare an expectation thatCompletableSource.Subscriber.onComplete()
onComplete} will be the next signal.StepVerifier
expectError()
Declare an expectation thatonError
will be the next signal.StepVerifier
expectError(java.lang.Class<? extends java.lang.Throwable> errorClass)
Declare an expectation thatonError
will be the next signal and it will be of typeerrorClass
.StepVerifier
expectErrorConsumed(java.util.function.Consumer<java.lang.Throwable> errorConsumer)
Declare an expectation thatonError
will be the next signal and evaluate it witherrorConsumer
.StepVerifier
expectErrorMatches(java.util.function.Predicate<java.lang.Throwable> errorPredicate)
Declare an expectation thatonError
will be the next signal and evaluate it witherrorPredicate
.CompletableLastStep
expectNoSignals(java.time.Duration duration)
Expect no signals induration
time.CompletableLastStep
then(java.lang.Runnable r)
InvokeRunnable.run()
on the thread which invokesStepVerifier.verify()
.CompletableLastStep
thenAwait(java.time.Duration duration)
Wait for a time delay ofduration
on the thread which invokesStepVerifier.verify()
.StepVerifier
thenCancel()
Manually invokeCancellable.cancel()
on theCancellable
fromCompletableSource.Subscriber.onSubscribe(Cancellable)
.
-
-
-
Method Detail
-
expectNoSignals
CompletableLastStep expectNoSignals(java.time.Duration duration)
Expect no signals induration
time.- Parameters:
duration
- The amount of time to assert that no signals are received.- Returns:
- An object which allows for subsequent expectations to be defined.
-
expectError
StepVerifier expectError()
Declare an expectation thatonError
will be the next signal.- Returns:
- An object which allows to verify all expectations.
-
expectErrorMatches
StepVerifier expectErrorMatches(java.util.function.Predicate<java.lang.Throwable> errorPredicate)
Declare an expectation thatonError
will be the next signal and evaluate it witherrorPredicate
.- Parameters:
errorPredicate
- Will be invoked whenonError
is called and will raise aAssertionError
if the predicate returnsfalse
.- Returns:
- An object which allows to verify all expectations.
-
expectError
StepVerifier expectError(java.lang.Class<? extends java.lang.Throwable> errorClass)
Declare an expectation thatonError
will be the next signal and it will be of typeerrorClass
.- Parameters:
errorClass
- The type of error which is expected.- Returns:
- An object which allows to verify all expectations.
-
expectErrorConsumed
StepVerifier expectErrorConsumed(java.util.function.Consumer<java.lang.Throwable> errorConsumer)
Declare an expectation thatonError
will be the next signal and evaluate it witherrorConsumer
.- Parameters:
errorConsumer
- Will be invoked whenonError
is called.- Returns:
- An object which allows to verify all expectations.
-
expectComplete
StepVerifier expectComplete()
Declare an expectation thatCompletableSource.Subscriber.onComplete()
onComplete} will be the next signal.- Returns:
- An object which allows to verify all expectations.
-
thenCancel
StepVerifier thenCancel()
Manually invokeCancellable.cancel()
on theCancellable
fromCompletableSource.Subscriber.onSubscribe(Cancellable)
.- Returns:
- An object which allows to verify all expectations.
-
then
CompletableLastStep then(java.lang.Runnable r)
InvokeRunnable.run()
on the thread which invokesStepVerifier.verify()
.- Parameters:
r
- theRunnable
to invoke.- Returns:
- An object which allows for subsequent expectations to be defined.
-
thenAwait
CompletableLastStep thenAwait(java.time.Duration duration)
Wait for a time delay ofduration
on the thread which invokesStepVerifier.verify()
.- Parameters:
duration
- the duration to wait for.- Returns:
- An object which allows for subsequent expectations to be defined.
-
-