Class ObservableAmb.AmbCoordinator<T>
java.lang.Object
io.reactivex.rxjava3.internal.operators.observable.ObservableAmb.AmbCoordinator<T>
- All Implemented Interfaces:
Disposable
- Enclosing class:
ObservableAmb<T>
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) final ObservableAmb.AmbInnerObserver<T>[]
(package private) final AtomicInteger
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
dispose()
Dispose the resource, the operation should be idempotent.boolean
Returns true if this resource has been disposed.void
subscribe
(ObservableSource<? extends T>[] sources) boolean
win
(int index)
-
Field Details
-
downstream
-
observers
-
winner
-
-
Constructor Details
-
AmbCoordinator
-
-
Method Details
-
subscribe
-
win
public boolean win(int index) -
dispose
public void dispose()Description copied from interface:Disposable
Dispose the resource, the operation should be idempotent.- Specified by:
dispose
in interfaceDisposable
-
isDisposed
public boolean isDisposed()Description copied from interface:Disposable
Returns true if this resource has been disposed.- Specified by:
isDisposed
in interfaceDisposable
- Returns:
- true if this resource has been disposed
-