Uses of Interface
io.reactivex.rxjava3.operators.QueueSubscription
Packages that use QueueSubscription
Package
Description
Base interfaces and types for supporting operator-fusion.
-
Uses of QueueSubscription in io.reactivex.rxjava3.internal.fuseable
Classes in io.reactivex.rxjava3.internal.fuseable that implement QueueSubscriptionModifier and TypeClassDescriptionclassRepresents an empty, async-onlyQueueFuseableinstance.final classRepresents an empty, async-onlyQueueFuseableinstance that tracks and exposes a canceled/disposed state. -
Uses of QueueSubscription in io.reactivex.rxjava3.internal.operators.flowable
Classes in io.reactivex.rxjava3.internal.operators.flowable that implement QueueSubscriptionModifier and TypeClassDescriptionstatic final class -
Uses of QueueSubscription in io.reactivex.rxjava3.internal.operators.observable
Classes in io.reactivex.rxjava3.internal.operators.observable that implement QueueSubscriptionModifier and TypeClassDescriptionstatic final class -
Uses of QueueSubscription in io.reactivex.rxjava3.internal.subscribers
Classes in io.reactivex.rxjava3.internal.subscribers that implement QueueSubscriptionModifier and TypeClassDescriptionclassBase class for a fuseable intermediate subscriber.classBase class for a fuseable intermediate subscriber.classA subscriber, extending a DeferredScalarSubscription, that is unbounded-in and can generate 0 or 1 resulting value.Fields in io.reactivex.rxjava3.internal.subscribers declared as QueueSubscriptionModifier and TypeFieldDescriptionprotected QueueSubscription<T> BasicFuseableConditionalSubscriber.qsThe upstream's QueueSubscription if not null.protected QueueSubscription<T> BasicFuseableSubscriber.qsThe upstream's QueueSubscription if not null. -
Uses of QueueSubscription in io.reactivex.rxjava3.internal.subscriptions
Classes in io.reactivex.rxjava3.internal.subscriptions that implement QueueSubscriptionModifier and TypeClassDescriptionclassBase class extending AtomicInteger (wip or request accounting) and QueueSubscription (fusion).classBase class extending AtomicLong (wip or request accounting) and QueueSubscription (fusion).classA subscription that signals a single value eventually.enumAn empty subscription that does nothing other than validates the request amount.final classA Subscription that holds a constant value and emits it only when requested.