CompletableAmb.Amb

java.lang.Object
- io.reactivex.rxjava3.internal.operators.completable.CompletableAmb.Amb

All Implemented Interfaces:: CompletableObserver

Enclosing class:: CompletableAmb

static final class CompletableAmb.Amb
extends java.lang.Object
implements CompletableObserver

Field Summary

Fields
Modifier and Type	Field	Description
`(package private) CompletableObserver`	`downstream`
`(package private) java.util.concurrent.atomic.AtomicBoolean`	`once`
`(package private) CompositeDisposable`	`set`
`(package private) Disposable`	`upstream`

Constructor Summary

Constructors
Constructor Description

Amb(java.util.concurrent.atomic.AtomicBoolean once, CompositeDisposable set, CompletableObserver observer)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`onComplete()`	Called once the deferred computation completes normally.
`void`	`onError(java.lang.Throwable e)`	Called once if the deferred computation 'throws' an exception.
`void`	`onSubscribe(Disposable d)`	Called once by the `Completable` to set a `Disposable` on this instance which then can be used to cancel the subscription at any time.

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

- Field Detail
  - once
```
final java.util.concurrent.atomic.AtomicBoolean once
```
  - set
```
final CompositeDisposable set
```
  - downstream
```
final CompletableObserver downstream
```
  - upstream
```
Disposable upstream
```
- Constructor Detail
  - Amb
```
Amb(java.util.concurrent.atomic.AtomicBoolean once,
    CompositeDisposable set,
    CompletableObserver observer)
```
- Method Detail
  - onComplete
```
public void onComplete()
```
    Description copied from interface: CompletableObserver
    
    Called once the deferred computation completes normally.
    
    Specified by:
    
    onComplete in interface CompletableObserver
  - onError
```
public void onError(java.lang.Throwable e)
```
    Description copied from interface: CompletableObserver
    
    Called once if the deferred computation 'throws' an exception.
    
    Specified by:
    
    onError in interface CompletableObserver
    
    Parameters:
    
    e - the exception, not null.
  - onSubscribe
```
public void onSubscribe(Disposable d)
```
    Description copied from interface: CompletableObserver
    
    Called once by the Completable to set a Disposable on this instance which then can be used to cancel the subscription at any time.
    
    Specified by:
    
    onSubscribe in interface CompletableObserver
    
    Parameters:
    
    d - the Disposable instance to call dispose on for cancellation, not null