io.servicetalk.concurrent.reactivestreams

Class ReactiveStreamsAdapters

java.lang.Object

io.servicetalk.concurrent.reactivestreams.ReactiveStreamsAdapters

public final class ReactiveStreamsAdapters
extends java.lang.Object

A set of adapter methods for converting to and from Reactive Streams APIs and ServiceTalk APIs.

Method Summary

Modifier and Type	Method and Description
static <T> Publisher<T>	fromReactiveStreamsPublisher(org.reactivestreams.Publisher<T> source) Converts the passed Publisher to a Reactive Streams Publisher.
static <T> org.reactivestreams.Publisher<T>	toReactiveStreamsPublisher(Publisher<T> publisher) Converts the passed Publisher to a Reactive Streams Publisher.
static <T> org.reactivestreams.Publisher<T>	toReactiveStreamsPublisher(PublisherSource<T> source) Converts the passed PublisherSource to a Reactive Streams Publisher.

Methods inherited from class java.lang.Object

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

Method Detail

fromReactiveStreamsPublisher

public static <T> Publisher<T> fromReactiveStreamsPublisher(org.reactivestreams.Publisher<T> source)

Converts the passed Publisher to a Reactive Streams Publisher.

Type Parameters:

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

Parameters:

source - Publisher to convert to a Publisher.

Returns:

A Publisher representation of the passed Publisher.

toReactiveStreamsPublisher

public static <T> org.reactivestreams.Publisher<T> toReactiveStreamsPublisher(Publisher<T> publisher)

Converts the passed Publisher to a Reactive Streams Publisher.

Type Parameters:

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

Parameters:

publisher - Publisher to convert to a Publisher.

Returns:

A Publisher representation of the passed Publisher.

toReactiveStreamsPublisher

public static <T> org.reactivestreams.Publisher<T> toReactiveStreamsPublisher(PublisherSource<T> source)

Converts the passed PublisherSource to a Reactive Streams 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.