Package rx.internal.operators
Class OnSubscribeAmb.Selection<T>
- java.lang.Object
-
- rx.internal.operators.OnSubscribeAmb.Selection<T>
-
- Enclosing class:
- OnSubscribeAmb<T>
static final class OnSubscribeAmb.Selection<T> extends java.lang.Object
-
-
Field Summary
Fields Modifier and Type Field Description (package private) java.util.Collection<OnSubscribeAmb.AmbSubscriber<T>>
ambSubscribers
(package private) java.util.concurrent.atomic.AtomicReference<OnSubscribeAmb.AmbSubscriber<T>>
choice
-
Constructor Summary
Constructors Constructor Description Selection()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
unsubscribeLosers()
void
unsubscribeOthers(OnSubscribeAmb.AmbSubscriber<T> notThis)
-
-
-
Field Detail
-
choice
final java.util.concurrent.atomic.AtomicReference<OnSubscribeAmb.AmbSubscriber<T>> choice
-
ambSubscribers
final java.util.Collection<OnSubscribeAmb.AmbSubscriber<T>> ambSubscribers
-
-
Method Detail
-
unsubscribeLosers
public void unsubscribeLosers()
-
unsubscribeOthers
public void unsubscribeOthers(OnSubscribeAmb.AmbSubscriber<T> notThis)
-
-