Package org.reactivestreams

package org.reactivestreams

Related Packages

Package	Description
org.reactivestreams.tck

Class	Description
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.
Processor<T,R>	A Processor represents a processing stage—which is both a Subscriber and a Publisher and obeys the contracts of both.
Publisher<T>	A Publisher is a provider of a potentially unbounded number of sequenced elements, publishing them according to the demand received from its Subscriber(s).
Subscriber<T>	Will receive call to Subscriber.onSubscribe(Subscription) once after passing an instance of Subscriber to Publisher.subscribe(Subscriber).
Subscription	A Subscription represents a one-to-one lifecycle of a Subscriber subscribing to a Publisher.