Package io.servicetalk.concurrent.api.test

Interface CompletableLastStep

All Known Subinterfaces:

CompletableFirstStep

public interface CompletableLastStep

Provides the ability to express expectations for the terminal signals (e.g. onComplete or onError) of a CompletableSource.Subscriber.

Method Summary

Modifier and Type	Method	Description
StepVerifier	expectComplete()	Declare an expectation that CompletableSource.Subscriber.onComplete() onComplete} will be the next signal.
StepVerifier	expectError()	Declare an expectation that onError will be the next signal.
StepVerifier	expectError(java.lang.Class<? extends java.lang.Throwable> errorClass)	Declare an expectation that onError will be the next signal and it will be of type errorClass.
StepVerifier	expectErrorConsumed(java.util.function.Consumer<java.lang.Throwable> errorConsumer)	Declare an expectation that onError will be the next signal and evaluate it with errorConsumer.
StepVerifier	expectErrorMatches(java.util.function.Predicate<java.lang.Throwable> errorPredicate)	Declare an expectation that onError will be the next signal and evaluate it with errorPredicate.
CompletableLastStep	expectNoSignals(java.time.Duration duration)	Expect no signals in duration time.
CompletableLastStep	then(java.lang.Runnable r)	Invoke Runnable.run() on the thread which invokes StepVerifier.verify().
CompletableLastStep	thenAwait(java.time.Duration duration)	Wait for a time delay of duration on the thread which invokes StepVerifier.verify().
StepVerifier	thenCancel()	Manually invoke Cancellable.cancel() on the Cancellable from CompletableSource.Subscriber.onSubscribe(Cancellable).

Method Detail

expectNoSignals

CompletableLastStep expectNoSignals(java.time.Duration duration)

Expect no signals in duration 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 that onError 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 that onError will be the next signal and evaluate it with errorPredicate.

Parameters:

errorPredicate - Will be invoked when onError is called and will raise a AssertionError if the predicate returns false.

Returns:

An object which allows to verify all expectations.

expectError

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

Declare an expectation that onError will be the next signal and it will be of type errorClass.

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 that onError will be the next signal and evaluate it with errorConsumer.

Parameters:

errorConsumer - Will be invoked when onError is called.

Returns:

An object which allows to verify all expectations.

expectComplete

StepVerifier expectComplete()

Declare an expectation that CompletableSource.Subscriber.onComplete() onComplete} will be the next signal.

Returns:

An object which allows to verify all expectations.

thenCancel

StepVerifier thenCancel()

Manually invoke Cancellable.cancel() on the Cancellable from CompletableSource.Subscriber.onSubscribe(Cancellable).

Returns:

An object which allows to verify all expectations.

then

CompletableLastStep then(java.lang.Runnable r)

Invoke Runnable.run() on the thread which invokes StepVerifier.verify().

Parameters:

r - the Runnable 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 of duration on the thread which invokes StepVerifier.verify().

Parameters:

duration - the duration to wait for.

Returns:

An object which allows for subsequent expectations to be defined.