Package org.reactivestreams
-
Interface Summary Interface Description 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)
.Subscription -
Class Summary Class Description FlowAdapters Bridge between Reactive Streams API and the Java 9Flow
API.