Package io.servicetalk.concurrent.api.test

Interface PublisherLastStep

All Known Subinterfaces:

PublisherFirstStep<T>, PublisherStep<T>

public interface PublisherLastStep

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

Method Summary

Modifier and Type	Method	Description
StepVerifier	expectComplete()	Declare an expectation that PublisherSource.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.
StepVerifier	thenCancel()	Manually invoke Cancellable.cancel() on the PublisherSource.Subscription from PublisherSource.Subscriber.onSubscribe(Subscription).

Method Detail

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 PublisherSource.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 PublisherSource.Subscription from PublisherSource.Subscriber.onSubscribe(Subscription).

Returns:

An object which allows to verify all expectations.