Uses of Interface
io.reactivex.rxjava3.operators.QueueSubscription

Packages that use QueueSubscription

Package	Description
io.reactivex.rxjava3.internal.fuseable	Base interfaces and types for supporting operator-fusion.
io.reactivex.rxjava3.internal.jdk8
io.reactivex.rxjava3.internal.operators.flowable
io.reactivex.rxjava3.internal.operators.maybe
io.reactivex.rxjava3.internal.operators.observable
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 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 QueueSubscription

Modifier and Type	Class	Description
class	AbstractEmptyQueueFuseable<T>	Represents an empty, async-only QueueFuseable instance.
final class	CancellableQueueFuseable<T>	Represents an empty, async-only QueueFuseable 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 QueueSubscription

Modifier and Type	Class	Description
(package private) static final class	FlowableCollectWithCollector.CollectorSubscriber<T,A,R>
(package private) static final class	FlowableFromCompletionStage.CompletionStageHandler<T>
(package private) static class	FlowableFromStream.AbstractStreamSubscription<T>
(package private) static final class	FlowableFromStream.StreamConditionalSubscription<T>
(package private) static final class	FlowableFromStream.StreamSubscription<T>
(package private) static final class	FlowableMapOptional.MapOptionalConditionalSubscriber<T,R>
(package private) static final class	FlowableMapOptional.MapOptionalSubscriber<T,R>
(package private) static final class	MaybeFlattenStreamAsFlowable.FlattenStreamMultiObserver<T,R>
(package private) static final class	ParallelCollector.ParallelCollectorSubscriber<T,A,R>

Uses of QueueSubscription in io.reactivex.rxjava3.internal.operators.flowable

Classes in io.reactivex.rxjava3.internal.operators.flowable that implement QueueSubscription

Modifier and Type	Class	Description
(package private) static final class	FlowableAll.AllSubscriber<T>
(package private) static final class	FlowableAny.AnySubscriber<T>
(package private) static final class	FlowableCollect.CollectSubscriber<T,U>
(package private) static final class	FlowableCombineLatest.CombineLatestCoordinator<T,R>
(package private) static final class	FlowableCount.CountSubscriber
(package private) static final class	FlowableDistinct.DistinctSubscriber<T,K>
(package private) static final class	FlowableDistinctUntilChanged.DistinctUntilChangedConditionalSubscriber<T,K>
(package private) static final class	FlowableDistinctUntilChanged.DistinctUntilChangedSubscriber<T,K>
(package private) static final class	FlowableDoAfterNext.DoAfterConditionalSubscriber<T>
(package private) static final class	FlowableDoAfterNext.DoAfterSubscriber<T>
(package private) static final class	FlowableDoFinally.DoFinallyConditionalSubscriber<T>
(package private) static final class	FlowableDoFinally.DoFinallySubscriber<T>
(package private) static final class	FlowableDoOnEach.DoOnEachConditionalSubscriber<T>
(package private) static final class	FlowableDoOnEach.DoOnEachSubscriber<T>
(package private) static final class	FlowableElementAt.ElementAtSubscriber<T>
(package private) static final class	FlowableFilter.FilterConditionalSubscriber<T>
(package private) static final class	FlowableFilter.FilterSubscriber<T>
(package private) static final class	FlowableFlatMapCompletable.FlatMapCompletableMainSubscriber<T>
(package private) static final class	FlowableFlattenIterable.FlattenIterableSubscriber<T,R>
(package private) static final class	FlowableFromArray.ArrayConditionalSubscription<T>
(package private) static final class	FlowableFromArray.ArraySubscription<T>
(package private) static class	FlowableFromArray.BaseArraySubscription<T>
static final class	FlowableFromCompletable.FromCompletableObserver<T>
(package private) static class	FlowableFromIterable.BaseRangeSubscription<T>
(package private) static final class	FlowableFromIterable.IteratorConditionalSubscription<T>
(package private) static final class	FlowableFromIterable.IteratorSubscription<T>
(package private) static final class	FlowableGroupBy.State<T,K>
(package private) static final class	FlowableIgnoreElements.IgnoreElementsSubscriber<T>
(package private) static final class	FlowableMap.MapConditionalSubscriber<T,U>
(package private) static final class	FlowableMap.MapSubscriber<T,U>
(package private) static class	FlowableObserveOn.BaseObserveOnSubscriber<T>
(package private) static final class	FlowableObserveOn.ObserveOnConditionalSubscriber<T>
(package private) static final class	FlowableObserveOn.ObserveOnSubscriber<T>
(package private) static final class	FlowableOnBackpressureBuffer.BackpressureBufferSubscriber<T>
(package private) static class	FlowableRange.BaseRangeSubscription
(package private) static final class	FlowableRange.RangeConditionalSubscription
(package private) static final class	FlowableRange.RangeSubscription
(package private) static class	FlowableRangeLong.BaseRangeSubscription
(package private) static final class	FlowableRangeLong.RangeConditionalSubscription
(package private) static final class	FlowableRangeLong.RangeSubscription
(package private) static final class	FlowableReduce.ReduceSubscriber<T>
(package private) static final class	FlowableSequenceEqual.EqualCoordinator<T>
(package private) static final class	FlowableSingle.SingleElementSubscriber<T>
(package private) static final class	FlowableTakeLastOne.TakeLastOneSubscriber<T>
(package private) static final class	FlowableToList.ToListSubscriber<T,U extends Collection<? super T>>

