Class StepVerifiers
- java.lang.Object
-
- io.servicetalk.concurrent.api.test.StepVerifiers
-
public final class StepVerifiers extends java.lang.Object
Factory for the first steps that lead toStepVerifier
test utility to verify each step in the lifecycle of asynchronous sourcesPublisher
,Single
, andCompletable
.The steps are typically from the perspective of a
PublisherSource.Subscriber
's lifecycle.
-
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static CompletableFirstStep
create(Completable source)
Creates a newCompletableFirstStep
.static <T> PublisherFirstStep<T>
create(Publisher<T> source)
Creates a newPublisherFirstStep
.static <T> SingleFirstStep<T>
create(Single<T> source)
Creates a newSingleFirstStep
.static CompletableFirstStep
createForSource(CompletableSource source)
Creates a newCompletableFirstStep
.static <T> PublisherFirstStep<T>
createForSource(PublisherSource<T> source)
Creates a newPublisherFirstStep
.static <T> SingleFirstStep<T>
createForSource(SingleSource<T> source)
Creates a newSingleFirstStep
.
-
-
-
Method Detail
-
create
public static <T> PublisherFirstStep<T> create(Publisher<T> source)
Creates a newPublisherFirstStep
.- Type Parameters:
T
- The type ofPublisher
.- Parameters:
source
- ThePublisher
to verify.- Returns:
- A
PublisherFirstStep
that can be used to verifysource
's signal emission(s).
-
createForSource
public static <T> PublisherFirstStep<T> createForSource(PublisherSource<T> source)
Creates a newPublisherFirstStep
.- Type Parameters:
T
- The type ofPublisherSource
.- Parameters:
source
- ThePublisherSource
to verify.- Returns:
- A
PublisherFirstStep
that can be used to verifysource
's signal emission(s).
-
create
public static <T> SingleFirstStep<T> create(Single<T> source)
Creates a newSingleFirstStep
.- Type Parameters:
T
- The type ofSingle
.- Parameters:
source
- TheSingle
to verify.- Returns:
- A
SingleFirstStep
that can be used to verifysource
's signal emission(s).
-
createForSource
public static <T> SingleFirstStep<T> createForSource(SingleSource<T> source)
Creates a newSingleFirstStep
.- Type Parameters:
T
- The type ofSingleSource
.- Parameters:
source
- TheSingleSource
to verify.- Returns:
- A
SingleFirstStep
that can be used to verifysource
's signal emission(s).
-
create
public static CompletableFirstStep create(Completable source)
Creates a newCompletableFirstStep
.- Parameters:
source
- TheCompletable
to verify.- Returns:
- A
CompletableFirstStep
that can be used to verifysource
's signal emission(s).
-
createForSource
public static CompletableFirstStep createForSource(CompletableSource source)
Creates a newCompletableFirstStep
.- Parameters:
source
- TheCompletableSource
to verify.- Returns:
- A
CompletableFirstStep
that can be used to verifysource
's signal emission(s).
-
-