Uses of Class
rx.internal.util.atomic.SpscLinkedArrayQueue
Packages that use SpscLinkedArrayQueue
Package
Description
Operators that allow composing Observables to transform and
manipulate data in an asynchronous, functional and thread-safe manner.
-
Uses of SpscLinkedArrayQueue in rx.internal.operators
Fields in rx.internal.operators declared as SpscLinkedArrayQueueModifier and TypeFieldDescription(package private) final SpscLinkedArrayQueue
<Object> OnSubscribeCombineLatest.LatestCoordinator.queue
(package private) final SpscLinkedArrayQueue
<Object> OperatorSwitch.SwitchSubscriber.queue
Methods in rx.internal.operators with parameters of type SpscLinkedArrayQueueModifier and TypeMethodDescriptionprotected boolean
OperatorSwitch.SwitchSubscriber.checkTerminated
(boolean localMainDone, boolean localInnerActive, Throwable localError, SpscLinkedArrayQueue<Object> localQueue, Subscriber<? super T> localChild, boolean empty)