Uses of Class
io.reactivex.rxjava3.operators.SpscLinkedArrayQueue
Packages that use SpscLinkedArrayQueue
Package
Description
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 SpscLinkedArrayQueue in io.reactivex.rxjava3.internal.operators.flowable
Fields in io.reactivex.rxjava3.internal.operators.flowable declared as SpscLinkedArrayQueueModifier and TypeFieldDescription(package private) final SpscLinkedArrayQueue
<C> FlowableBufferBoundary.BufferBoundarySubscriber.queue
(package private) final SpscLinkedArrayQueue
<Object> FlowableCombineLatest.CombineLatestCoordinator.queue
(package private) final SpscLinkedArrayQueue
<T> FlowableCreate.BufferAsyncEmitter.queue
(package private) final SpscLinkedArrayQueue
<T> FlowableGroupBy.State.queue
(package private) final SpscLinkedArrayQueue
<Object> FlowableGroupJoin.GroupJoinSubscription.queue
(package private) final SpscLinkedArrayQueue
<Object> FlowableJoin.JoinSubscription.queue
(package private) final SpscLinkedArrayQueue
<Object> FlowableSkipLastTimed.SkipLastTimedSubscriber.queue
(package private) final SpscLinkedArrayQueue
<Object> FlowableTakeLastTimed.TakeLastTimedSubscriber.queue
(package private) final SpscLinkedArrayQueue
<UnicastProcessor<T>> FlowableWindow.WindowOverlapSubscriber.queue
(package private) final SpscLinkedArrayQueue
<InnerQueuedSubscriber<R>> FlowableConcatMapEager.ConcatMapEagerDelayErrorSubscriber.subscribers
Fields in io.reactivex.rxjava3.internal.operators.flowable with type parameters of type SpscLinkedArrayQueueModifier and TypeFieldDescription(package private) final AtomicReference
<SpscLinkedArrayQueue<R>> FlowableFlatMapMaybe.FlatMapMaybeSubscriber.queue
(package private) final AtomicReference
<SpscLinkedArrayQueue<R>> FlowableFlatMapSingle.FlatMapSingleSubscriber.queue
Methods in io.reactivex.rxjava3.internal.operators.flowable that return SpscLinkedArrayQueueModifier and TypeMethodDescription(package private) SpscLinkedArrayQueue
<R> FlowableFlatMapMaybe.FlatMapMaybeSubscriber.getOrCreateQueue()
(package private) SpscLinkedArrayQueue
<R> FlowableFlatMapSingle.FlatMapSingleSubscriber.getOrCreateQueue()
Methods in io.reactivex.rxjava3.internal.operators.flowable with parameters of type SpscLinkedArrayQueueModifier and TypeMethodDescription(package private) static boolean
FlowableFlatMapMaybe.FlatMapMaybeSubscriber.checkTerminate
(boolean d, SpscLinkedArrayQueue<?> q) (package private) boolean
FlowableCombineLatest.CombineLatestCoordinator.checkTerminated
(boolean d, boolean empty, org.reactivestreams.Subscriber<?> a, SpscLinkedArrayQueue<?> q) (package private) boolean
FlowableWindow.WindowOverlapSubscriber.checkTerminated
(boolean d, boolean empty, org.reactivestreams.Subscriber<?> a, SpscLinkedArrayQueue<?> q) (package private) void
FlowableTakeLastTimed.TakeLastTimedSubscriber.trim
(long now, SpscLinkedArrayQueue<Object> q) -
Uses of SpscLinkedArrayQueue in io.reactivex.rxjava3.internal.operators.observable
Fields in io.reactivex.rxjava3.internal.operators.observable declared as SpscLinkedArrayQueueModifier and TypeFieldDescription(package private) final SpscLinkedArrayQueue
<T> BlockingObservableIterable.BlockingObservableIterator.queue
(package private) final SpscLinkedArrayQueue
<C> ObservableBufferBoundary.BufferBoundaryObserver.queue
(package private) final SpscLinkedArrayQueue
<Object[]> ObservableCombineLatest.LatestCoordinator.queue
(package private) final SpscLinkedArrayQueue
<T> ObservableCreate.SerializedEmitter.queue
(package private) final SpscLinkedArrayQueue
<T> ObservableGroupBy.State.queue
(package private) final SpscLinkedArrayQueue
<Object> ObservableGroupJoin.GroupJoinDisposable.queue
(package private) final SpscLinkedArrayQueue
<Object> ObservableJoin.JoinDisposable.queue
(package private) final SpscLinkedArrayQueue
<T> ObservableSequenceEqual.EqualObserver.queue
(package private) final SpscLinkedArrayQueue
<T> ObservableSequenceEqualSingle.EqualObserver.queue
(package private) final SpscLinkedArrayQueue
<Object> ObservableSkipLastTimed.SkipLastTimedObserver.queue
(package private) final SpscLinkedArrayQueue
<Object> ObservableTakeLastTimed.TakeLastTimedObserver.queue
(package private) final SpscLinkedArrayQueue
<T> ObservableZip.ZipObserver.queue
Fields in io.reactivex.rxjava3.internal.operators.observable with type parameters of type SpscLinkedArrayQueueModifier and TypeFieldDescription(package private) final AtomicReference
<SpscLinkedArrayQueue<R>> ObservableFlatMapMaybe.FlatMapMaybeObserver.queue
(package private) final AtomicReference
<SpscLinkedArrayQueue<R>> ObservableFlatMapSingle.FlatMapSingleObserver.queue
Methods in io.reactivex.rxjava3.internal.operators.observable that return SpscLinkedArrayQueueModifier and TypeMethodDescription(package private) SpscLinkedArrayQueue
<R> ObservableFlatMapMaybe.FlatMapMaybeObserver.getOrCreateQueue()
(package private) SpscLinkedArrayQueue
<R> ObservableFlatMapSingle.FlatMapSingleObserver.getOrCreateQueue()
Methods in io.reactivex.rxjava3.internal.operators.observable with parameters of type SpscLinkedArrayQueueModifier and TypeMethodDescription(package private) void
ObservableSequenceEqual.EqualCoordinator.cancel
(SpscLinkedArrayQueue<T> q1, SpscLinkedArrayQueue<T> q2) (package private) void
ObservableSequenceEqualSingle.EqualCoordinator.cancel
(SpscLinkedArrayQueue<T> q1, SpscLinkedArrayQueue<T> q2) (package private) void
ObservableCombineLatest.LatestCoordinator.clear
(SpscLinkedArrayQueue<?> q) (package private) void
ObservableGroupJoin.GroupJoinDisposable.fail
(Throwable exc, Observer<?> a, SpscLinkedArrayQueue<?> q) (package private) void
ObservableJoin.JoinDisposable.fail
(Throwable exc, Observer<?> a, SpscLinkedArrayQueue<?> q) -
Uses of SpscLinkedArrayQueue in io.reactivex.rxjava3.processors
Fields in io.reactivex.rxjava3.processors declared as SpscLinkedArrayQueueModifier and TypeFieldDescription(package private) final SpscLinkedArrayQueue
<T> UnicastProcessor.queue
Methods in io.reactivex.rxjava3.processors with parameters of type SpscLinkedArrayQueueModifier and TypeMethodDescription(package private) boolean
UnicastProcessor.checkTerminated
(boolean failFast, boolean d, boolean empty, org.reactivestreams.Subscriber<? super @NonNull T> a, SpscLinkedArrayQueue<@NonNull T> q) -
Uses of SpscLinkedArrayQueue in io.reactivex.rxjava3.subjects
Fields in io.reactivex.rxjava3.subjects declared as SpscLinkedArrayQueueModifier and TypeFieldDescription(package private) final SpscLinkedArrayQueue
<T> UnicastSubject.queue
The queue that buffers the source events.