Package io.servicetalk.concurrent.api.test

Interface SingleLastStep<T>

Type Parameters:

T - The type of SingleSource.Subscriber.

All Known Subinterfaces:

SingleFirstStep<T>

public interface SingleLastStep<T>

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

Method Summary

Modifier and Type	Method	Description
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.
SingleLastStep<T>	expectNoSignals(java.time.Duration duration)	Expect no signals in duration time.
StepVerifier	expectSuccess()	Declare an expectation that onSuccess will be the next signal.
StepVerifier	expectSuccess(T onSuccess)	Declare an expectation that onSuccess will be the next signal.
StepVerifier	expectSuccessConsumed(java.util.function.Consumer<? super T> onSuccessConsumer)	Declare an expectation that onSuccess will be the next signal and verify it with onSuccessConsumer.
StepVerifier	expectSuccessMatches(java.util.function.Predicate<? super T> onSuccessPredicate)	Declare an expectation that onSuccess will be the next signal and verify it with onSuccessPredicate.
SingleLastStep<T>	then(java.lang.Runnable r)	Invoke Runnable.run() on the thread which invokes StepVerifier.verify().
SingleLastStep<T>	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 SingleSource.Subscriber.onSubscribe(Cancellable).

Method Detail

expectNoSignals

SingleLastStep<T> 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.

expectSuccess

StepVerifier expectSuccess()

Declare an expectation that onSuccess will be the next signal.

Returns:

An object which allows to verify all expectations.

expectSuccess

StepVerifier expectSuccess(@Nullable
                           T onSuccess)

Declare an expectation that onSuccess will be the next signal.

Parameters:

onSuccess - The expected value of onSuccess.

Returns:

An object which allows to verify all expectations.

expectSuccessMatches

StepVerifier expectSuccessMatches(java.util.function.Predicate<? super T> onSuccessPredicate)

Declare an expectation that onSuccess will be the next signal and verify it with onSuccessPredicate.

Parameters:

onSuccessPredicate - Used to verify onSuccess.

Returns:

An object which allows to verify all expectations.

expectSuccessConsumed

StepVerifier expectSuccessConsumed(java.util.function.Consumer<? super T> onSuccessConsumer)

Declare an expectation that onSuccess will be the next signal and verify it with onSuccessConsumer.

Parameters:

onSuccessConsumer - Used to verify onSuccess.

Returns:

An object which allows to verify all expectations.

thenCancel

StepVerifier thenCancel()

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

Returns:

An object which allows to verify all expectations.

then

SingleLastStep<T> 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

SingleLastStep<T> 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.