FlowAdapters |
Bridge between Reactive Streams API and the Java 9 Flow API.
|
FlowAdapters.FlowPublisherFromReactive<T> |
Flow Publisher that wraps a Reactive Streams Publisher.
|
FlowAdapters.FlowToReactiveProcessor<T,U> |
Wraps a Reactive Streams Processor and forwards methods of the Flow Processor to it.
|
FlowAdapters.FlowToReactiveSubscriber<T> |
Wraps a Reactive Streams Subscriber and forwards methods of the Flow Subscriber to it.
|
FlowAdapters.FlowToReactiveSubscription |
Wraps a Reactive Streams Subscription and converts the calls to a Flow Subscription.
|
FlowAdapters.ReactivePublisherFromFlow<T> |
Reactive Streams Publisher that wraps a Flow Publisher.
|
FlowAdapters.ReactiveToFlowProcessor<T,U> |
Wraps a Flow Processor and forwards methods of the Reactive Streams Processor to it.
|
FlowAdapters.ReactiveToFlowSubscriber<T> |
Wraps a Flow Subscriber and forwards methods of the Reactive Streams Subscriber to it.
|
FlowAdapters.ReactiveToFlowSubscription |
Wraps a Flow Subscription and converts the calls to a Reactive Streams Subscription.
|