Package io.servicetalk.concurrent.api.test

Class Verifiers

java.lang.Object

io.servicetalk.concurrent.api.test.Verifiers

public final class Verifiers
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	stepVerifier(Completable source)	Create a new CompletableFirstStep.
static <T> PublisherFirstStep<T>	stepVerifier(Publisher<T> source)	Create a new PublisherFirstStep.
static <T> SingleFirstStep<T>	stepVerifier(Single<T> source)	Create a new SingleFirstStep.
static CompletableFirstStep	stepVerifierForSource(CompletableSource source)	Create a new CompletableFirstStep.
static <T> PublisherFirstStep<T>	stepVerifierForSource(PublisherSource<T> source)	Create a new PublisherFirstStep.
static <T> SingleFirstStep<T>	stepVerifierForSource(SingleSource<T> source)	Create a new SingleFirstStep.

Methods inherited from class java.lang.Object

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

Method Detail

stepVerifier

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

Create 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).

stepVerifierForSource

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

Create 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).

stepVerifier

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

Create 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).

stepVerifierForSource

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

Create 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).

stepVerifier

public static CompletableFirstStep stepVerifier(Completable source)

Create a new CompletableFirstStep.

Parameters:

source - The Completable to verify.

Returns:

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

stepVerifierForSource

public static CompletableFirstStep stepVerifierForSource(CompletableSource source)

Create a new CompletableFirstStep.

Parameters:

source - The CompletableSource to verify.

Returns:

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