Uses of Package
io.reactivex.rxjava3.internal.subscriptions
-
Packages that use io.reactivex.rxjava3.internal.subscriptions Package Description io.reactivex.rxjava3.internal.jdk8 io.reactivex.rxjava3.internal.operators.flowable io.reactivex.rxjava3.internal.operators.maybe io.reactivex.rxjava3.internal.operators.parallel io.reactivex.rxjava3.internal.operators.single io.reactivex.rxjava3.internal.subscribers io.reactivex.rxjava3.internal.subscriptions io.reactivex.rxjava3.processors Classes representing so-called hot backpressure-aware sources, aka processors, that implement theFlowableProcessor
class, the Reactive StreamsProcessor
interface to allow forms of multicasting events to one or more subscribers as well as consuming another Reactive StreamsPublisher
. -
Classes in io.reactivex.rxjava3.internal.subscriptions used by io.reactivex.rxjava3.internal.jdk8 Class Description BasicIntQueueSubscription Base class extending AtomicInteger (wip or request accounting) and QueueSubscription (fusion).DeferredScalarSubscription A subscription that signals a single value eventually. -
Classes in io.reactivex.rxjava3.internal.subscriptions used by io.reactivex.rxjava3.internal.operators.flowable Class Description BasicIntQueueSubscription Base class extending AtomicInteger (wip or request accounting) and QueueSubscription (fusion).BasicQueueSubscription Base class extending AtomicLong (wip or request accounting) and QueueSubscription (fusion).DeferredScalarSubscription A subscription that signals a single value eventually.SubscriptionArbiter Arbitrates requests and cancellation between Subscriptions. -
Classes in io.reactivex.rxjava3.internal.subscriptions used by io.reactivex.rxjava3.internal.operators.maybe Class Description BasicIntQueueSubscription Base class extending AtomicInteger (wip or request accounting) and QueueSubscription (fusion).DeferredScalarSubscription A subscription that signals a single value eventually. -
Classes in io.reactivex.rxjava3.internal.subscriptions used by io.reactivex.rxjava3.internal.operators.parallel Class Description BasicIntQueueSubscription Base class extending AtomicInteger (wip or request accounting) and QueueSubscription (fusion).DeferredScalarSubscription A subscription that signals a single value eventually. -
Classes in io.reactivex.rxjava3.internal.subscriptions used by io.reactivex.rxjava3.internal.operators.single Class Description BasicIntQueueSubscription Base class extending AtomicInteger (wip or request accounting) and QueueSubscription (fusion).DeferredScalarSubscription A subscription that signals a single value eventually. -
Classes in io.reactivex.rxjava3.internal.subscriptions used by io.reactivex.rxjava3.internal.subscribers Class Description BasicIntQueueSubscription Base class extending AtomicInteger (wip or request accounting) and QueueSubscription (fusion).DeferredScalarSubscription A subscription that signals a single value eventually. -
Classes in io.reactivex.rxjava3.internal.subscriptions used by io.reactivex.rxjava3.internal.subscriptions Class Description BasicIntQueueSubscription Base class extending AtomicInteger (wip or request accounting) and QueueSubscription (fusion).EmptySubscription An empty subscription that does nothing other than validates the request amount.SubscriptionHelper Utility methods to validate Subscriptions in the various onSubscribe calls. -
Classes in io.reactivex.rxjava3.internal.subscriptions used by io.reactivex.rxjava3.processors Class Description BasicIntQueueSubscription Base class extending AtomicInteger (wip or request accounting) and QueueSubscription (fusion).DeferredScalarSubscription A subscription that signals a single value eventually.