Package rx.internal.operators
Class OnSubscribeAmb.Selection<T>
java.lang.Object
rx.internal.operators.OnSubscribeAmb.Selection<T>
- Enclosing class:
OnSubscribeAmb<T>
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) final Collection
<OnSubscribeAmb.AmbSubscriber<T>> (package private) final AtomicReference
<OnSubscribeAmb.AmbSubscriber<T>> -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
void
unsubscribeOthers
(OnSubscribeAmb.AmbSubscriber<T> notThis)
-
Field Details
-
choice
-
ambSubscribers
-
-
Constructor Details
-
Selection
Selection()
-
-
Method Details
-
unsubscribeLosers
public void unsubscribeLosers() -
unsubscribeOthers
-