Uses of Class
io.reactivex.rxjava3.internal.subscriptions.BasicIntQueueSubscription
-
Packages that use BasicIntQueueSubscription 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
. -
-
Uses of BasicIntQueueSubscription in io.reactivex.rxjava3.internal.jdk8
Subclasses of BasicIntQueueSubscription in io.reactivex.rxjava3.internal.jdk8 Modifier and Type Class Description (package private) static class
FlowableCollectWithCollector.CollectorSubscriber<T,A,R>
(package private) static class
FlowableFromCompletionStage.CompletionStageHandler<T>
(package private) static class
MaybeFlattenStreamAsFlowable.FlattenStreamMultiObserver<T,R>
(package private) static class
ParallelCollector.ParallelCollectorSubscriber<T,A,R>
-
Uses of BasicIntQueueSubscription in io.reactivex.rxjava3.internal.operators.flowable
-
Uses of BasicIntQueueSubscription in io.reactivex.rxjava3.internal.operators.maybe
Subclasses of BasicIntQueueSubscription in io.reactivex.rxjava3.internal.operators.maybe Modifier and Type Class Description (package private) static class
MaybeFlatMapIterableFlowable.FlatMapIterableObserver<T,R>
(package private) static class
MaybeMergeArray.MergeMaybeObserver<T>
(package private) static class
MaybeToFlowable.MaybeToFlowableSubscriber<T>
-
Uses of BasicIntQueueSubscription in io.reactivex.rxjava3.internal.operators.parallel
Subclasses of BasicIntQueueSubscription in io.reactivex.rxjava3.internal.operators.parallel Modifier and Type Class Description (package private) static class
ParallelCollect.ParallelCollectSubscriber<T,C>
(package private) static class
ParallelReduce.ParallelReduceSubscriber<T,R>
(package private) static class
ParallelReduceFull.ParallelReduceFullMainSubscriber<T>
-
Uses of BasicIntQueueSubscription in io.reactivex.rxjava3.internal.operators.single
Subclasses of BasicIntQueueSubscription in io.reactivex.rxjava3.internal.operators.single Modifier and Type Class Description (package private) static class
SingleFlatMapIterableFlowable.FlatMapIterableObserver<T,R>
(package private) static class
SingleToFlowable.SingleToFlowableObserver<T>
-
Uses of BasicIntQueueSubscription in io.reactivex.rxjava3.internal.subscribers
Subclasses of BasicIntQueueSubscription in io.reactivex.rxjava3.internal.subscribers Modifier and Type Class Description class
DeferredScalarSubscriber<T,R>
A subscriber, extending a DeferredScalarSubscription, that is unbounded-in and can generate 0 or 1 resulting value. -
Uses of BasicIntQueueSubscription in io.reactivex.rxjava3.internal.subscriptions
Subclasses of BasicIntQueueSubscription in io.reactivex.rxjava3.internal.subscriptions Modifier and Type Class Description class
DeferredScalarSubscription<T>
A subscription that signals a single value eventually. -
Uses of BasicIntQueueSubscription in io.reactivex.rxjava3.processors
Subclasses of BasicIntQueueSubscription in io.reactivex.rxjava3.processors Modifier and Type Class Description (package private) static class
AsyncProcessor.AsyncSubscription<T>
(package private) class
UnicastProcessor.UnicastQueueSubscription
Fields in io.reactivex.rxjava3.processors declared as BasicIntQueueSubscription Modifier and Type Field Description (package private) BasicIntQueueSubscription<T>
UnicastProcessor. wip
-