Uses of Interface
io.reactivex.rxjava3.operators.QueueSubscription
Packages that use QueueSubscription
Package
Description
Base interfaces and types for supporting operator-fusion.
Classes representing so-called hot backpressure-aware sources, aka processors,
that implement the
FlowableProcessor
class,
the Reactive Streams Processor
interface
to allow forms of multicasting events to one or more subscribers as well as consuming another
Reactive Streams Publisher
.-
Uses of QueueSubscription in io.reactivex.rxjava3.internal.fuseable
Classes in io.reactivex.rxjava3.internal.fuseable that implement QueueSubscriptionModifier and TypeClassDescriptionclass
Represents an empty, async-onlyQueueFuseable
instance.final class
Represents an empty, async-onlyQueueFuseable
instance that tracks and exposes a canceled/disposed state. -
Uses of QueueSubscription in io.reactivex.rxjava3.internal.jdk8
Classes in io.reactivex.rxjava3.internal.jdk8 that implement QueueSubscriptionModifier and TypeClassDescription(package private) static final class
(package private) static final class
(package private) static class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
-
Uses of QueueSubscription in io.reactivex.rxjava3.internal.operators.flowable
Classes in io.reactivex.rxjava3.internal.operators.flowable that implement QueueSubscriptionModifier and TypeClassDescription(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static class
static final class
(package private) static class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static class
(package private) static final class
(package private) static final class
(package private) static class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
FlowableToList.ToListSubscriber<T,
U extends Collection<? super T>> Fields in io.reactivex.rxjava3.internal.operators.flowable declared as QueueSubscriptionModifier and TypeFieldDescription(package private) QueueSubscription
<T> FlowableDoFinally.DoFinallyConditionalSubscriber.qs
(package private) QueueSubscription
<T> FlowableDoFinally.DoFinallySubscriber.qs
-
Uses of QueueSubscription in io.reactivex.rxjava3.internal.operators.maybe
Classes in io.reactivex.rxjava3.internal.operators.maybe that implement QueueSubscriptionModifier and TypeClassDescription(package private) static final class
(package private) static final class
(package private) static 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.operators.parallel
Classes in io.reactivex.rxjava3.internal.operators.parallel that implement QueueSubscriptionModifier and TypeClassDescription(package private) static final class
(package private) static final class
(package private) static final class
-
Uses of QueueSubscription in io.reactivex.rxjava3.internal.operators.single
Classes in io.reactivex.rxjava3.internal.operators.single that implement QueueSubscriptionModifier and TypeClassDescription(package private) static final class
(package private) static final class
-
Uses of QueueSubscription in io.reactivex.rxjava3.internal.subscribers
Classes in io.reactivex.rxjava3.internal.subscribers that implement QueueSubscriptionModifier and TypeClassDescriptionclass
Base class for a fuseable intermediate subscriber.class
Base class for a fuseable intermediate subscriber.class
A 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.qs
The upstream's QueueSubscription if not null.protected QueueSubscription
<T> BasicFuseableSubscriber.qs
The 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 TypeClassDescriptionclass
Base class extending AtomicInteger (wip or request accounting) and QueueSubscription (fusion).class
Base class extending AtomicLong (wip or request accounting) and QueueSubscription (fusion).class
A subscription that signals a single value eventually.enum
An empty subscription that does nothing other than validates the request amount.final class
A Subscription that holds a constant value and emits it only when requested. -
Uses of QueueSubscription in io.reactivex.rxjava3.processors
Classes in io.reactivex.rxjava3.processors that implement QueueSubscriptionModifier and TypeClassDescription(package private) static final class
(package private) final class