ResourceMaybeObserver.smali
4.5 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
.class public abstract Lio/reactivex/observers/ResourceMaybeObserver;
.super Ljava/lang/Object;
.source "ResourceMaybeObserver.java"
# interfaces
.implements Lio/reactivex/MaybeObserver;
.implements Lio/reactivex/disposables/Disposable;
# annotations
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">",
"Ljava/lang/Object;",
"Lio/reactivex/MaybeObserver<",
"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 85
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
.line 87
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/ResourceMaybeObserver;->s:Ljava/util/concurrent/atomic/AtomicReference;
.line 90
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/ResourceMaybeObserver;->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 100
invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
.line 101
iget-object v0, p0, Lio/reactivex/observers/ResourceMaybeObserver;->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 129
iget-object v0, p0, Lio/reactivex/observers/ResourceMaybeObserver;->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 130
iget-object v0, p0, Lio/reactivex/observers/ResourceMaybeObserver;->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 140
iget-object v0, p0, Lio/reactivex/observers/ResourceMaybeObserver;->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
.param p1 # Lio/reactivex/disposables/Disposable;
.annotation build Lio/reactivex/annotations/NonNull;
.end annotation
.end param
.line 106
iget-object v0, p0, Lio/reactivex/observers/ResourceMaybeObserver;->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 107
invoke-virtual {p0}, Lio/reactivex/observers/ResourceMaybeObserver;->onStart()V
:cond_0
return-void
.end method