Class FlowAdapters

java.lang.Object

org.reactivestreams.FlowAdapters

public final class FlowAdapters
extends Object

Bridge between Reactive Streams API and the Java 9 Flow API.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static final class	FlowAdapters.FlowPublisherFromReactive<T>	Flow Publisher that wraps a Reactive Streams Publisher.
(package private) static final class	FlowAdapters.FlowToReactiveProcessor<T,U>	Wraps a Reactive Streams Processor and forwards methods of the Flow Processor to it.
(package private) static final class	FlowAdapters.FlowToReactiveSubscriber<T>	Wraps a Reactive Streams Subscriber and forwards methods of the Flow Subscriber to it.
(package private) static final class	FlowAdapters.FlowToReactiveSubscription	Wraps a Reactive Streams Subscription and converts the calls to a Flow Subscription.
(package private) static final class	FlowAdapters.ReactivePublisherFromFlow<T>	Reactive Streams Publisher that wraps a Flow Publisher.
(package private) static final class	FlowAdapters.ReactiveToFlowProcessor<T,U>	Wraps a Flow Processor and forwards methods of the Reactive Streams Processor to it.
(package private) static final class	FlowAdapters.ReactiveToFlowSubscriber<T>	Wraps a Flow Subscriber and forwards methods of the Reactive Streams Subscriber to it.
(package private) static final class	FlowAdapters.ReactiveToFlowSubscription	Wraps a Flow Subscription and converts the calls to a Reactive Streams Subscription.

Constructor Summary

Constructors

Modifier	Constructor	Description
private	FlowAdapters()	Utility class.

Method Summary

Modifier and Type	Method	Description
static <T,U> Flow.Processor<T,U>	toFlowProcessor(Processor<? super T, ? extends U> reactiveStreamsProcessor)	Converts a Reactive Streams Processor into a Flow Processor.
static <T> Flow.Publisher<T>	toFlowPublisher(Publisher<? extends T> reactiveStreamsPublisher)	Converts a Reactive Streams Publisher into a Flow Publisher.
static <T> Flow.Subscriber<T>	toFlowSubscriber(Subscriber<T> reactiveStreamsSubscriber)	Converts a Reactive Streams Subscriber into a Flow Subscriber.
static <T,U> Processor<T,U>	toProcessor(Flow.Processor<? super T, ? extends U> flowProcessor)	Converts a Flow Processor into a Reactive Streams Processor.
static <T> Publisher<T>	toPublisher(Flow.Publisher<? extends T> flowPublisher)	Converts a Flow Publisher into a Reactive Streams Publisher.
static <T> Subscriber<T>	toSubscriber(Flow.Subscriber<T> flowSubscriber)	Converts a Flow Subscriber into a Reactive Streams Subscriber.

Methods inherited from class Object

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

Constructor Details

FlowAdapters

private FlowAdapters()

Utility class.

Method Details

toPublisher

public static <T> Publisher<T> toPublisher(Flow.Publisher<? extends T> flowPublisher)

Converts a Flow Publisher into a Reactive Streams Publisher.

Type Parameters:

T - the element type

Parameters:

flowPublisher - the source Flow Publisher to convert

Returns:

the equivalent Reactive Streams Publisher

toFlowPublisher

public static <T> Flow.Publisher<T> toFlowPublisher(Publisher<? extends T> reactiveStreamsPublisher)

Converts a Reactive Streams Publisher into a Flow Publisher.

Type Parameters:

T - the element type

Parameters:

reactiveStreamsPublisher - the source Reactive Streams Publisher to convert

Returns:

the equivalent Flow Publisher

toProcessor

public static <T,U> Processor<T,U> toProcessor(Flow.Processor<? super T, ? extends U> flowProcessor)

Converts a Flow Processor into a Reactive Streams Processor.

Type Parameters:

T - the input value type

U - the output value type

Parameters:

flowProcessor - the source Flow Processor to convert

Returns:

the equivalent Reactive Streams Processor

toFlowProcessor

public static <T,U> Flow.Processor<T,U> toFlowProcessor(Processor<? super T, ? extends U> reactiveStreamsProcessor)

Converts a Reactive Streams Processor into a Flow Processor.

Type Parameters:

T - the input value type

U - the output value type

Parameters:

reactiveStreamsProcessor - the source Reactive Streams Processor to convert

Returns:

the equivalent Flow Processor

toFlowSubscriber

public static <T> Flow.Subscriber<T> toFlowSubscriber(Subscriber<T> reactiveStreamsSubscriber)

Converts a Reactive Streams Subscriber into a Flow Subscriber.

Type Parameters:

T - the input and output value type

Parameters:

reactiveStreamsSubscriber - the Reactive Streams Subscriber instance to convert

Returns:

the equivalent Flow Subscriber

toSubscriber

public static <T> Subscriber<T> toSubscriber(Flow.Subscriber<T> flowSubscriber)

Converts a Flow Subscriber into a Reactive Streams Subscriber.

Type Parameters:

T - the input and output value type

Parameters:

flowSubscriber - the Flow Subscriber instance to convert

Returns:

the equivalent Reactive Streams Subscriber