ObservableAmb$AmbInnerObserver.smali
.class final Lio/reactivex/internal/operators/observable/ObservableAmb$AmbInnerObserver;
.super Ljava/util/concurrent/atomic/AtomicReference;
.source "ObservableAmb.java"
# interfaces
.implements Lio/reactivex/r;
# annotations
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">",
"Ljava/util/concurrent/atomic/AtomicReference",
"<",
"Lio/reactivex/disposables/b;",
">;",
"Lio/reactivex/r",
"<TT;>;"
}
.end annotation
# static fields
.field private static final serialVersionUID:J = -0x10756d62aa142dccL
# instance fields
.field final actual:Lio/reactivex/r;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/r",
"<-TT;>;"
}
.end annotation
.end field
.field final index:I
.field final parent:Lio/reactivex/internal/operators/observable/n;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/internal/operators/observable/n",
"<TT;>;"
}
.end annotation
.end field
.field won:Z
# direct methods
.method constructor <init>(Lio/reactivex/internal/operators/observable/n;ILio/reactivex/r;)V
.registers 4
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/internal/operators/observable/n",
"<TT;>;I",
"Lio/reactivex/r",
"<-TT;>;)V"
}
.end annotation
.prologue
.line 149
invoke-direct {p0}, Ljava/util/concurrent/atomic/AtomicReference;-><init>()V
.line 150
iput-object p1, p0, Lio/reactivex/internal/operators/observable/ObservableAmb$AmbInnerObserver;->parent:Lio/reactivex/internal/operators/observable/n;
.line 151
iput p2, p0, Lio/reactivex/internal/operators/observable/ObservableAmb$AmbInnerObserver;->index:I
.line 152
iput-object p3, p0, Lio/reactivex/internal/operators/observable/ObservableAmb$AmbInnerObserver;->actual:Lio/reactivex/r;
.line 153
return-void
.end method
# virtual methods
.method public final dispose()V
.registers 1
.prologue
.line 201
invoke-static {p0}, Lio/reactivex/internal/disposables/DisposableHelper;->dispose(Ljava/util/concurrent/atomic/AtomicReference;)Z
.line 202
return-void
.end method
.method public final onComplete()V
.registers 3
.prologue
.line 190
iget-boolean v0, p0, Lio/reactivex/internal/operators/observable/ObservableAmb$AmbInnerObserver;->won:Z
if-eqz v0, :cond_a
.line 191
iget-object v0, p0, Lio/reactivex/internal/operators/observable/ObservableAmb$AmbInnerObserver;->actual:Lio/reactivex/r;
invoke-interface {v0}, Lio/reactivex/r;->onComplete()V
.line 198
:cond_9
:goto_9
return-void
.line 193
:cond_a
iget-object v0, p0, Lio/reactivex/internal/operators/observable/ObservableAmb$AmbInnerObserver;->parent:Lio/reactivex/internal/operators/observable/n;
iget v1, p0, Lio/reactivex/internal/operators/observable/ObservableAmb$AmbInnerObserver;->index:I
invoke-virtual {v0, v1}, Lio/reactivex/internal/operators/observable/n;->fg(I)Z
move-result v0
if-eqz v0, :cond_9
.line 194
const/4 v0, 0x1
iput-boolean v0, p0, Lio/reactivex/internal/operators/observable/ObservableAmb$AmbInnerObserver;->won:Z
.line 195
iget-object v0, p0, Lio/reactivex/internal/operators/observable/ObservableAmb$AmbInnerObserver;->actual:Lio/reactivex/r;
invoke-interface {v0}, Lio/reactivex/r;->onComplete()V
goto :goto_9
.end method
.method public final onError(Ljava/lang/Throwable;)V
.registers 4
.prologue
.line 176
iget-boolean v0, p0, Lio/reactivex/internal/operators/observable/ObservableAmb$AmbInnerObserver;->won:Z
if-eqz v0, :cond_a
.line 177
iget-object v0, p0, Lio/reactivex/internal/operators/observable/ObservableAmb$AmbInnerObserver;->actual:Lio/reactivex/r;
invoke-interface {v0, p1}, Lio/reactivex/r;->onError(Ljava/lang/Throwable;)V
.line 186
:goto_9
return-void
.line 179
:cond_a
iget-object v0, p0, Lio/reactivex/internal/operators/observable/ObservableAmb$AmbInnerObserver;->parent:Lio/reactivex/internal/operators/observable/n;
iget v1, p0, Lio/reactivex/internal/operators/observable/ObservableAmb$AmbInnerObserver;->index:I
invoke-virtual {v0, v1}, Lio/reactivex/internal/operators/observable/n;->fg(I)Z
move-result v0
if-eqz v0, :cond_1d
.line 180
const/4 v0, 0x1
iput-boolean v0, p0, Lio/reactivex/internal/operators/observable/ObservableAmb$AmbInnerObserver;->won:Z
.line 181
iget-object v0, p0, Lio/reactivex/internal/operators/observable/ObservableAmb$AmbInnerObserver;->actual:Lio/reactivex/r;
invoke-interface {v0, p1}, Lio/reactivex/r;->onError(Ljava/lang/Throwable;)V
goto :goto_9
.line 183
:cond_1d
invoke-static {p1}, Lio/reactivex/d/a;->onError(Ljava/lang/Throwable;)V
goto :goto_9
.end method
.method public final onNext(Ljava/lang/Object;)V
.registers 4
.annotation system Ldalvik/annotation/Signature;
value = {
"(TT;)V"
}
.end annotation
.prologue
.line 162
iget-boolean v0, p0, Lio/reactivex/internal/operators/observable/ObservableAmb$AmbInnerObserver;->won:Z
if-eqz v0, :cond_a
.line 163
iget-object v0, p0, Lio/reactivex/internal/operators/observable/ObservableAmb$AmbInnerObserver;->actual:Lio/reactivex/r;
invoke-interface {v0, p1}, Lio/reactivex/r;->onNext(Ljava/lang/Object;)V
.line 172
:goto_9
return-void
.line 165
:cond_a
iget-object v0, p0, Lio/reactivex/internal/operators/observable/ObservableAmb$AmbInnerObserver;->parent:Lio/reactivex/internal/operators/observable/n;
iget v1, p0, Lio/reactivex/internal/operators/observable/ObservableAmb$AmbInnerObserver;->index:I
invoke-virtual {v0, v1}, Lio/reactivex/internal/operators/observable/n;->fg(I)Z
move-result v0
if-eqz v0, :cond_1d
.line 166
const/4 v0, 0x1
iput-boolean v0, p0, Lio/reactivex/internal/operators/observable/ObservableAmb$AmbInnerObserver;->won:Z
.line 167
iget-object v0, p0, Lio/reactivex/internal/operators/observable/ObservableAmb$AmbInnerObserver;->actual:Lio/reactivex/r;
invoke-interface {v0, p1}, Lio/reactivex/r;->onNext(Ljava/lang/Object;)V
goto :goto_9
.line 169
:cond_1d
invoke-virtual {p0}, Lio/reactivex/internal/operators/observable/ObservableAmb$AmbInnerObserver;->get()Ljava/lang/Object;
move-result-object v0
check-cast v0, Lio/reactivex/disposables/b;
invoke-interface {v0}, Lio/reactivex/disposables/b;->dispose()V
goto :goto_9
.end method
.method public final onSubscribe(Lio/reactivex/disposables/b;)V
.registers 2
.prologue
.line 157
invoke-static {p0, p1}, Lio/reactivex/internal/disposables/DisposableHelper;->setOnce(Ljava/util/concurrent/atomic/AtomicReference;Lio/reactivex/disposables/b;)Z
.line 158
return-void
.end method