Uses of Interface
io.reactivex.rxjava3.operators.SimpleQueue
Packages that use SimpleQueue
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 SimpleQueue in io.reactivex.rxjava3.internal.disposables
Classes in io.reactivex.rxjava3.internal.disposables that implement SimpleQueueModifier and TypeClassDescriptionenum
Represents a stateless empty Disposable that reports being always empty and disposed. -
Uses of SimpleQueue in io.reactivex.rxjava3.internal.fuseable
Classes in io.reactivex.rxjava3.internal.fuseable that implement SimpleQueueModifier 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 SimpleQueue in io.reactivex.rxjava3.internal.jdk8
Classes in io.reactivex.rxjava3.internal.jdk8 that implement SimpleQueueModifier 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
Fields in io.reactivex.rxjava3.internal.jdk8 declared as SimpleQueueModifier and TypeFieldDescription(package private) SimpleQueue
<T> FlowableFlatMapStream.FlatMapStreamSubscriber.queue
-
Uses of SimpleQueue in io.reactivex.rxjava3.internal.observers
Classes in io.reactivex.rxjava3.internal.observers that implement SimpleQueueModifier 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.Fields in io.reactivex.rxjava3.internal.observers declared as SimpleQueueMethods in io.reactivex.rxjava3.internal.observers that return SimpleQueue -
Uses of SimpleQueue in io.reactivex.rxjava3.internal.operators.completable
Fields in io.reactivex.rxjava3.internal.operators.completable declared as SimpleQueueModifier and TypeFieldDescription(package private) SimpleQueue
<CompletableSource> CompletableConcat.CompletableConcatSubscriber.queue
-
Uses of SimpleQueue in io.reactivex.rxjava3.internal.operators.flowable
Classes in io.reactivex.rxjava3.internal.operators.flowable that implement SimpleQueueModifier 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>> Fields in io.reactivex.rxjava3.internal.operators.flowable declared as SimpleQueueModifier and TypeFieldDescription(package private) SimpleQueue
<T> FlowableConcatMap.BaseConcatMapSubscriber.queue
(package private) SimpleQueue
<T> FlowableConcatMapScheduler.BaseConcatMapSubscriber.queue
(package private) SimpleQueue
<U> FlowableFlatMap.InnerSubscriber.queue
(package private) SimpleQueue
<T> FlowableFlattenIterable.FlattenIterableSubscriber.queue
(package private) SimpleQueue
<T> FlowableObserveOn.BaseObserveOnSubscriber.queue
(package private) SimpleQueue
<T> FlowablePublish.PublishConnection.queue
(package private) SimpleQueue
<T> FlowablePublishMulticast.MulticastProcessor.queue
(package private) SimpleQueue
<T> FlowableSequenceEqual.EqualSubscriber.queue
(package private) SimpleQueue
<R> FlowableSwitchMap.SwitchMapInnerSubscriber.queue
(package private) SimpleQueue
<T> FlowableZip.ZipSubscriber.queue
Methods in io.reactivex.rxjava3.internal.operators.flowable that return SimpleQueueModifier and TypeMethodDescription(package private) SimpleQueue
<U> FlowableFlatMap.MergeSubscriber.getMainQueue()
Methods in io.reactivex.rxjava3.internal.operators.flowable with parameters of type SimpleQueueModifier and TypeMethodDescription(package private) boolean
FlowableFlattenIterable.FlattenIterableSubscriber.checkTerminated
(boolean d, boolean empty, org.reactivestreams.Subscriber<?> a, SimpleQueue<?> q) (package private) void
FlowableGroupJoin.GroupJoinSubscription.fail
(Throwable exc, org.reactivestreams.Subscriber<?> a, SimpleQueue<?> q) (package private) void
FlowableJoin.JoinSubscription.fail
(Throwable exc, org.reactivestreams.Subscriber<?> a, SimpleQueue<?> q) -
Uses of SimpleQueue in io.reactivex.rxjava3.internal.operators.maybe
Subinterfaces of SimpleQueue in io.reactivex.rxjava3.internal.operators.maybeModifier and TypeInterfaceDescription(package private) static interface
Classes in io.reactivex.rxjava3.internal.operators.maybe that implement SimpleQueueModifier 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
-
Uses of SimpleQueue in io.reactivex.rxjava3.internal.operators.mixed
Fields in io.reactivex.rxjava3.internal.operators.mixed declared as SimpleQueueModifier and TypeFieldDescription(package private) SimpleQueue
<T> ConcatMapXMainObserver.queue
(package private) SimpleQueue
<T> ConcatMapXMainSubscriber.queue
-
Uses of SimpleQueue in io.reactivex.rxjava3.internal.operators.observable
Classes in io.reactivex.rxjava3.internal.operators.observable that implement SimpleQueueModifier 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.Fields in io.reactivex.rxjava3.internal.operators.observable declared as SimpleQueueModifier and TypeFieldDescription(package private) SimpleQueue
<T> ObservableConcatMap.ConcatMapDelayErrorObserver.queue
(package private) SimpleQueue
<T> ObservableConcatMap.SourceObserver.queue
(package private) SimpleQueue
<T> ObservableConcatMapEager.ConcatMapEagerMainObserver.queue
(package private) SimpleQueue
<T> ObservableConcatMapScheduler.ConcatMapDelayErrorObserver.queue
(package private) SimpleQueue
<T> ObservableConcatMapScheduler.ConcatMapObserver.queue
(package private) SimpleQueue
<U> ObservableFlatMap.InnerObserver.queue
(package private) SimpleQueue
<T> ObservableObserveOn.ObserveOnObserver.queue
(package private) SimpleQueue
<R> ObservableSwitchMap.SwitchMapInnerObserver.queue
-
Uses of SimpleQueue in io.reactivex.rxjava3.internal.operators.parallel
Classes in io.reactivex.rxjava3.internal.operators.parallel that implement SimpleQueueModifier and TypeClassDescription(package private) static final class
(package private) static final class
(package private) static final class
Fields in io.reactivex.rxjava3.internal.operators.parallel declared as SimpleQueueModifier and TypeFieldDescription(package private) SimpleQueue
<T> ParallelFromPublisher.ParallelDispatcher.queue
-
Uses of SimpleQueue in io.reactivex.rxjava3.internal.operators.single
Classes in io.reactivex.rxjava3.internal.operators.single that implement SimpleQueueModifier and TypeClassDescription(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
-
Uses of SimpleQueue in io.reactivex.rxjava3.internal.queue
Classes in io.reactivex.rxjava3.internal.queue that implement SimpleQueueModifier and TypeClassDescriptionfinal class
A multi-producer single consumer unbounded queue. -
Uses of SimpleQueue in io.reactivex.rxjava3.internal.subscribers
Classes in io.reactivex.rxjava3.internal.subscribers that implement SimpleQueueModifier 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.Fields in io.reactivex.rxjava3.internal.subscribers declared as SimpleQueueMethods in io.reactivex.rxjava3.internal.subscribers that return SimpleQueue -
Uses of SimpleQueue in io.reactivex.rxjava3.internal.subscriptions
Classes in io.reactivex.rxjava3.internal.subscriptions that implement SimpleQueueModifier 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 SimpleQueue in io.reactivex.rxjava3.internal.util
Methods in io.reactivex.rxjava3.internal.util that return SimpleQueueModifier and TypeMethodDescriptionstatic <T> SimpleQueue
<T> QueueDrainHelper.createQueue
(int capacityHint) Creates a queue: spsc-array if capacityHint is positive and spsc-linked-array if capacityHint is negative; in both cases, the capacity is the absolute value of prefetch.Methods in io.reactivex.rxjava3.internal.util with parameters of type SimpleQueueModifier and TypeMethodDescriptionstatic <T,
U> boolean QueueDrainHelper.checkTerminated
(boolean d, boolean empty, Observer<?> observer, boolean delayError, SimpleQueue<?> q, Disposable disposable, ObservableQueueDrain<T, U> qd) static <T,
U> boolean QueueDrainHelper.checkTerminated
(boolean d, boolean empty, org.reactivestreams.Subscriber<?> s, boolean delayError, SimpleQueue<?> q, QueueDrain<T, U> qd) -
Uses of SimpleQueue in io.reactivex.rxjava3.operators
Subinterfaces of SimpleQueue 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
Represents aSimpleQueue
plus the means and constants for requesting a fusion mode.interface
An interface extendingSimpleQueue
andSubscription
and allows negotiating the fusion mode between subsequent operators of theFlowable
base reactive type.interface
Classes in io.reactivex.rxjava3.operators that implement SimpleQueueModifier and TypeClassDescriptionfinal class
A Single-Producer-Single-Consumer queue backed by a pre-allocated buffer.final class
A single-producer single-consumer array-backed queue which can allocate new arrays in case the consumer is slower than the producer. -
Uses of SimpleQueue in io.reactivex.rxjava3.processors
Classes in io.reactivex.rxjava3.processors that implement SimpleQueueModifier and TypeClassDescription(package private) static final class
(package private) final class
Fields in io.reactivex.rxjava3.processors declared as SimpleQueue -
Uses of SimpleQueue in io.reactivex.rxjava3.subjects
Classes in io.reactivex.rxjava3.subjects that implement SimpleQueueModifier and TypeClassDescription(package private) static final class
(package private) final class
Methods in io.reactivex.rxjava3.subjects with parameters of type SimpleQueueModifier and TypeMethodDescription(package private) boolean
UnicastSubject.failedFast
(SimpleQueue<T> q, Observer<? super T> a)