Uses of Package
org.reactivestreams
Packages that use org.reactivestreams
Package
Description
-
Classes in org.reactivestreams used by org.reactivestreamsClassDescriptionA
Processorrepresents a processing stage—which is both aSubscriberand aPublisherand obeys the contracts of both.APublisheris a provider of a potentially unbounded number of sequenced elements, publishing them according to the demand received from itsSubscriber(s).Will receive call toSubscriber.onSubscribe(Subscription)once after passing an instance ofSubscribertoPublisher.subscribe(Subscriber). -
Classes in org.reactivestreams used by org.reactivestreams.example.unicastClassDescriptionA
Publisheris a provider of a potentially unbounded number of sequenced elements, publishing them according to the demand received from itsSubscriber(s).Will receive call toSubscriber.onSubscribe(Subscription)once after passing an instance ofSubscribertoPublisher.subscribe(Subscriber). -
Classes in org.reactivestreams used by org.reactivestreams.tckClassDescriptionA
Processorrepresents a processing stage—which is both aSubscriberand aPublisherand obeys the contracts of both.APublisheris a provider of a potentially unbounded number of sequenced elements, publishing them according to the demand received from itsSubscriber(s).Will receive call toSubscriber.onSubscribe(Subscription)once after passing an instance ofSubscribertoPublisher.subscribe(Subscriber). -
Classes in org.reactivestreams used by org.reactivestreams.tck.flowClassDescriptionA
Processorrepresents a processing stage—which is both aSubscriberand aPublisherand obeys the contracts of both.APublisheris a provider of a potentially unbounded number of sequenced elements, publishing them according to the demand received from itsSubscriber(s).Will receive call toSubscriber.onSubscribe(Subscription)once after passing an instance ofSubscribertoPublisher.subscribe(Subscriber). -
Classes in org.reactivestreams used by org.reactivestreams.tck.flow.supportClassDescriptionA
Publisheris a provider of a potentially unbounded number of sequenced elements, publishing them according to the demand received from itsSubscriber(s).