Fields in io.reactivex.rxjava3.internal.operators.flowable declared as QueueSubscription

Modifier and Type	Field	Description
(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 QueueSubscription

Modifier and Type	Class	Description
(package private) static final class	MaybeFlatMapIterableFlowable.FlatMapIterableObserver<T,R>
(package private) static final class	MaybeMergeArray.MergeMaybeObserver<T>
(package private) static final class	MaybeToFlowable.MaybeToFlowableSubscriber<T>

Uses of QueueSubscription in io.reactivex.rxjava3.internal.operators.observable

Classes in io.reactivex.rxjava3.internal.operators.observable that implement QueueSubscription

Modifier and Type	Class	Description
static final class	ObservableFromCompletable.FromCompletableObserver<T>

Uses of QueueSubscription in io.reactivex.rxjava3.internal.operators.parallel

Classes in io.reactivex.rxjava3.internal.operators.parallel that implement QueueSubscription

Modifier and Type	Class	Description
(package private) static final class	ParallelCollect.ParallelCollectSubscriber<T,C>
(package private) static final class	ParallelReduce.ParallelReduceSubscriber<T,R>
(package private) static final class	ParallelReduceFull.ParallelReduceFullMainSubscriber<T>

Uses of QueueSubscription in io.reactivex.rxjava3.internal.operators.single

Classes in io.reactivex.rxjava3.internal.operators.single that implement QueueSubscription

Modifier and Type	Class	Description
(package private) static final class	SingleFlatMapIterableFlowable.FlatMapIterableObserver<T,R>
(package private) static final class	SingleToFlowable.SingleToFlowableObserver<T>

Uses of QueueSubscription in io.reactivex.rxjava3.internal.subscribers

Classes in io.reactivex.rxjava3.internal.subscribers that implement QueueSubscription

Modifier and Type	Class	Description
class	BasicFuseableConditionalSubscriber<T,R>	Base class for a fuseable intermediate subscriber.
class	BasicFuseableSubscriber<T,R>	Base class for a fuseable intermediate subscriber.
class	DeferredScalarSubscriber<T,R>	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 QueueSubscription

Modifier and Type	Field	Description
protected 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 QueueSubscription

Modifier and Type	Class	Description
class	BasicIntQueueSubscription<T>	Base class extending AtomicInteger (wip or request accounting) and QueueSubscription (fusion).
class	BasicQueueSubscription<T>	Base class extending AtomicLong (wip or request accounting) and QueueSubscription (fusion).
class	DeferredScalarSubscription<T>	A subscription that signals a single value eventually.
enum	EmptySubscription	An empty subscription that does nothing other than validates the request amount.
final class	ScalarSubscription<T>	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 QueueSubscription

Modifier and Type	Class	Description
(package private) static final class	AsyncProcessor.AsyncSubscription<T>
(package private) final class	UnicastProcessor.UnicastQueueSubscription