ObservableWithLatestFrom$WithLatestFromObserver.smali
.class final Lio/reactivex/internal/operators/observable/ObservableWithLatestFrom$WithLatestFromObserver;
.super Ljava/util/concurrent/atomic/AtomicReference;
.source "ObservableWithLatestFrom.java"
# interfaces
.implements Lio/reactivex/disposables/b;
.implements Lio/reactivex/r;
# annotations
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
"U:",
"Ljava/lang/Object;",
"R:",
"Ljava/lang/Object;",
">",
"Ljava/util/concurrent/atomic/AtomicReference",
"<TU;>;",
"Lio/reactivex/disposables/b;",
"Lio/reactivex/r",
"<TT;>;"
}
.end annotation
# static fields
.field private static final serialVersionUID:J = -0x455524b80cbc46bL
# instance fields
.field final actual:Lio/reactivex/r;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/r",
"<-TR;>;"
}
.end annotation
.end field
.field final combiner:Lio/reactivex/b/c;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/b/c",
"<-TT;-TU;+TR;>;"
}
.end annotation
.end field
.field final other:Ljava/util/concurrent/atomic/AtomicReference;
.annotation system Ldalvik/annotation/Signature;
value = {
"Ljava/util/concurrent/atomic/AtomicReference",
"<",
"Lio/reactivex/disposables/b;",
">;"
}
.end annotation
.end field
.field final s:Ljava/util/concurrent/atomic/AtomicReference;
.annotation system Ldalvik/annotation/Signature;
value = {
"Ljava/util/concurrent/atomic/AtomicReference",
"<",
"Lio/reactivex/disposables/b;",
">;"
}
.end annotation
.end field
# direct methods
.method constructor <init>(Lio/reactivex/r;Lio/reactivex/b/c;)V
.registers 4
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/r",
"<-TR;>;",
"Lio/reactivex/b/c",
"<-TT;-TU;+TR;>;)V"
}
.end annotation
.prologue
.line 60
invoke-direct {p0}, Ljava/util/concurrent/atomic/AtomicReference;-><init>()V
.line 56
new-instance v0, Ljava/util/concurrent/atomic/AtomicReference;
invoke-direct {v0}, Ljava/util/concurrent/atomic/AtomicReference;-><init>()V
iput-object v0, p0, Lio/reactivex/internal/operators/observable/ObservableWithLatestFrom$WithLatestFromObserver;->s:Ljava/util/concurrent/atomic/AtomicReference;
.line 58
new-instance v0, Ljava/util/concurrent/atomic/AtomicReference;
invoke-direct {v0}, Ljava/util/concurrent/atomic/AtomicReference;-><init>()V
iput-object v0, p0, Lio/reactivex/internal/operators/observable/ObservableWithLatestFrom$WithLatestFromObserver;->other:Ljava/util/concurrent/atomic/AtomicReference;
.line 61
iput-object p1, p0, Lio/reactivex/internal/operators/observable/ObservableWithLatestFrom$WithLatestFromObserver;->actual:Lio/reactivex/r;
.line 62
iput-object p2, p0, Lio/reactivex/internal/operators/observable/ObservableWithLatestFrom$WithLatestFromObserver;->combiner:Lio/reactivex/b/c;
.line 63
return-void
.end method
# virtual methods
.method public final dispose()V
.registers 2
.prologue
.line 100
iget-object v0, p0, Lio/reactivex/internal/operators/observable/ObservableWithLatestFrom$WithLatestFromObserver;->s:Ljava/util/concurrent/atomic/AtomicReference;
invoke-static {v0}, Lio/reactivex/internal/disposables/DisposableHelper;->dispose(Ljava/util/concurrent/atomic/AtomicReference;)Z
.line 101
iget-object v0, p0, Lio/reactivex/internal/operators/observable/ObservableWithLatestFrom$WithLatestFromObserver;->other:Ljava/util/concurrent/atomic/AtomicReference;
invoke-static {v0}, Lio/reactivex/internal/disposables/DisposableHelper;->dispose(Ljava/util/concurrent/atomic/AtomicReference;)Z
.line 102
return-void
.end method
.method public final isDisposed()Z
.registers 2
.prologue
.line 106
iget-object v0, p0, Lio/reactivex/internal/operators/observable/ObservableWithLatestFrom$WithLatestFromObserver;->s:Ljava/util/concurrent/atomic/AtomicReference;
invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object;
move-result-object v0
check-cast v0, Lio/reactivex/disposables/b;
invoke-static {v0}, Lio/reactivex/internal/disposables/DisposableHelper;->isDisposed(Lio/reactivex/disposables/b;)Z
move-result v0
return v0
.end method
.method public final onComplete()V
.registers 2
.prologue
.line 94
iget-object v0, p0, Lio/reactivex/internal/operators/observable/ObservableWithLatestFrom$WithLatestFromObserver;->other:Ljava/util/concurrent/atomic/AtomicReference;
invoke-static {v0}, Lio/reactivex/internal/disposables/DisposableHelper;->dispose(Ljava/util/concurrent/atomic/AtomicReference;)Z
.line 95
iget-object v0, p0, Lio/reactivex/internal/operators/observable/ObservableWithLatestFrom$WithLatestFromObserver;->actual:Lio/reactivex/r;
invoke-interface {v0}, Lio/reactivex/r;->onComplete()V
.line 96
return-void
.end method
.method public final onError(Ljava/lang/Throwable;)V
.registers 3
.prologue
.line 88
iget-object v0, p0, Lio/reactivex/internal/operators/observable/ObservableWithLatestFrom$WithLatestFromObserver;->other:Ljava/util/concurrent/atomic/AtomicReference;
invoke-static {v0}, Lio/reactivex/internal/disposables/DisposableHelper;->dispose(Ljava/util/concurrent/atomic/AtomicReference;)Z
.line 89
iget-object v0, p0, Lio/reactivex/internal/operators/observable/ObservableWithLatestFrom$WithLatestFromObserver;->actual:Lio/reactivex/r;
invoke-interface {v0, p1}, Lio/reactivex/r;->onError(Ljava/lang/Throwable;)V
.line 90
return-void
.end method
.method public final onNext(Ljava/lang/Object;)V
.registers 4
.annotation system Ldalvik/annotation/Signature;
value = {
"(TT;)V"
}
.end annotation
.prologue
.line 71
invoke-virtual {p0}, Lio/reactivex/internal/operators/observable/ObservableWithLatestFrom$WithLatestFromObserver;->get()Ljava/lang/Object;
move-result-object v0
.line 72
if-eqz v0, :cond_17
.line 75
:try_start_6
iget-object v1, p0, Lio/reactivex/internal/operators/observable/ObservableWithLatestFrom$WithLatestFromObserver;->combiner:Lio/reactivex/b/c;
invoke-interface {v1, p1, v0}, Lio/reactivex/b/c;->apply(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v0
const-string v1, "The combiner returned a null value"
invoke-static {v0, v1}, Lio/reactivex/internal/functions/aj;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
:try_end_11
.catch Ljava/lang/Throwable; {:try_start_6 .. :try_end_11} :catch_18
move-result-object v0
.line 82
iget-object v1, p0, Lio/reactivex/internal/operators/observable/ObservableWithLatestFrom$WithLatestFromObserver;->actual:Lio/reactivex/r;
invoke-interface {v1, v0}, Lio/reactivex/r;->onNext(Ljava/lang/Object;)V
.line 84
:cond_17
:goto_17
return-void
.line 76
:catch_18
move-exception v0
.line 77
invoke-static {v0}, Lio/reactivex/exceptions/d;->throwIfFatal(Ljava/lang/Throwable;)V
.line 78
invoke-virtual {p0}, Lio/reactivex/internal/operators/observable/ObservableWithLatestFrom$WithLatestFromObserver;->dispose()V
.line 79
iget-object v1, p0, Lio/reactivex/internal/operators/observable/ObservableWithLatestFrom$WithLatestFromObserver;->actual:Lio/reactivex/r;
invoke-interface {v1, v0}, Lio/reactivex/r;->onError(Ljava/lang/Throwable;)V
goto :goto_17
.end method
.method public final onSubscribe(Lio/reactivex/disposables/b;)V
.registers 3
.prologue
.line 66
iget-object v0, p0, Lio/reactivex/internal/operators/observable/ObservableWithLatestFrom$WithLatestFromObserver;->s:Ljava/util/concurrent/atomic/AtomicReference;
invoke-static {v0, p1}, Lio/reactivex/internal/disposables/DisposableHelper;->setOnce(Ljava/util/concurrent/atomic/AtomicReference;Lio/reactivex/disposables/b;)Z
.line 67
return-void
.end method
.method public final otherError(Ljava/lang/Throwable;)V
.registers 3
.prologue
.line 114
iget-object v0, p0, Lio/reactivex/internal/operators/observable/ObservableWithLatestFrom$WithLatestFromObserver;->s:Ljava/util/concurrent/atomic/AtomicReference;
invoke-static {v0}, Lio/reactivex/internal/disposables/DisposableHelper;->dispose(Ljava/util/concurrent/atomic/AtomicReference;)Z
.line 115
iget-object v0, p0, Lio/reactivex/internal/operators/observable/ObservableWithLatestFrom$WithLatestFromObserver;->actual:Lio/reactivex/r;
invoke-interface {v0, p1}, Lio/reactivex/r;->onError(Ljava/lang/Throwable;)V
.line 116
return-void
.end method
.method public final setOther(Lio/reactivex/disposables/b;)Z
.registers 3
.prologue
.line 110
iget-object v0, p0, Lio/reactivex/internal/operators/observable/ObservableWithLatestFrom$WithLatestFromObserver;->other:Ljava/util/concurrent/atomic/AtomicReference;
invoke-static {v0, p1}, Lio/reactivex/internal/disposables/DisposableHelper;->setOnce(Ljava/util/concurrent/atomic/AtomicReference;Lio/reactivex/disposables/b;)Z
move-result v0
return v0
.end method