Package io.servicetalk.concurrent.api

Class SourceAdapters

java.lang.Object

io.servicetalk.concurrent.api.SourceAdapters

public final class SourceAdapters
extends Object

A set of adapter methods to convert an asynchronous source in this module to a corresponding source in io.servicetalk.concurrent module.

Method Summary

Modifier and Type	Method	Description
static Completable	fromSource(CompletableSource source)	Converts the provided CompletableSource into a Completable.
static <T> Publisher<T>	fromSource(PublisherSource<T> source)	Converts the provided PublisherSource into a Publisher.
static <T> Single<T>	fromSource(SingleSource<T> source)	Converts the provided SingleSource into a Single.
static CompletableSource	toSource(Completable completable)	Converts the provided Completable into a CompletableSource.
static <T> PublisherSource<T>	toSource(Publisher<T> publisher)	Converts the provided Publisher into a PublisherSource.
static <T> SingleSource<T>	toSource(Single<T> single)	Converts the provided Single into a SingleSource.

Methods inherited from class java.lang.Object

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

Method Details

toSource

public static <T> PublisherSource<T> toSource(Publisher<T> publisher)

Converts the provided Publisher into a PublisherSource.

Type Parameters:

T - Type of items emitted from the publisher and the returned PublisherSource.

Parameters:

publisher - Publisher to convert to a PublisherSource.

Returns:

A PublisherSource representation of the passed Publisher.

toSource

public static <T> SingleSource<T> toSource(Single<T> single)

Converts the provided Single into a SingleSource.

Type Parameters:

T - Type of items emitted from the single and the returned SingleSource.

Parameters:

single - Single to convert to a SingleSource.

Returns:

A SingleSource representation of the passed Single.

toSource

public static CompletableSource toSource(Completable completable)

Converts the provided Completable into a CompletableSource.

Parameters:

completable - Completable to convert to a CompletableSource.

Returns:

A CompletableSource representation of the passed Completable.

fromSource

public static <T> Publisher<T> fromSource(PublisherSource<T> source)

Converts the provided PublisherSource into a Publisher.

Type Parameters:

T - Type of items emitted from the source and the returned Publisher.

Parameters:

source - PublisherSource to convert to a Publisher.

Returns:

A Publisher representation of the passed PublisherSource.

fromSource

public static <T> Single<T> fromSource(SingleSource<T> source)

Converts the provided SingleSource into a Single.

Type Parameters:

T - Type of items emitted from the source and the returned Single.

Parameters:

source - SingleSource to convert to a Single.

Returns:

A Single representation of the passed SingleSource.

fromSource

public static Completable fromSource(CompletableSource source)

Converts the provided CompletableSource into a Completable.

Parameters:

source - CompletableSource to convert to a Completable.

Returns:

A Completable representation of the passed CompletableSource.