Uses of Class
rx.internal.util.atomic.SpscLinkedArrayQueue
-
Packages that use SpscLinkedArrayQueue Package Description rx.internal.operators 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 SpscLinkedArrayQueue Modifier and Type Field Description (package private) SpscLinkedArrayQueue<java.lang.Object>
OnSubscribeCombineLatest.LatestCoordinator. queue
(package private) SpscLinkedArrayQueue<java.lang.Object>
OperatorSwitch.SwitchSubscriber. queue
Methods in rx.internal.operators with parameters of type SpscLinkedArrayQueue Modifier and Type Method Description protected boolean
OperatorSwitch.SwitchSubscriber. checkTerminated(boolean localMainDone, boolean localInnerActive, java.lang.Throwable localError, SpscLinkedArrayQueue<java.lang.Object> localQueue, Subscriber<? super T> localChild, boolean empty)
-