Package io.servicetalk.concurrent.api.test

Interface CompletableFirstStep

All Superinterfaces:

CompletableLastStep

public interface CompletableFirstStep
extends CompletableLastStep

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

Method Summary

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

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

expectComplete, expectError, expectError, expectErrorConsumed, expectErrorMatches, expectNoSignals, then, thenAwait, thenCancel

Method Details

expectCancellable

CompletableLastStep expectCancellable()

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

Returns:

An object which allows for subsequent expectations to be defined.

expectCancellableConsumed

CompletableLastStep expectCancellableConsumed(Consumer<? super Cancellable> consumer)

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

Parameters:

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

Returns:

An object which allows for subsequent expectations to be defined.