Uses of Interface
io.reactivex.rxjava3.operators.QueueFuseable
Packages that use QueueFuseable
Package
Description
Base interfaces and types for supporting operator-fusion.
Classes and interfaces for writing advanced operators within and outside RxJava.
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
.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 QueueFuseableModifier and TypeClassDescriptionenum
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 QueueFuseableModifier and TypeClassDescriptionclass
Represents an empty, async-onlyQueueFuseable
instance.final class
Represents an empty, async-onlyQueueFuseable
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 QueueFuseableModifier and TypeClassDescription(package private) static final class
(package private) static final class
(package private) static class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
-
Uses of QueueFuseable in io.reactivex.rxjava3.internal.observers
Classes in io.reactivex.rxjava3.internal.observers that implement QueueFuseableModifier and TypeClassDescriptionclass
Base class for a fuseable intermediate observer.class
An abstract QueueDisposable implementation, extending an AtomicInteger, that defaults all unnecessary Queue methods to throw UnsupportedOperationException.class
An abstract QueueDisposable implementation that defaults all unnecessary Queue methods to throw UnsupportedOperationException.class
Represents a fuseable container for a single value.class
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 QueueFuseableModifier and TypeClassDescription(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static class
static final class
(package private) static class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static class
(package private) static final class
(package private) static final class
(package private) static class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(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 QueueFuseableModifier and TypeClassDescription(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
-
Uses of QueueFuseable in io.reactivex.rxjava3.internal.operators.observable
Classes in io.reactivex.rxjava3.internal.operators.observable that implement QueueFuseableModifier and TypeClassDescription(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
static final class
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 QueueFuseableModifier and TypeClassDescription(package private) static final class
(package private) static final class
(package private) static final class
-
Uses of QueueFuseable in io.reactivex.rxjava3.internal.operators.single
Classes in io.reactivex.rxjava3.internal.operators.single that implement QueueFuseableModifier and TypeClassDescription(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
-
Uses of QueueFuseable in io.reactivex.rxjava3.internal.subscribers
Classes in io.reactivex.rxjava3.internal.subscribers that implement QueueFuseableModifier and TypeClassDescriptionclass
Base class for a fuseable intermediate subscriber.class
Base class for a fuseable intermediate subscriber.class
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 QueueFuseableModifier and TypeClassDescriptionclass
Base class extending AtomicInteger (wip or request accounting) and QueueSubscription (fusion).class
Base class extending AtomicLong (wip or request accounting) and QueueSubscription (fusion).class
A subscription that signals a single value eventually.enum
An empty subscription that does nothing other than validates the request amount.final class
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.operatorsModifier and TypeInterfaceDescriptioninterface
An interface extendingSimpleQueue
andDisposable
and allows negotiating the fusion mode between subsequent operators of theObservable
base reactive type.interface
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 QueueFuseableModifier and TypeClassDescription(package private) static final class
(package private) final class
-
Uses of QueueFuseable in io.reactivex.rxjava3.subjects
Classes in io.reactivex.rxjava3.subjects that implement QueueFuseableModifier and TypeClassDescription(package private) static final class
(package private) final class