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 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.
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-only QueueFuseable instance.
class	CancellableQueueFuseable<T>	Represents an empty, async-only QueueFuseable instance that tracks and exposes a canceled/disposed state.

Uses of QueueFuseable in io.reactivex.rxjava3.internal.jdk8

Classes in io.reactivex.rxjava3.internal.jdk8 that implement QueueFuseable

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	FlowableFromStream.AbstractStreamSubscription<T>
(package private) static class	FlowableFromStream.StreamConditionalSubscription<T>
(package private) static class	FlowableFromStream.StreamSubscription<T>
(package private) static class	FlowableMapOptional.MapOptionalConditionalSubscriber<T,R>
(package private) static class	FlowableMapOptional.MapOptionalSubscriber<T,R>
(package private) static class	MaybeFlattenStreamAsFlowable.FlattenStreamMultiObserver<T,R>
(package private) static class	MaybeFlattenStreamAsObservable.FlattenStreamMultiObserver<T,R>
(package private) static class	ObservableCollectWithCollector.CollectorObserver<T,A,R>
(package private) static class	ObservableFromCompletionStage.CompletionStageHandler<T>
(package private) static class	ObservableFromStream.StreamDisposable<T>
(package private) static class	ObservableMapOptional.MapOptionalObserver<T,R>
(package private) static class	ParallelCollector.ParallelCollectorSubscriber<T,A,R>

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

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

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

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

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

Modifier and Type	Class	Description
(package private) static class	ObservableDistinct.DistinctObserver<T,K>
(package private) static class	ObservableDistinctUntilChanged.DistinctUntilChangedObserver<T,K>
(package private) static class	ObservableDoAfterNext.DoAfterObserver<T>
(package private) static class	ObservableDoFinally.DoFinallyObserver<T>
(package private) static class	ObservableFilter.FilterObserver<T>
(package private) static class	ObservableFlatMapCompletable.FlatMapCompletableMainObserver<T>
(package private) static class	ObservableFromArray.FromArrayDisposable<T>
static class	ObservableFromCompletable.FromCompletableObserver<T>
(package private) static class	ObservableFromIterable.FromIterableDisposable<T>
(package private) static class	ObservableMap.MapObserver<T,U>
(package private) static class	ObservableObserveOn.ObserveOnObserver<T>
(package private) static class	ObservableRange.RangeDisposable
(package private) static class	ObservableRangeLong.RangeDisposable
static class	ObservableScalarXMap.ScalarDisposable<T>	Represents a Disposable that signals one onNext followed by an onComplete.

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 extending SimpleQueue and Disposable and allows negotiating the fusion mode between subsequent operators of the Observable base reactive type.
interface	QueueSubscription<T>	An interface extending SimpleQueue and Subscription and allows negotiating the fusion mode between subsequent operators of the Flowable 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