Package io.servicetalk.concurrent.api.test

Interface SingleFirstStep<T>

Type Parameters:

T - The type of SingleSource.Subscriber.

All Superinterfaces:

SingleLastStep<T>

public interface SingleFirstStep<T>
extends SingleLastStep<T>

Provides the ability to express expectations for the first step in a Subscriber's lifecycle.

Method Summary

Modifier and Type	Method	Description
SingleLastStep<T>	expectCancellable()	Declare an expectation that SingleSource.Subscriber.onSubscribe(Cancellable) is the next signal.
SingleLastStep<T>	expectCancellableConsumed(Consumer<? super Cancellable> consumer)	Declare an expectation that can be asserted when the SingleSource.Subscriber.onSubscribe(Cancellable) method is called.

Methods inherited from interface io.servicetalk.concurrent.api.test.SingleLastStep

expectError, expectError, expectErrorConsumed, expectErrorMatches, expectNoSignals, expectSuccess, expectSuccess, expectSuccessConsumed, expectSuccessMatches, then, thenAwait, thenCancel

Method Details

expectCancellable

SingleLastStep<T> expectCancellable()

Declare an expectation that SingleSource.Subscriber.onSubscribe(Cancellable) is the next signal.

Returns:

An object which allows for subsequent expectations to be defined.

expectCancellableConsumed

SingleLastStep<T> expectCancellableConsumed(Consumer<? super Cancellable> consumer)

Declare an expectation that can be asserted when the SingleSource.Subscriber.onSubscribe(Cancellable) method is called.

Parameters:

consumer - Consumes the Cancellable from SingleSource.Subscriber.onSubscribe(Cancellable).

Returns:

An object which allows for subsequent expectations to be defined.