Uses of Class
io.reactivex.rxjava3.operators.SpscLinkedArrayQueue

Packages that use SpscLinkedArrayQueue

Package	Description
io.reactivex.rxjava3.internal.operators.flowable
io.reactivex.rxjava3.internal.operators.observable
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 SpscLinkedArrayQueue in io.reactivex.rxjava3.internal.operators.flowable

Fields in io.reactivex.rxjava3.internal.operators.flowable declared as SpscLinkedArrayQueue

Modifier and Type	Field	Description
(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 SpscLinkedArrayQueue

Modifier and Type	Field	Description
(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 SpscLinkedArrayQueue

Modifier and Type	Method	Description
(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 SpscLinkedArrayQueue

Modifier and Type	Method	Description
(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 SpscLinkedArrayQueue

Modifier and Type	Field	Description
(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 SpscLinkedArrayQueue

Modifier and Type	Field	Description
(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 SpscLinkedArrayQueue

Modifier and Type	Method	Description
(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 SpscLinkedArrayQueue

Modifier and Type	Method	Description
(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 SpscLinkedArrayQueue

Modifier and Type	Field	Description
(package private) final SpscLinkedArrayQueue<T>	UnicastProcessor.queue

Methods in io.reactivex.rxjava3.processors with parameters of type SpscLinkedArrayQueue

Modifier and Type	Method	Description
(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 SpscLinkedArrayQueue

Modifier and Type	Field	Description
(package private) final SpscLinkedArrayQueue<T>	UnicastSubject.queue	The queue that buffers the source events.