ResultObservable$ResultObserver.smali
.class Lretrofit2/adapter/rxjava2/ResultObservable$ResultObserver;
.super Ljava/lang/Object;
.source "ResultObservable.java"
# interfaces
.implements Lio/reactivex/Observer;
# annotations
.annotation system Ldalvik/annotation/EnclosingClass;
value = Lretrofit2/adapter/rxjava2/ResultObservable;
.end annotation
.annotation system Ldalvik/annotation/InnerClass;
accessFlags = 0xa
name = "ResultObserver"
.end annotation
.annotation system Ldalvik/annotation/Signature;
value = {
"<R:",
"Ljava/lang/Object;",
">",
"Ljava/lang/Object;",
"Lio/reactivex/Observer<",
"Lretrofit2/Response<",
"TR;>;>;"
}
.end annotation
# instance fields
.field private final observer:Lio/reactivex/Observer;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/Observer<",
"-",
"Lretrofit2/adapter/rxjava2/Result<",
"TR;>;>;"
}
.end annotation
.end field
# direct methods
.method static constructor <clinit>()V
.registers 1
return-void
.end method
.method constructor <init>(Lio/reactivex/Observer;)V
.registers 2
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/Observer<",
"-",
"Lretrofit2/adapter/rxjava2/Result<",
"TR;>;>;)V"
}
.end annotation
.line 40
.local p0, "this":Lretrofit2/adapter/rxjava2/ResultObservable$ResultObserver;, "Lretrofit2/adapter/rxjava2/ResultObservable$ResultObserver<TR;>;"
.local p1, "observer":Lio/reactivex/Observer;, "Lio/reactivex/Observer<-Lretrofit2/adapter/rxjava2/Result<TR;>;>;"
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
.line 41
iput-object p1, p0, Lretrofit2/adapter/rxjava2/ResultObservable$ResultObserver;->observer:Lio/reactivex/Observer;
.line 42
return-void
.end method
# virtual methods
.method public onComplete()V
.registers 2
.line 68
.local p0, "this":Lretrofit2/adapter/rxjava2/ResultObservable$ResultObserver;, "Lretrofit2/adapter/rxjava2/ResultObservable$ResultObserver<TR;>;"
iget-object v0, p0, Lretrofit2/adapter/rxjava2/ResultObservable$ResultObserver;->observer:Lio/reactivex/Observer;
invoke-interface {v0}, Lio/reactivex/Observer;->onComplete()V
.line 69
return-void
.end method
.method public onError(Ljava/lang/Throwable;)V
.registers 7
.param p1, "throwable" # Ljava/lang/Throwable;
.line 54
.local p0, "this":Lretrofit2/adapter/rxjava2/ResultObservable$ResultObserver;, "Lretrofit2/adapter/rxjava2/ResultObservable$ResultObserver<TR;>;"
:try_start_0
iget-object v0, p0, Lretrofit2/adapter/rxjava2/ResultObservable$ResultObserver;->observer:Lio/reactivex/Observer;
invoke-static {p1}, Lretrofit2/adapter/rxjava2/Result;->error(Ljava/lang/Throwable;)Lretrofit2/adapter/rxjava2/Result;
move-result-object v1
invoke-interface {v0, v1}, Lio/reactivex/Observer;->onNext(Ljava/lang/Object;)V
:try_end_9
.catchall {:try_start_0 .. :try_end_9} :catchall_10
.line 63
nop
.line 64
iget-object v0, p0, Lretrofit2/adapter/rxjava2/ResultObservable$ResultObserver;->observer:Lio/reactivex/Observer;
invoke-interface {v0}, Lio/reactivex/Observer;->onComplete()V
.line 65
return-void
.line 55
:catchall_10
move-exception v0
.line 57
.local v0, "t":Ljava/lang/Throwable;
:try_start_11
iget-object v1, p0, Lretrofit2/adapter/rxjava2/ResultObservable$ResultObserver;->observer:Lio/reactivex/Observer;
invoke-interface {v1, v0}, Lio/reactivex/Observer;->onError(Ljava/lang/Throwable;)V
:try_end_16
.catchall {:try_start_11 .. :try_end_16} :catchall_17
.line 61
goto :goto_2c
.line 58
:catchall_17
move-exception v1
.line 59
.local v1, "inner":Ljava/lang/Throwable;
invoke-static {v1}, Lio/reactivex/exceptions/Exceptions;->throwIfFatal(Ljava/lang/Throwable;)V
.line 60
new-instance v2, Lio/reactivex/exceptions/CompositeException;
const/4 v3, 0x2
new-array v3, v3, [Ljava/lang/Throwable;
const/4 v4, 0x0
aput-object v0, v3, v4
const/4 v4, 0x1
aput-object v1, v3, v4
invoke-direct {v2, v3}, Lio/reactivex/exceptions/CompositeException;-><init>([Ljava/lang/Throwable;)V
invoke-static {v2}, Lio/reactivex/plugins/RxJavaPlugins;->onError(Ljava/lang/Throwable;)V
.line 62
.end local v1 # "inner":Ljava/lang/Throwable;
:goto_2c
return-void
.end method
.method public bridge synthetic onNext(Ljava/lang/Object;)V
.registers 2
.line 37
.local p0, "this":Lretrofit2/adapter/rxjava2/ResultObservable$ResultObserver;, "Lretrofit2/adapter/rxjava2/ResultObservable$ResultObserver<TR;>;"
check-cast p1, Lretrofit2/Response;
invoke-virtual {p0, p1}, Lretrofit2/adapter/rxjava2/ResultObservable$ResultObserver;->onNext(Lretrofit2/Response;)V
return-void
.end method
.method public onNext(Lretrofit2/Response;)V
.registers 4
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lretrofit2/Response<",
"TR;>;)V"
}
.end annotation
.line 49
.local p0, "this":Lretrofit2/adapter/rxjava2/ResultObservable$ResultObserver;, "Lretrofit2/adapter/rxjava2/ResultObservable$ResultObserver<TR;>;"
.local p1, "response":Lretrofit2/Response;, "Lretrofit2/Response<TR;>;"
iget-object v0, p0, Lretrofit2/adapter/rxjava2/ResultObservable$ResultObserver;->observer:Lio/reactivex/Observer;
invoke-static {p1}, Lretrofit2/adapter/rxjava2/Result;->response(Lretrofit2/Response;)Lretrofit2/adapter/rxjava2/Result;
move-result-object v1
invoke-interface {v0, v1}, Lio/reactivex/Observer;->onNext(Ljava/lang/Object;)V
.line 50
return-void
.end method
.method public onSubscribe(Lio/reactivex/disposables/Disposable;)V
.registers 3
.param p1, "disposable" # Lio/reactivex/disposables/Disposable;
.line 45
.local p0, "this":Lretrofit2/adapter/rxjava2/ResultObservable$ResultObserver;, "Lretrofit2/adapter/rxjava2/ResultObservable$ResultObserver<TR;>;"
iget-object v0, p0, Lretrofit2/adapter/rxjava2/ResultObservable$ResultObserver;->observer:Lio/reactivex/Observer;
invoke-interface {v0, p1}, Lio/reactivex/Observer;->onSubscribe(Lio/reactivex/disposables/Disposable;)V
.line 46
return-void
.end method