Top Description Inners Constructors Methods

org.reactivestreams

public final Class FlowAdapters

Class Inheritance

extends Object

java.lang.Object
org.reactivestreams.FlowAdapters

Imports

java.util.concurrent.Flow

Bridge between Reactive Streams API and the Java 9 java.util.concurrent.Flow API.

Nested and Inner Type Summary

Modifier and Type	Class and Description
pack-priv static class	FlowAdapters.FlowPublisherFromReactive< the element type T> Flow Publisher that wraps a Reactive Streams Publisher.
pack-priv static class	FlowAdapters.FlowToReactiveProcessor< the input type T, the output type U> Wraps a Reactive Streams Processor and forwards methods of the Flow Processor to it.
pack-priv static class	FlowAdapters.FlowToReactiveSubscriber< the element type T> Wraps a Reactive Streams Subscriber and forwards methods of the Flow Subscriber to it.
pack-priv static class	FlowAdapters.FlowToReactiveSubscription Wraps a Reactive Streams Subscription and converts the calls to a Flow Subscription.
pack-priv static class	FlowAdapters.ReactivePublisherFromFlow< the element type T> Reactive Streams Publisher that wraps a Flow Publisher.
pack-priv static class	FlowAdapters.ReactiveToFlowProcessor< the input type T, the output type U> Wraps a Flow Processor and forwards methods of the Reactive Streams Processor to it.
pack-priv static class	FlowAdapters.ReactiveToFlowSubscriber< the element type T> Wraps a Flow Subscriber and forwards methods of the Reactive Streams Subscriber to it.
pack-priv static class	FlowAdapters.ReactiveToFlowSubscription Wraps a Flow Subscription and converts the calls to a Reactive Streams Subscription.

Constructor Summary

Access	Constructor and Description
private	FlowAdapters() Utility class.

Method Summary

Modifier and Type	Method and Description
public static < the input value type T, the output value type U> Flow.Processor<T, U>	Returns: the equivalent Flow Processor toFlowProcessor(Processor<? super T, ? extends U> the source Reactive Streams Processor to convert reactiveStreamsProcessor) Converts a Reactive Streams Processor into a Flow Processor.
public static < the element type T> Flow.Publisher<T>	Returns: the equivalent Flow Publisher toFlowPublisher(Publisher<? extends T> the source Reactive Streams Publisher to convert reactiveStreamsPublisher) Converts a Reactive Streams Publisher into a Flow Publisher.
public static < the input and output value type T> Flow.Subscriber<T>	Returns: the equivalent Flow Subscriber toFlowSubscriber(Subscriber<T> the Reactive Streams Subscriber instance to convert reactiveStreamsSubscriber) Converts a Reactive Streams Subscriber into a Flow Subscriber.
public static < the input value type T, the output value type U> Processor<T, U>	Returns: the equivalent Reactive Streams Processor toProcessor(Flow.Processor<? super T, ? extends U> the source Flow Processor to convert flowProcessor) Converts a Flow Processor into a Reactive Streams Processor.
public static < the element type T> Publisher<T>	Returns: the equivalent Reactive Streams Publisher toPublisher(Flow.Publisher<? extends T> the source Flow Publisher to convert flowPublisher) Converts a Flow Publisher into a Reactive Streams Publisher.
public static < the input and output value type T> Subscriber<T>	Returns: the equivalent Reactive Streams Subscriber toSubscriber(Flow.Subscriber<T> the Flow Subscriber instance to convert flowSubscriber) Converts a Flow Subscriber into a Reactive Streams Subscriber.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait