ResourceCompletableObserver.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
.class public abstract Lio/reactivex/observers/ResourceCompletableObserver;
.super Ljava/lang/Object;
.source "ResourceCompletableObserver.java"
# interfaces
.implements Lio/reactivex/CompletableObserver;
.implements Lio/reactivex/disposables/Disposable;
# 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 75
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
.line 77
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/ResourceCompletableObserver;->s:Ljava/util/concurrent/atomic/AtomicReference;
.line 80
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/ResourceCompletableObserver;->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 90
invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
.line 91
iget-object v0, p0, Lio/reactivex/observers/ResourceCompletableObserver;->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 119
iget-object v0, p0, Lio/reactivex/observers/ResourceCompletableObserver;->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 120
iget-object v0, p0, Lio/reactivex/observers/ResourceCompletableObserver;->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 130
iget-object v0, p0, Lio/reactivex/observers/ResourceCompletableObserver;->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 96
iget-object v0, p0, Lio/reactivex/observers/ResourceCompletableObserver;->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 97
invoke-virtual {p0}, Lio/reactivex/observers/ResourceCompletableObserver;->onStart()V
:cond_0
return-void
.end method