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) final SpscLinkedArrayQueue<Object>	OnSubscribeCombineLatest.LatestCoordinator.queue
(package private) final SpscLinkedArrayQueue<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, Throwable localError, SpscLinkedArrayQueue<Object> localQueue, Subscriber<? super T> localChild, boolean empty)