ResourceObserver.smali
4.3 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
.class public abstract Lio/reactivex/observers/ResourceObserver;
.super Ljava/lang/Object;
.source "ResourceObserver.java"
# interfaces
.implements Lio/reactivex/Observer;
.implements Lio/reactivex/disposables/Disposable;
# annotations
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">",
"Ljava/lang/Object;",
"Lio/reactivex/Observer<",
"TT;>;",
"Lio/reactivex/disposables/Disposable;"
}
.end annotation
# instance fields
.field private final resources:Lio/reactivex/internal/disposables/ListCompositeDisposable;
.field private final s:Ljava/util/concurrent/atomic/AtomicReference;
.annotation system Ldalvik/annotation/Signature;
value = {
"Ljava/util/concurrent/atomic/AtomicReference<",
"Lio/reactivex/disposables/Disposable;",
">;"
}
.end annotation
.end field
# direct methods
.method public constructor <init>()V
.locals 1
.line 83
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
.line 85
new-instance v0, Ljava/util/concurrent/atomic/AtomicReference;
invoke-direct {v0}, Ljava/util/concurrent/atomic/AtomicReference;-><init>()V
iput-object v0, p0, Lio/reactivex/observers/ResourceObserver;->s:Ljava/util/concurrent/atomic/AtomicReference;
.line 88
new-instance v0, Lio/reactivex/internal/disposables/ListCompositeDisposable;
invoke-direct {v0}, Lio/reactivex/internal/disposables/ListCompositeDisposable;-><init>()V
iput-object v0, p0, Lio/reactivex/observers/ResourceObserver;->resources:Lio/reactivex/internal/disposables/ListCompositeDisposable;
return-void
.end method
# virtual methods
.method public final add(Lio/reactivex/disposables/Disposable;)V
.locals 1
.param p1 # Lio/reactivex/disposables/Disposable;
.annotation build Lio/reactivex/annotations/NonNull;
.end annotation
.end param
const-string v0, "resource is null"
.line 98
invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
.line 99
iget-object v0, p0, Lio/reactivex/observers/ResourceObserver;->resources:Lio/reactivex/internal/disposables/ListCompositeDisposable;
invoke-virtual {v0, p1}, Lio/reactivex/internal/disposables/ListCompositeDisposable;->add(Lio/reactivex/disposables/Disposable;)Z
return-void
.end method
.method public final dispose()V
.locals 1
.line 127
iget-object v0, p0, Lio/reactivex/observers/ResourceObserver;->s:Ljava/util/concurrent/atomic/AtomicReference;
invoke-static {v0}, Lio/reactivex/internal/disposables/DisposableHelper;->dispose(Ljava/util/concurrent/atomic/AtomicReference;)Z
move-result v0
if-eqz v0, :cond_0
.line 128
iget-object v0, p0, Lio/reactivex/observers/ResourceObserver;->resources:Lio/reactivex/internal/disposables/ListCompositeDisposable;
invoke-virtual {v0}, Lio/reactivex/internal/disposables/ListCompositeDisposable;->dispose()V
:cond_0
return-void
.end method
.method public final isDisposed()Z
.locals 1
.line 138
iget-object v0, p0, Lio/reactivex/observers/ResourceObserver;->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/Disposable;
invoke-static {v0}, Lio/reactivex/internal/disposables/DisposableHelper;->isDisposed(Lio/reactivex/disposables/Disposable;)Z
move-result v0
return v0
.end method
.method protected onStart()V
.locals 0
return-void
.end method
.method public final onSubscribe(Lio/reactivex/disposables/Disposable;)V
.locals 2
.line 104
iget-object v0, p0, Lio/reactivex/observers/ResourceObserver;->s:Ljava/util/concurrent/atomic/AtomicReference;
invoke-virtual {p0}, Ljava/lang/Object;->getClass()Ljava/lang/Class;
move-result-object v1
invoke-static {v0, p1, v1}, Lio/reactivex/internal/util/EndConsumerHelper;->setOnce(Ljava/util/concurrent/atomic/AtomicReference;Lio/reactivex/disposables/Disposable;Ljava/lang/Class;)Z
move-result p1
if-eqz p1, :cond_0
.line 105
invoke-virtual {p0}, Lio/reactivex/observers/ResourceObserver;->onStart()V
:cond_0
return-void
.end method