Interface PublisherFirstStep<T>
-
- Type Parameters:
T
- The type ofPublisherSource.Subscriber
.
- All Superinterfaces:
PublisherLastStep
,PublisherStep<T>
public interface PublisherFirstStep<T> extends PublisherStep<T>
Provides the ability to express expectations for the first step in aSubscriber
's lifecycle.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description PublisherStep<T>
expectSubscription()
Declare an expectation thatPublisherSource.Subscriber.onSubscribe(Subscription)
is the next signal.PublisherStep<T>
expectSubscriptionConsumed(java.util.function.Consumer<? super PublisherSource.Subscription> consumer)
Declare an expectation that can be asserted when thePublisherSource.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 Detail
-
expectSubscription
PublisherStep<T> expectSubscription()
Declare an expectation thatPublisherSource.Subscriber.onSubscribe(Subscription)
is the next signal.- Returns:
- An object which allows for subsequent expectations to be defined.
-
expectSubscriptionConsumed
PublisherStep<T> expectSubscriptionConsumed(java.util.function.Consumer<? super PublisherSource.Subscription> consumer)
Declare an expectation that can be asserted when thePublisherSource.Subscriber.onSubscribe(Subscription)
method is called.- Parameters:
consumer
- Consumes thePublisherSource.Subscription
fromPublisherSource.Subscriber.onSubscribe(Subscription)
.- Returns:
- An object which allows for subsequent expectations to be defined.
-
-