Interface PublisherFirstStep<T>
- Type Parameters:
T
- The type ofPublisherSource.Subscriber
.
- All Superinterfaces:
PublisherLastStep
,PublisherStep<T>
Provides the ability to express expectations for the first step in a
Subscriber
's lifecycle.-
Method Summary
Modifier and TypeMethodDescriptionDeclare an expectation thatPublisherSource.Subscriber.onSubscribe(Subscription)
is the next signal.expectSubscriptionConsumed
(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 Details
-
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(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.
-