DeferredScalarObserver.smali
3.4 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
.class public abstract Lio/reactivex/internal/observers/DeferredScalarObserver;
.super Lio/reactivex/internal/observers/DeferredScalarDisposable;
.source "DeferredScalarObserver.java"
# interfaces
.implements Lio/reactivex/Observer;
# annotations
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
"R:",
"Ljava/lang/Object;",
">",
"Lio/reactivex/internal/observers/DeferredScalarDisposable<",
"TR;>;",
"Lio/reactivex/Observer<",
"TT;>;"
}
.end annotation
# static fields
.field private static final serialVersionUID:J = -0x3b1b71a072cf1ebL
# instance fields
.field protected s:Lio/reactivex/disposables/Disposable;
# direct methods
.method public constructor <init>(Lio/reactivex/Observer;)V
.locals 0
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/Observer<",
"-TR;>;)V"
}
.end annotation
.line 39
invoke-direct {p0, p1}, Lio/reactivex/internal/observers/DeferredScalarDisposable;-><init>(Lio/reactivex/Observer;)V
return-void
.end method
# virtual methods
.method public dispose()V
.locals 1
.line 70
invoke-super {p0}, Lio/reactivex/internal/observers/DeferredScalarDisposable;->dispose()V
.line 71
iget-object v0, p0, Lio/reactivex/internal/observers/DeferredScalarObserver;->s:Lio/reactivex/disposables/Disposable;
invoke-interface {v0}, Lio/reactivex/disposables/Disposable;->dispose()V
return-void
.end method
.method public onComplete()V
.locals 2
.line 59
iget-object v0, p0, Lio/reactivex/internal/observers/DeferredScalarObserver;->value:Ljava/lang/Object;
if-eqz v0, :cond_0
const/4 v1, 0x0
.line 61
iput-object v1, p0, Lio/reactivex/internal/observers/DeferredScalarObserver;->value:Ljava/lang/Object;
.line 62
invoke-virtual {p0, v0}, Lio/reactivex/internal/observers/DeferredScalarObserver;->complete(Ljava/lang/Object;)V
goto :goto_0
.line 64
:cond_0
invoke-virtual {p0}, Lio/reactivex/internal/observers/DeferredScalarObserver;->complete()V
:goto_0
return-void
.end method
.method public onError(Ljava/lang/Throwable;)V
.locals 1
const/4 v0, 0x0
.line 53
iput-object v0, p0, Lio/reactivex/internal/observers/DeferredScalarObserver;->value:Ljava/lang/Object;
.line 54
invoke-virtual {p0, p1}, Lio/reactivex/internal/observers/DeferredScalarObserver;->error(Ljava/lang/Throwable;)V
return-void
.end method
.method public onSubscribe(Lio/reactivex/disposables/Disposable;)V
.locals 1
.line 44
iget-object v0, p0, Lio/reactivex/internal/observers/DeferredScalarObserver;->s:Lio/reactivex/disposables/Disposable;
invoke-static {v0, p1}, Lio/reactivex/internal/disposables/DisposableHelper;->validate(Lio/reactivex/disposables/Disposable;Lio/reactivex/disposables/Disposable;)Z
move-result v0
if-eqz v0, :cond_0
.line 45
iput-object p1, p0, Lio/reactivex/internal/observers/DeferredScalarObserver;->s:Lio/reactivex/disposables/Disposable;
.line 47
iget-object p1, p0, Lio/reactivex/internal/observers/DeferredScalarObserver;->actual:Lio/reactivex/Observer;
invoke-interface {p1, p0}, Lio/reactivex/Observer;->onSubscribe(Lio/reactivex/disposables/Disposable;)V
:cond_0
return-void
.end method