Package org.reactivestreams
package org.reactivestreams
-
ClassDescriptionBridge between Reactive Streams API and the Java 9
FlowAPI.Processor<T,R> AProcessorrepresents a processing stage—which is both aSubscriberand aPublisherand obeys the contracts of both.Publisher<T>APublisheris 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 ofSubscribertoPublisher.subscribe(Subscriber).