Uses of Interface
io.reactivex.rxjava3.operators.QueueFuseable
-
Packages that use QueueFuseable Package Description io.reactivex.rxjava3.internal.disposables io.reactivex.rxjava3.internal.fuseable Base interfaces and types for supporting operator-fusion.io.reactivex.rxjava3.internal.jdk8 io.reactivex.rxjava3.internal.observers 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.operators Classes and interfaces for writing advanced operators within and outside RxJava.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
.io.reactivex.rxjava3.subjects Classes representing so-called hot sources, aka subjects, that implement a base reactive class and the respective consumer type at once to allow forms of multicasting events to multiple consumers as well as consuming another base reactive type of their kind. -
-
Uses of QueueFuseable in io.reactivex.rxjava3.internal.disposables
Classes in io.reactivex.rxjava3.internal.disposables that implement QueueFuseable Modifier and Type Class Description class
EmptyDisposable
Represents a stateless empty Disposable that reports being always empty and disposed. -
Uses of QueueFuseable in io.reactivex.rxjava3.internal.fuseable
Classes in io.reactivex.rxjava3.internal.fuseable that implement QueueFuseable Modifier and Type Class Description class
AbstractEmptyQueueFuseable<T>
Represents an empty, async-onlyQueueFuseable
instance.class
CancellableQueueFuseable<T>
Represents an empty, async-onlyQueueFuseable
instance that tracks and exposes a canceled/disposed state. -
Uses of QueueFuseable in io.reactivex.rxjava3.internal.jdk8
-
Uses of QueueFuseable in io.reactivex.rxjava3.internal.observers
Classes in io.reactivex.rxjava3.internal.observers that implement QueueFuseable Modifier and Type Class Description class
BasicFuseableObserver<T,R>
Base class for a fuseable intermediate observer.class
BasicIntQueueDisposable<T>
An abstract QueueDisposable implementation, extending an AtomicInteger, that defaults all unnecessary Queue methods to throw UnsupportedOperationException.class
BasicQueueDisposable<T>
An abstract QueueDisposable implementation that defaults all unnecessary Queue methods to throw UnsupportedOperationException.class
DeferredScalarDisposable<T>
Represents a fuseable container for a single value.class
DeferredScalarObserver<T,R>
A fuseable Observer that can generate 0 or 1 resulting value. -
Uses of QueueFuseable in io.reactivex.rxjava3.internal.operators.flowable
-
Uses of QueueFuseable in io.reactivex.rxjava3.internal.operators.maybe
Classes in io.reactivex.rxjava3.internal.operators.maybe that implement QueueFuseable Modifier and Type Class Description (package private) static class
MaybeFlatMapIterableFlowable.FlatMapIterableObserver<T,R>
(package private) static class
MaybeFlatMapIterableObservable.FlatMapIterableObserver<T,R>
(package private) static class
MaybeMergeArray.MergeMaybeObserver<T>
(package private) static class
MaybeToFlowable.MaybeToFlowableSubscriber<T>
(package private) static class
MaybeToObservable.MaybeToObservableObserver<T>
-
Uses of QueueFuseable in io.reactivex.rxjava3.internal.operators.observable
-
Uses of QueueFuseable in io.reactivex.rxjava3.internal.operators.parallel
Classes in io.reactivex.rxjava3.internal.operators.parallel that implement QueueFuseable 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 QueueFuseable in io.reactivex.rxjava3.internal.operators.single
Classes in io.reactivex.rxjava3.internal.operators.single that implement QueueFuseable Modifier and Type Class Description (package private) static class
SingleFlatMapIterableFlowable.FlatMapIterableObserver<T,R>
(package private) static class
SingleFlatMapIterableObservable.FlatMapIterableObserver<T,R>
(package private) static class
SingleToFlowable.SingleToFlowableObserver<T>
(package private) static class
SingleToObservable.SingleToObservableObserver<T>
-
Uses of QueueFuseable in io.reactivex.rxjava3.internal.subscribers
Classes in io.reactivex.rxjava3.internal.subscribers that implement QueueFuseable 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. -
Uses of QueueFuseable in io.reactivex.rxjava3.internal.subscriptions
Classes in io.reactivex.rxjava3.internal.subscriptions that implement QueueFuseable 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.class
EmptySubscription
An empty subscription that does nothing other than validates the request amount.class
ScalarSubscription<T>
A Subscription that holds a constant value and emits it only when requested. -
Uses of QueueFuseable in io.reactivex.rxjava3.operators
Subinterfaces of QueueFuseable in io.reactivex.rxjava3.operators Modifier and Type Interface Description interface
QueueDisposable<T>
An interface extendingSimpleQueue
andDisposable
and allows negotiating the fusion mode between subsequent operators of theObservable
base reactive type.interface
QueueSubscription<T>
An interface extendingSimpleQueue
andSubscription
and allows negotiating the fusion mode between subsequent operators of theFlowable
base reactive type. -
Uses of QueueFuseable in io.reactivex.rxjava3.processors
Classes in io.reactivex.rxjava3.processors that implement QueueFuseable Modifier and Type Class Description (package private) static class
AsyncProcessor.AsyncSubscription<T>
(package private) class
UnicastProcessor.UnicastQueueSubscription
-
Uses of QueueFuseable in io.reactivex.rxjava3.subjects
Classes in io.reactivex.rxjava3.subjects that implement QueueFuseable Modifier and Type Class Description (package private) static class
AsyncSubject.AsyncDisposable<T>
(package private) class
UnicastSubject.UnicastQueueDisposable
-