ObservableAmb.AmbCoordinator

java.lang.Object
- io.reactivex.rxjava3.internal.operators.observable.ObservableAmb.AmbCoordinator<T>

All Implemented Interfaces:: Disposable

Enclosing class:: ObservableAmb<T>

static final class ObservableAmb.AmbCoordinator<T>
extends java.lang.Object
implements Disposable

Field Summary

Fields
Modifier and Type	Field	Description
`(package private) Observer<? super T>`	`downstream`
`(package private) ObservableAmb.AmbInnerObserver<T>[]`	`observers`
`(package private) java.util.concurrent.atomic.AtomicInteger`	`winner`

Constructor Summary

Constructors
Constructor Description

AmbCoordinator(Observer<? super T> actual, int count)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`dispose()`	Dispose the resource, the operation should be idempotent.
`boolean`	`isDisposed()`	Returns true if this resource has been disposed.
`void`	`subscribe(ObservableSource<? extends T>[] sources)`
`boolean`	`win(int index)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - downstream
```
final Observer<? super T> downstream
```
  - observers
```
final ObservableAmb.AmbInnerObserver<T>[] observers
```
  - winner
```
final java.util.concurrent.atomic.AtomicInteger winner
```
- Constructor Detail
  - AmbCoordinator
```
AmbCoordinator(Observer<? super T> actual,
               int count)
```
- Method Detail
  - subscribe
```
public void subscribe(ObservableSource<? extends T>[] sources)
```
  - 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 interface Disposable
  - isDisposed
```
public boolean isDisposed()
```
    Description copied from interface: Disposable
    
    Returns true if this resource has been disposed.
    
    Specified by:
    
    isDisposed in interface Disposable
    
    Returns:
    
    true if this resource has been disposed