Package io.servicetalk.concurrent.api.test

Interface PublisherFirstStep<T>

Type Parameters:

T - The type of PublisherSource.Subscriber.

All Superinterfaces:

PublisherLastStep, PublisherStep<T>

public interface PublisherFirstStep<T>
extends PublisherStep<T>

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

Method Summary

Modifier and Type	Method	Description
PublisherStep<T>	expectSubscription()	Declare an expectation that PublisherSource.Subscriber.onSubscribe(Subscription) is the next signal.
PublisherStep<T>	expectSubscriptionConsumed(Consumer<? super PublisherSource.Subscription> consumer)	Declare an expectation that can be asserted when the PublisherSource.Subscriber.onSubscribe(Subscription) method is called.

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

expectComplete, expectError, expectError, expectErrorConsumed, expectErrorMatches, thenCancel

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

expectNext, expectNext, expectNext, expectNext, expectNextConsumed, expectNextCount, expectNextCount, expectNextMatches, expectNextSequence, expectNoSignals, then, thenAwait, thenRequest

Method Details

expectSubscription

PublisherStep<T> expectSubscription()

Declare an expectation that PublisherSource.Subscriber.onSubscribe(Subscription) is the next signal.

Returns:

An object which allows for subsequent expectations to be defined.

expectSubscriptionConsumed

PublisherStep<T> expectSubscriptionConsumed(Consumer<? super PublisherSource.Subscription> consumer)

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

Parameters:

consumer - Consumes the PublisherSource.Subscription from PublisherSource.Subscriber.onSubscribe(Subscription).

Returns:

An object which allows for subsequent expectations to be defined.