Uses of Package
org.reactivestreams
Packages that use org.reactivestreams
Package
Description
-
Classes in org.reactivestreams used by org.reactivestreamsClassDescriptionA
Processor
represents a processing stage—which is both aSubscriber
and aPublisher
and obeys the contracts of both.APublisher
is 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 ofSubscriber
toPublisher.subscribe(Subscriber)
. -
Classes in org.reactivestreams used by org.reactivestreams.example.unicastClassDescriptionA
Publisher
is 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 ofSubscriber
toPublisher.subscribe(Subscriber)
. -
Classes in org.reactivestreams used by org.reactivestreams.tckClassDescriptionA
Processor
represents a processing stage—which is both aSubscriber
and aPublisher
and obeys the contracts of both.APublisher
is 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 ofSubscriber
toPublisher.subscribe(Subscriber)
. -
Classes in org.reactivestreams used by org.reactivestreams.tck.flowClassDescriptionA
Processor
represents a processing stage—which is both aSubscriber
and aPublisher
and obeys the contracts of both.APublisher
is 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 ofSubscriber
toPublisher.subscribe(Subscriber)
. -
Classes in org.reactivestreams used by org.reactivestreams.tck.flow.supportClassDescriptionA
Publisher
is a provider of a potentially unbounded number of sequenced elements, publishing them according to the demand received from itsSubscriber
(s).