BlockingBaseObserver.smali
3.9 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
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
.class public abstract Lio/reactivex/internal/observers/BlockingBaseObserver;
.super Ljava/util/concurrent/CountDownLatch;
.source "BlockingBaseObserver.java"
# interfaces
.implements Lio/reactivex/Observer;
.implements Lio/reactivex/disposables/Disposable;
# annotations
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">",
"Ljava/util/concurrent/CountDownLatch;",
"Lio/reactivex/Observer<",
"TT;>;",
"Lio/reactivex/disposables/Disposable;"
}
.end annotation
# instance fields
.field volatile cancelled:Z
.field d:Lio/reactivex/disposables/Disposable;
.field error:Ljava/lang/Throwable;
.field value:Ljava/lang/Object;
.annotation system Ldalvik/annotation/Signature;
value = {
"TT;"
}
.end annotation
.end field
# direct methods
.method public constructor <init>()V
.locals 1
const/4 v0, 0x1
.line 32
invoke-direct {p0, v0}, Ljava/util/concurrent/CountDownLatch;-><init>(I)V
return-void
.end method
# virtual methods
.method public final blockingGet()Ljava/lang/Object;
.locals 4
.annotation system Ldalvik/annotation/Signature;
value = {
"()TT;"
}
.end annotation
.line 68
invoke-virtual {p0}, Lio/reactivex/internal/observers/BlockingBaseObserver;->getCount()J
move-result-wide v0
const-wide/16 v2, 0x0
cmp-long v0, v0, v2
if-eqz v0, :cond_0
.line 70
:try_start_0
invoke-static {}, Lio/reactivex/internal/util/BlockingHelper;->verifyNonBlocking()V
.line 71
invoke-virtual {p0}, Lio/reactivex/internal/observers/BlockingBaseObserver;->await()V
:try_end_0
.catch Ljava/lang/InterruptedException; {:try_start_0 .. :try_end_0} :catch_0
goto :goto_0
:catch_0
move-exception v0
.line 73
invoke-virtual {p0}, Lio/reactivex/internal/observers/BlockingBaseObserver;->dispose()V
.line 74
invoke-static {v0}, Lio/reactivex/internal/util/ExceptionHelper;->wrapOrThrow(Ljava/lang/Throwable;)Ljava/lang/RuntimeException;
move-result-object v0
throw v0
.line 78
:cond_0
:goto_0
iget-object v0, p0, Lio/reactivex/internal/observers/BlockingBaseObserver;->error:Ljava/lang/Throwable;
if-nez v0, :cond_1
.line 82
iget-object v0, p0, Lio/reactivex/internal/observers/BlockingBaseObserver;->value:Ljava/lang/Object;
return-object v0
.line 80
:cond_1
invoke-static {v0}, Lio/reactivex/internal/util/ExceptionHelper;->wrapOrThrow(Ljava/lang/Throwable;)Ljava/lang/RuntimeException;
move-result-object v0
throw v0
.end method
.method public final dispose()V
.locals 1
const/4 v0, 0x1
.line 50
iput-boolean v0, p0, Lio/reactivex/internal/observers/BlockingBaseObserver;->cancelled:Z
.line 51
iget-object v0, p0, Lio/reactivex/internal/observers/BlockingBaseObserver;->d:Lio/reactivex/disposables/Disposable;
if-eqz v0, :cond_0
.line 53
invoke-interface {v0}, Lio/reactivex/disposables/Disposable;->dispose()V
:cond_0
return-void
.end method
.method public final isDisposed()Z
.locals 1
.line 59
iget-boolean v0, p0, Lio/reactivex/internal/observers/BlockingBaseObserver;->cancelled:Z
return v0
.end method
.method public final onComplete()V
.locals 0
.line 45
invoke-virtual {p0}, Lio/reactivex/internal/observers/BlockingBaseObserver;->countDown()V
return-void
.end method
.method public final onSubscribe(Lio/reactivex/disposables/Disposable;)V
.locals 1
.line 37
iput-object p1, p0, Lio/reactivex/internal/observers/BlockingBaseObserver;->d:Lio/reactivex/disposables/Disposable;
.line 38
iget-boolean v0, p0, Lio/reactivex/internal/observers/BlockingBaseObserver;->cancelled:Z
if-eqz v0, :cond_0
.line 39
invoke-interface {p1}, Lio/reactivex/disposables/Disposable;->dispose()V
:cond_0
return-void
.end method