Package io.servicetalk.concurrent.api.test

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 to StepVerifier test utility to verify each step in the lifecycle of asynchronous sources Publisher, Single, and Completable.

The steps are typically from the perspective of a PublisherSource.Subscriber's lifecycle.

Method Summary

Modifier and Type	Method	Description
static CompletableFirstStep	create(Completable source)	Creates a new CompletableFirstStep.
static <T> PublisherFirstStep<T>	create(Publisher<T> source)	Creates a new PublisherFirstStep.
static <T> SingleFirstStep<T>	create(Single<T> source)	Creates a new SingleFirstStep.
static CompletableFirstStep	createForSource(CompletableSource source)	Creates a new CompletableFirstStep.
static <T> PublisherFirstStep<T>	createForSource(PublisherSource<T> source)	Creates a new PublisherFirstStep.
static <T> SingleFirstStep<T>	createForSource(SingleSource<T> source)	Creates a new SingleFirstStep.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

create

public static <T> PublisherFirstStep<T> create(Publisher<T> source)

Creates a new PublisherFirstStep.

Type Parameters:

T - The type of Publisher.

Parameters:

source - The Publisher to verify.

Returns:

A PublisherFirstStep that can be used to verify source's signal emission(s).

createForSource

public static <T> PublisherFirstStep<T> createForSource(PublisherSource<T> source)

Creates a new PublisherFirstStep.

Type Parameters:

T - The type of PublisherSource.

Parameters:

source - The PublisherSource to verify.

Returns:

A PublisherFirstStep that can be used to verify source's signal emission(s).

create

public static <T> SingleFirstStep<T> create(Single<T> source)

Creates a new SingleFirstStep.

Type Parameters:

T - The type of Single.

Parameters:

source - The Single to verify.

Returns:

A SingleFirstStep that can be used to verify source's signal emission(s).

createForSource

public static <T> SingleFirstStep<T> createForSource(SingleSource<T> source)

Creates a new SingleFirstStep.

Type Parameters:

T - The type of SingleSource.

Parameters:

source - The SingleSource to verify.

Returns:

A SingleFirstStep that can be used to verify source's signal emission(s).

create

public static CompletableFirstStep create(Completable source)

Creates a new CompletableFirstStep.

Parameters:

source - The Completable to verify.

Returns:

A CompletableFirstStep that can be used to verify source's signal emission(s).

createForSource

public static CompletableFirstStep createForSource(CompletableSource source)

Creates a new CompletableFirstStep.

Parameters:

source - The CompletableSource to verify.

Returns:

A CompletableFirstStep that can be used to verify source's signal emission(s).