d.smali
.class public final Lio/reactivex/observers/d;
.super Ljava/lang/Object;
.source "SourceFile"
# interfaces
.implements Lio/reactivex/s;
.implements Lio/reactivex/disposables/b;
# annotations
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">",
"Ljava/lang/Object;",
"Lio/reactivex/s<",
"TT;>;",
"Lio/reactivex/disposables/b;"
}
.end annotation
# instance fields
.field public final a:Lio/reactivex/s;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/s<",
"-TT;>;"
}
.end annotation
.end field
.field public b:Lio/reactivex/disposables/b;
.field public c:Z
# direct methods
.method public constructor <init>(Lio/reactivex/s;)V
.registers 2
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/s<",
"-TT;>;)V"
}
.end annotation
.line 1
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
.line 2
iput-object p1, p0, Lio/reactivex/observers/d;->a:Lio/reactivex/s;
return-void
.end method
# virtual methods
.method public final dispose()V
.registers 2
iget-object v0, p0, Lio/reactivex/observers/d;->b:Lio/reactivex/disposables/b;
invoke-interface {v0}, Lio/reactivex/disposables/b;->dispose()V
return-void
.end method
.method public final isDisposed()Z
.registers 2
iget-object v0, p0, Lio/reactivex/observers/d;->b:Lio/reactivex/disposables/b;
invoke-interface {v0}, Lio/reactivex/disposables/b;->isDisposed()Z
move-result v0
return v0
.end method
.method public final onComplete()V
.registers 7
.line 1
iget-boolean v0, p0, Lio/reactivex/observers/d;->c:Z
if-eqz v0, :cond_5
return-void
:cond_5
const/4 v0, 0x1
.line 2
iput-boolean v0, p0, Lio/reactivex/observers/d;->c:Z
.line 3
iget-object v1, p0, Lio/reactivex/observers/d;->b:Lio/reactivex/disposables/b;
if-nez v1, :cond_48
.line 4
new-instance v1, Ljava/lang/NullPointerException;
const-string v2, "Subscription not set!"
invoke-direct {v1, v2}, Ljava/lang/NullPointerException;-><init>(Ljava/lang/String;)V
const/4 v2, 0x0
const/4 v3, 0x2
.line 5
:try_start_15
iget-object v4, p0, Lio/reactivex/observers/d;->a:Lio/reactivex/s;
sget-object v5, Lio/reactivex/internal/disposables/d;->INSTANCE:Lio/reactivex/internal/disposables/d;
invoke-interface {v4, v5}, Lio/reactivex/s;->onSubscribe(Lio/reactivex/disposables/b;)V
:try_end_1c
.catchall {:try_start_15 .. :try_end_1c} :catchall_35
.line 6
:try_start_1c
iget-object v4, p0, Lio/reactivex/observers/d;->a:Lio/reactivex/s;
invoke-interface {v4, v1}, Lio/reactivex/s;->onError(Ljava/lang/Throwable;)V
:try_end_21
.catchall {:try_start_1c .. :try_end_21} :catchall_22
goto :goto_47
:catchall_22
move-exception v4
.line 7
invoke-static {v4}, Lcom/shopee/app/dre/codepush/task/a;->m(Ljava/lang/Throwable;)V
.line 8
new-instance v5, Lio/reactivex/exceptions/a;
new-array v3, v3, [Ljava/lang/Throwable;
aput-object v1, v3, v2
aput-object v4, v3, v0
invoke-direct {v5, v3}, Lio/reactivex/exceptions/a;-><init>([Ljava/lang/Throwable;)V
invoke-static {v5}, Lio/reactivex/plugins/a;->b(Ljava/lang/Throwable;)V
goto :goto_47
:catchall_35
move-exception v4
.line 9
invoke-static {v4}, Lcom/shopee/app/dre/codepush/task/a;->m(Ljava/lang/Throwable;)V
.line 10
new-instance v5, Lio/reactivex/exceptions/a;
new-array v3, v3, [Ljava/lang/Throwable;
aput-object v1, v3, v2
aput-object v4, v3, v0
invoke-direct {v5, v3}, Lio/reactivex/exceptions/a;-><init>([Ljava/lang/Throwable;)V
invoke-static {v5}, Lio/reactivex/plugins/a;->b(Ljava/lang/Throwable;)V
:goto_47
return-void
.line 11
:cond_48
:try_start_48
iget-object v0, p0, Lio/reactivex/observers/d;->a:Lio/reactivex/s;
invoke-interface {v0}, Lio/reactivex/s;->onComplete()V
:try_end_4d
.catchall {:try_start_48 .. :try_end_4d} :catchall_4e
goto :goto_55
:catchall_4e
move-exception v0
.line 12
invoke-static {v0}, Lcom/shopee/app/dre/codepush/task/a;->m(Ljava/lang/Throwable;)V
.line 13
invoke-static {v0}, Lio/reactivex/plugins/a;->b(Ljava/lang/Throwable;)V
:goto_55
return-void
.end method
.method public final onError(Ljava/lang/Throwable;)V
.registers 10
.line 1
iget-boolean v0, p0, Lio/reactivex/observers/d;->c:Z
if-eqz v0, :cond_8
.line 2
invoke-static {p1}, Lio/reactivex/plugins/a;->b(Ljava/lang/Throwable;)V
return-void
:cond_8
const/4 v0, 0x1
.line 3
iput-boolean v0, p0, Lio/reactivex/observers/d;->c:Z
.line 4
iget-object v1, p0, Lio/reactivex/observers/d;->b:Lio/reactivex/disposables/b;
const/4 v2, 0x0
const/4 v3, 0x2
if-nez v1, :cond_5b
.line 5
new-instance v1, Ljava/lang/NullPointerException;
const-string v4, "Subscription not set!"
invoke-direct {v1, v4}, Ljava/lang/NullPointerException;-><init>(Ljava/lang/String;)V
const/4 v4, 0x3
.line 6
:try_start_19
iget-object v5, p0, Lio/reactivex/observers/d;->a:Lio/reactivex/s;
sget-object v6, Lio/reactivex/internal/disposables/d;->INSTANCE:Lio/reactivex/internal/disposables/d;
invoke-interface {v5, v6}, Lio/reactivex/s;->onSubscribe(Lio/reactivex/disposables/b;)V
:try_end_20
.catchall {:try_start_19 .. :try_end_20} :catchall_46
.line 7
:try_start_20
iget-object v5, p0, Lio/reactivex/observers/d;->a:Lio/reactivex/s;
new-instance v6, Lio/reactivex/exceptions/a;
new-array v7, v3, [Ljava/lang/Throwable;
aput-object p1, v7, v2
aput-object v1, v7, v0
invoke-direct {v6, v7}, Lio/reactivex/exceptions/a;-><init>([Ljava/lang/Throwable;)V
invoke-interface {v5, v6}, Lio/reactivex/s;->onError(Ljava/lang/Throwable;)V
:try_end_30
.catchall {:try_start_20 .. :try_end_30} :catchall_31
goto :goto_45
:catchall_31
move-exception v5
.line 8
invoke-static {v5}, Lcom/shopee/app/dre/codepush/task/a;->m(Ljava/lang/Throwable;)V
.line 9
new-instance v6, Lio/reactivex/exceptions/a;
new-array v4, v4, [Ljava/lang/Throwable;
aput-object p1, v4, v2
aput-object v1, v4, v0
aput-object v5, v4, v3
invoke-direct {v6, v4}, Lio/reactivex/exceptions/a;-><init>([Ljava/lang/Throwable;)V
invoke-static {v6}, Lio/reactivex/plugins/a;->b(Ljava/lang/Throwable;)V
:goto_45
return-void
:catchall_46
move-exception v5
.line 10
invoke-static {v5}, Lcom/shopee/app/dre/codepush/task/a;->m(Ljava/lang/Throwable;)V
.line 11
new-instance v6, Lio/reactivex/exceptions/a;
new-array v4, v4, [Ljava/lang/Throwable;
aput-object p1, v4, v2
aput-object v1, v4, v0
aput-object v5, v4, v3
invoke-direct {v6, v4}, Lio/reactivex/exceptions/a;-><init>([Ljava/lang/Throwable;)V
invoke-static {v6}, Lio/reactivex/plugins/a;->b(Ljava/lang/Throwable;)V
return-void
:cond_5b
if-nez p1, :cond_64
.line 12
new-instance p1, Ljava/lang/NullPointerException;
const-string v1, "onError called with null. Null values are generally not allowed in 2.x operators and sources."
invoke-direct {p1, v1}, Ljava/lang/NullPointerException;-><init>(Ljava/lang/String;)V
.line 13
:cond_64
:try_start_64
iget-object v1, p0, Lio/reactivex/observers/d;->a:Lio/reactivex/s;
invoke-interface {v1, p1}, Lio/reactivex/s;->onError(Ljava/lang/Throwable;)V
:try_end_69
.catchall {:try_start_64 .. :try_end_69} :catchall_6a
goto :goto_7c
:catchall_6a
move-exception v1
.line 14
invoke-static {v1}, Lcom/shopee/app/dre/codepush/task/a;->m(Ljava/lang/Throwable;)V
.line 15
new-instance v4, Lio/reactivex/exceptions/a;
new-array v3, v3, [Ljava/lang/Throwable;
aput-object p1, v3, v2
aput-object v1, v3, v0
invoke-direct {v4, v3}, Lio/reactivex/exceptions/a;-><init>([Ljava/lang/Throwable;)V
invoke-static {v4}, Lio/reactivex/plugins/a;->b(Ljava/lang/Throwable;)V
:goto_7c
return-void
.end method
.method public final onNext(Ljava/lang/Object;)V
.registers 7
.annotation system Ldalvik/annotation/Signature;
value = {
"(TT;)V"
}
.end annotation
.line 1
iget-boolean v0, p0, Lio/reactivex/observers/d;->c:Z
if-eqz v0, :cond_5
return-void
.line 2
:cond_5
iget-object v0, p0, Lio/reactivex/observers/d;->b:Lio/reactivex/disposables/b;
const/4 v1, 0x2
const/4 v2, 0x0
const/4 v3, 0x1
if-nez v0, :cond_48
.line 3
iput-boolean v3, p0, Lio/reactivex/observers/d;->c:Z
.line 4
new-instance p1, Ljava/lang/NullPointerException;
const-string v0, "Subscription not set!"
invoke-direct {p1, v0}, Ljava/lang/NullPointerException;-><init>(Ljava/lang/String;)V
.line 5
:try_start_15
iget-object v0, p0, Lio/reactivex/observers/d;->a:Lio/reactivex/s;
sget-object v4, Lio/reactivex/internal/disposables/d;->INSTANCE:Lio/reactivex/internal/disposables/d;
invoke-interface {v0, v4}, Lio/reactivex/s;->onSubscribe(Lio/reactivex/disposables/b;)V
:try_end_1c
.catchall {:try_start_15 .. :try_end_1c} :catchall_35
.line 6
:try_start_1c
iget-object v0, p0, Lio/reactivex/observers/d;->a:Lio/reactivex/s;
invoke-interface {v0, p1}, Lio/reactivex/s;->onError(Ljava/lang/Throwable;)V
:try_end_21
.catchall {:try_start_1c .. :try_end_21} :catchall_22
goto :goto_47
:catchall_22
move-exception v0
.line 7
invoke-static {v0}, Lcom/shopee/app/dre/codepush/task/a;->m(Ljava/lang/Throwable;)V
.line 8
new-instance v4, Lio/reactivex/exceptions/a;
new-array v1, v1, [Ljava/lang/Throwable;
aput-object p1, v1, v2
aput-object v0, v1, v3
invoke-direct {v4, v1}, Lio/reactivex/exceptions/a;-><init>([Ljava/lang/Throwable;)V
invoke-static {v4}, Lio/reactivex/plugins/a;->b(Ljava/lang/Throwable;)V
goto :goto_47
:catchall_35
move-exception v0
.line 9
invoke-static {v0}, Lcom/shopee/app/dre/codepush/task/a;->m(Ljava/lang/Throwable;)V
.line 10
new-instance v4, Lio/reactivex/exceptions/a;
new-array v1, v1, [Ljava/lang/Throwable;
aput-object p1, v1, v2
aput-object v0, v1, v3
invoke-direct {v4, v1}, Lio/reactivex/exceptions/a;-><init>([Ljava/lang/Throwable;)V
invoke-static {v4}, Lio/reactivex/plugins/a;->b(Ljava/lang/Throwable;)V
:goto_47
return-void
:cond_48
if-nez p1, :cond_6d
.line 11
new-instance p1, Ljava/lang/NullPointerException;
const-string v0, "onNext called with null. Null values are generally not allowed in 2.x operators and sources."
invoke-direct {p1, v0}, Ljava/lang/NullPointerException;-><init>(Ljava/lang/String;)V
.line 12
:try_start_51
iget-object v0, p0, Lio/reactivex/observers/d;->b:Lio/reactivex/disposables/b;
invoke-interface {v0}, Lio/reactivex/disposables/b;->dispose()V
:try_end_56
.catchall {:try_start_51 .. :try_end_56} :catchall_5a
.line 13
invoke-virtual {p0, p1}, Lio/reactivex/observers/d;->onError(Ljava/lang/Throwable;)V
return-void
:catchall_5a
move-exception v0
.line 14
invoke-static {v0}, Lcom/shopee/app/dre/codepush/task/a;->m(Ljava/lang/Throwable;)V
.line 15
new-instance v4, Lio/reactivex/exceptions/a;
new-array v1, v1, [Ljava/lang/Throwable;
aput-object p1, v1, v2
aput-object v0, v1, v3
invoke-direct {v4, v1}, Lio/reactivex/exceptions/a;-><init>([Ljava/lang/Throwable;)V
invoke-virtual {p0, v4}, Lio/reactivex/observers/d;->onError(Ljava/lang/Throwable;)V
return-void
.line 16
:cond_6d
:try_start_6d
iget-object v0, p0, Lio/reactivex/observers/d;->a:Lio/reactivex/s;
invoke-interface {v0, p1}, Lio/reactivex/s;->onNext(Ljava/lang/Object;)V
:try_end_72
.catchall {:try_start_6d .. :try_end_72} :catchall_73
goto :goto_7f
:catchall_73
move-exception p1
.line 17
invoke-static {p1}, Lcom/shopee/app/dre/codepush/task/a;->m(Ljava/lang/Throwable;)V
.line 18
:try_start_77
iget-object v0, p0, Lio/reactivex/observers/d;->b:Lio/reactivex/disposables/b;
invoke-interface {v0}, Lio/reactivex/disposables/b;->dispose()V
:try_end_7c
.catchall {:try_start_77 .. :try_end_7c} :catchall_80
.line 19
invoke-virtual {p0, p1}, Lio/reactivex/observers/d;->onError(Ljava/lang/Throwable;)V
:goto_7f
return-void
:catchall_80
move-exception v0
.line 20
invoke-static {v0}, Lcom/shopee/app/dre/codepush/task/a;->m(Ljava/lang/Throwable;)V
.line 21
new-instance v4, Lio/reactivex/exceptions/a;
new-array v1, v1, [Ljava/lang/Throwable;
aput-object p1, v1, v2
aput-object v0, v1, v3
invoke-direct {v4, v1}, Lio/reactivex/exceptions/a;-><init>([Ljava/lang/Throwable;)V
invoke-virtual {p0, v4}, Lio/reactivex/observers/d;->onError(Ljava/lang/Throwable;)V
return-void
.end method
.method public final onSubscribe(Lio/reactivex/disposables/b;)V
.registers 7
.line 1
iget-object v0, p0, Lio/reactivex/observers/d;->b:Lio/reactivex/disposables/b;
invoke-static {v0, p1}, Lio/reactivex/internal/disposables/c;->validate(Lio/reactivex/disposables/b;Lio/reactivex/disposables/b;)Z
move-result v0
if-eqz v0, :cond_32
.line 2
iput-object p1, p0, Lio/reactivex/observers/d;->b:Lio/reactivex/disposables/b;
.line 3
:try_start_a
iget-object v0, p0, Lio/reactivex/observers/d;->a:Lio/reactivex/s;
invoke-interface {v0, p0}, Lio/reactivex/s;->onSubscribe(Lio/reactivex/disposables/b;)V
:try_end_f
.catchall {:try_start_a .. :try_end_f} :catchall_10
goto :goto_32
:catchall_10
move-exception v0
.line 4
invoke-static {v0}, Lcom/shopee/app/dre/codepush/task/a;->m(Ljava/lang/Throwable;)V
const/4 v1, 0x1
.line 5
iput-boolean v1, p0, Lio/reactivex/observers/d;->c:Z
.line 6
:try_start_17
invoke-interface {p1}, Lio/reactivex/disposables/b;->dispose()V
:try_end_1a
.catchall {:try_start_17 .. :try_end_1a} :catchall_1e
.line 7
invoke-static {v0}, Lio/reactivex/plugins/a;->b(Ljava/lang/Throwable;)V
goto :goto_32
:catchall_1e
move-exception p1
.line 8
invoke-static {p1}, Lcom/shopee/app/dre/codepush/task/a;->m(Ljava/lang/Throwable;)V
.line 9
new-instance v2, Lio/reactivex/exceptions/a;
const/4 v3, 0x2
new-array v3, v3, [Ljava/lang/Throwable;
const/4 v4, 0x0
aput-object v0, v3, v4
aput-object p1, v3, v1
invoke-direct {v2, v3}, Lio/reactivex/exceptions/a;-><init>([Ljava/lang/Throwable;)V
invoke-static {v2}, Lio/reactivex/plugins/a;->b(Ljava/lang/Throwable;)V
:cond_32
:goto_32
return-void
.end method