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
enum	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.
final 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 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	MaybeFlattenStreamAsObservable.FlattenStreamMultiObserver<T,R>
(package private) static final class	ObservableCollectWithCollector.CollectorObserver<T,A,R>
(package private) static final class	ObservableFromCompletionStage.CompletionStageHandler<T>
(package private) static final class	ObservableFromStream.StreamDisposable<T>
(package private) static final class	ObservableMapOptional.MapOptionalObserver<T,R>
(package private) static final 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 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>>

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 final class	MaybeFlatMapIterableFlowable.FlatMapIterableObserver<T,R>
(package private) static final class	MaybeFlatMapIterableObservable.FlatMapIterableObserver<T,R>
(package private) static final class	MaybeMergeArray.MergeMaybeObserver<T>
(package private) static final class	MaybeToFlowable.MaybeToFlowableSubscriber<T>
(package private) static final 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 final class	ObservableDistinct.DistinctObserver<T,K>
(package private) static final class	ObservableDistinctUntilChanged.DistinctUntilChangedObserver<T,K>
(package private) static final class	ObservableDoAfterNext.DoAfterObserver<T>
(package private) static final class	ObservableDoFinally.DoFinallyObserver<T>
(package private) static final class	ObservableFilter.FilterObserver<T>
(package private) static final class	ObservableFlatMapCompletable.FlatMapCompletableMainObserver<T>
(package private) static final class	ObservableFromArray.FromArrayDisposable<T>
static final class	ObservableFromCompletable.FromCompletableObserver<T>
(package private) static final class	ObservableFromIterable.FromIterableDisposable<T>
(package private) static final class	ObservableMap.MapObserver<T,U>
(package private) static final class	ObservableObserveOn.ObserveOnObserver<T>
(package private) static final class	ObservableRange.RangeDisposable
(package private) static final class	ObservableRangeLong.RangeDisposable
static final 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 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 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 final class	SingleFlatMapIterableFlowable.FlatMapIterableObserver<T,R>
(package private) static final class	SingleFlatMapIterableObservable.FlatMapIterableObserver<T,R>
(package private) static final class	SingleToFlowable.SingleToFlowableObserver<T>
(package private) static final 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.
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 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 final class	AsyncProcessor.AsyncSubscription<T>
(package private) final 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 final class	AsyncSubject.AsyncDisposable<T>
(package private) final class	UnicastSubject.UnicastQueueDisposable