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.SubscriptionfromPublisherSource.Subscriber.onSubscribe(Subscription).- Returns:
- An object which allows for subsequent expectations to be defined.
-
-