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 theFlowableProcessor
class, the Reactive StreamsProcessor
interface to allow forms of multicasting events to one or more subscribers as well as consuming another Reactive StreamsPublisher
.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) SpscLinkedArrayQueue<C>
FlowableBufferBoundary.BufferBoundarySubscriber. queue
(package private) SpscLinkedArrayQueue<java.lang.Object>
FlowableCombineLatest.CombineLatestCoordinator. queue
(package private) SpscLinkedArrayQueue<T>
FlowableCreate.BufferAsyncEmitter. queue
(package private) SpscLinkedArrayQueue<T>
FlowableGroupBy.State. queue
(package private) SpscLinkedArrayQueue<java.lang.Object>
FlowableGroupJoin.GroupJoinSubscription. queue
(package private) SpscLinkedArrayQueue<java.lang.Object>
FlowableJoin.JoinSubscription. queue
(package private) SpscLinkedArrayQueue<java.lang.Object>
FlowableSkipLastTimed.SkipLastTimedSubscriber. queue
(package private) SpscLinkedArrayQueue<java.lang.Object>
FlowableTakeLastTimed.TakeLastTimedSubscriber. queue
(package private) SpscLinkedArrayQueue<UnicastProcessor<T>>
FlowableWindow.WindowOverlapSubscriber. queue
(package private) 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) java.util.concurrent.atomic.AtomicReference<SpscLinkedArrayQueue<R>>
FlowableFlatMapMaybe.FlatMapMaybeSubscriber. queue
(package private) java.util.concurrent.atomic.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<java.lang.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) SpscLinkedArrayQueue<T>
BlockingObservableIterable.BlockingObservableIterator. queue
(package private) SpscLinkedArrayQueue<C>
ObservableBufferBoundary.BufferBoundaryObserver. queue
(package private) SpscLinkedArrayQueue<java.lang.Object[]>
ObservableCombineLatest.LatestCoordinator. queue
(package private) SpscLinkedArrayQueue<T>
ObservableCreate.SerializedEmitter. queue
(package private) SpscLinkedArrayQueue<T>
ObservableGroupBy.State. queue
(package private) SpscLinkedArrayQueue<java.lang.Object>
ObservableGroupJoin.GroupJoinDisposable. queue
(package private) SpscLinkedArrayQueue<java.lang.Object>
ObservableJoin.JoinDisposable. queue
(package private) SpscLinkedArrayQueue<T>
ObservableSequenceEqual.EqualObserver. queue
(package private) SpscLinkedArrayQueue<T>
ObservableSequenceEqualSingle.EqualObserver. queue
(package private) SpscLinkedArrayQueue<java.lang.Object>
ObservableSkipLastTimed.SkipLastTimedObserver. queue
(package private) SpscLinkedArrayQueue<java.lang.Object>
ObservableTakeLastTimed.TakeLastTimedObserver. queue
(package private) 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) java.util.concurrent.atomic.AtomicReference<SpscLinkedArrayQueue<R>>
ObservableFlatMapMaybe.FlatMapMaybeObserver. queue
(package private) java.util.concurrent.atomic.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(java.lang.Throwable exc, Observer<?> a, SpscLinkedArrayQueue<?> q)
(package private) void
ObservableJoin.JoinDisposable. fail(java.lang.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) 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) SpscLinkedArrayQueue<T>
UnicastSubject. queue
The queue that buffers the source events.
-