Package org.reactivestreams
package org.reactivestreams
-
ClassDescriptionBridge between Reactive Streams API and the Java 9
Flow
API.Flow Publisher that wraps a Reactive Streams Publisher.Wraps a Reactive Streams Processor and forwards methods of the Flow Processor to it.Wraps a Reactive Streams Subscriber and forwards methods of the Flow Subscriber to it.Wraps a Reactive Streams Subscription and converts the calls to a Flow Subscription.Reactive Streams Publisher that wraps a Flow Publisher.Wraps a Flow Processor and forwards methods of the Reactive Streams Processor to it.Wraps a Flow Subscriber and forwards methods of the Reactive Streams Subscriber to it.Wraps a Flow Subscription and converts the calls to a Reactive Streams Subscription.Processor<T,R> AProcessor
represents a processing stage—which is both aSubscriber
and aPublisher
and obeys the contracts of both.Publisher<T>APublisher
is a provider of a potentially unbounded number of sequenced elements, publishing them according to the demand received from itsSubscriber
(s).Subscriber<T>Will receive call toSubscriber.onSubscribe(Subscription)
once after passing an instance ofSubscriber
toPublisher.subscribe(Subscriber)
.