apkfuckery/com.discord/smali_classes2/rx/subscriptions/CompositeSubscription.smali

352 lines
6.9 KiB
Smali
Raw Normal View History

2019-02-04 20:08:30 +00:00
.class public final Lrx/subscriptions/CompositeSubscription;
.super Ljava/lang/Object;
2019-02-04 20:29:01 +00:00
.source "CompositeSubscription.java"
2019-02-04 20:08:30 +00:00
# interfaces
.implements Lrx/Subscription;
# instance fields
2019-05-08 22:54:48 +00:00
.field private volatile bDS:Z
2019-02-17 02:24:41 +00:00
2019-05-08 22:54:48 +00:00
.field private bMz:Ljava/util/Set;
2019-02-04 20:08:30 +00:00
.annotation system Ldalvik/annotation/Signature;
value = {
"Ljava/util/Set<",
"Lrx/Subscription;",
">;"
}
.end annotation
.end field
# direct methods
.method public constructor <init>()V
.locals 0
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
return-void
.end method
.method public varargs constructor <init>([Lrx/Subscription;)V
.locals 1
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
new-instance v0, Ljava/util/HashSet;
invoke-static {p1}, Ljava/util/Arrays;->asList([Ljava/lang/Object;)Ljava/util/List;
move-result-object p1
invoke-direct {v0, p1}, Ljava/util/HashSet;-><init>(Ljava/util/Collection;)V
2019-05-08 22:54:48 +00:00
iput-object v0, p0, Lrx/subscriptions/CompositeSubscription;->bMz:Ljava/util/Set;
2019-02-04 20:08:30 +00:00
return-void
.end method
2019-04-11 23:08:29 +00:00
.method private static k(Ljava/util/Collection;)V
2019-02-04 20:08:30 +00:00
.locals 2
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Ljava/util/Collection<",
"Lrx/Subscription;",
">;)V"
}
.end annotation
if-nez p0, :cond_0
return-void
:cond_0
const/4 v0, 0x0
invoke-interface {p0}, Ljava/util/Collection;->iterator()Ljava/util/Iterator;
move-result-object p0
:goto_0
invoke-interface {p0}, Ljava/util/Iterator;->hasNext()Z
move-result v1
if-eqz v1, :cond_2
invoke-interface {p0}, Ljava/util/Iterator;->next()Ljava/lang/Object;
move-result-object v1
check-cast v1, Lrx/Subscription;
:try_start_0
invoke-interface {v1}, Lrx/Subscription;->unsubscribe()V
:try_end_0
.catch Ljava/lang/Throwable; {:try_start_0 .. :try_end_0} :catch_0
goto :goto_0
:catch_0
move-exception v1
if-nez v0, :cond_1
new-instance v0, Ljava/util/ArrayList;
invoke-direct {v0}, Ljava/util/ArrayList;-><init>()V
:cond_1
invoke-interface {v0, v1}, Ljava/util/List;->add(Ljava/lang/Object;)Z
goto :goto_0
:cond_2
2019-05-03 18:53:54 +00:00
invoke-static {v0}, Lrx/a/b;->ah(Ljava/util/List;)V
2019-02-04 20:08:30 +00:00
return-void
.end method
# virtual methods
.method public final add(Lrx/Subscription;)V
.locals 2
invoke-interface {p1}, Lrx/Subscription;->isUnsubscribed()Z
move-result v0
if-eqz v0, :cond_0
return-void
:cond_0
2019-05-08 22:54:48 +00:00
iget-boolean v0, p0, Lrx/subscriptions/CompositeSubscription;->bDS:Z
2019-02-04 20:08:30 +00:00
if-nez v0, :cond_3
monitor-enter p0
:try_start_0
2019-05-08 22:54:48 +00:00
iget-boolean v0, p0, Lrx/subscriptions/CompositeSubscription;->bDS:Z
2019-02-04 20:08:30 +00:00
if-nez v0, :cond_2
2019-05-08 22:54:48 +00:00
iget-object v0, p0, Lrx/subscriptions/CompositeSubscription;->bMz:Ljava/util/Set;
2019-02-04 20:08:30 +00:00
if-nez v0, :cond_1
new-instance v0, Ljava/util/HashSet;
const/4 v1, 0x4
invoke-direct {v0, v1}, Ljava/util/HashSet;-><init>(I)V
2019-05-08 22:54:48 +00:00
iput-object v0, p0, Lrx/subscriptions/CompositeSubscription;->bMz:Ljava/util/Set;
2019-02-04 20:08:30 +00:00
:cond_1
2019-05-08 22:54:48 +00:00
iget-object v0, p0, Lrx/subscriptions/CompositeSubscription;->bMz:Ljava/util/Set;
2019-02-04 20:08:30 +00:00
invoke-interface {v0, p1}, Ljava/util/Set;->add(Ljava/lang/Object;)Z
monitor-exit p0
return-void
:cond_2
monitor-exit p0
goto :goto_0
:catchall_0
move-exception p1
monitor-exit p0
:try_end_0
.catchall {:try_start_0 .. :try_end_0} :catchall_0
throw p1
:cond_3
:goto_0
invoke-interface {p1}, Lrx/Subscription;->unsubscribe()V
return-void
.end method
.method public final clear()V
.locals 2
2019-05-08 22:54:48 +00:00
iget-boolean v0, p0, Lrx/subscriptions/CompositeSubscription;->bDS:Z
2019-02-04 20:08:30 +00:00
if-nez v0, :cond_2
monitor-enter p0
:try_start_0
2019-05-08 22:54:48 +00:00
iget-boolean v0, p0, Lrx/subscriptions/CompositeSubscription;->bDS:Z
2019-02-04 20:08:30 +00:00
if-nez v0, :cond_1
2019-05-08 22:54:48 +00:00
iget-object v0, p0, Lrx/subscriptions/CompositeSubscription;->bMz:Ljava/util/Set;
2019-02-04 20:08:30 +00:00
if-nez v0, :cond_0
goto :goto_0
:cond_0
2019-05-08 22:54:48 +00:00
iget-object v0, p0, Lrx/subscriptions/CompositeSubscription;->bMz:Ljava/util/Set;
2019-02-04 20:08:30 +00:00
const/4 v1, 0x0
2019-05-08 22:54:48 +00:00
iput-object v1, p0, Lrx/subscriptions/CompositeSubscription;->bMz:Ljava/util/Set;
2019-02-04 20:08:30 +00:00
monitor-exit p0
:try_end_0
.catchall {:try_start_0 .. :try_end_0} :catchall_0
2019-04-11 23:08:29 +00:00
invoke-static {v0}, Lrx/subscriptions/CompositeSubscription;->k(Ljava/util/Collection;)V
2019-02-04 20:08:30 +00:00
goto :goto_1
:cond_1
:goto_0
:try_start_1
monitor-exit p0
return-void
:catchall_0
move-exception v0
monitor-exit p0
:try_end_1
.catchall {:try_start_1 .. :try_end_1} :catchall_0
throw v0
:cond_2
:goto_1
return-void
.end method
.method public final e(Lrx/Subscription;)V
.locals 1
2019-05-08 22:54:48 +00:00
iget-boolean v0, p0, Lrx/subscriptions/CompositeSubscription;->bDS:Z
2019-02-04 20:08:30 +00:00
if-nez v0, :cond_2
monitor-enter p0
:try_start_0
2019-05-08 22:54:48 +00:00
iget-boolean v0, p0, Lrx/subscriptions/CompositeSubscription;->bDS:Z
2019-02-04 20:08:30 +00:00
if-nez v0, :cond_1
2019-05-08 22:54:48 +00:00
iget-object v0, p0, Lrx/subscriptions/CompositeSubscription;->bMz:Ljava/util/Set;
2019-02-04 20:08:30 +00:00
if-nez v0, :cond_0
goto :goto_0
:cond_0
2019-05-08 22:54:48 +00:00
iget-object v0, p0, Lrx/subscriptions/CompositeSubscription;->bMz:Ljava/util/Set;
2019-02-04 20:08:30 +00:00
invoke-interface {v0, p1}, Ljava/util/Set;->remove(Ljava/lang/Object;)Z
move-result v0
monitor-exit p0
:try_end_0
.catchall {:try_start_0 .. :try_end_0} :catchall_0
if-eqz v0, :cond_2
invoke-interface {p1}, Lrx/Subscription;->unsubscribe()V
goto :goto_1
:cond_1
:goto_0
:try_start_1
monitor-exit p0
return-void
:catchall_0
move-exception p1
monitor-exit p0
:try_end_1
.catchall {:try_start_1 .. :try_end_1} :catchall_0
throw p1
:cond_2
:goto_1
return-void
.end method
.method public final isUnsubscribed()Z
.locals 1
2019-05-08 22:54:48 +00:00
iget-boolean v0, p0, Lrx/subscriptions/CompositeSubscription;->bDS:Z
2019-02-04 20:08:30 +00:00
return v0
.end method
.method public final unsubscribe()V
.locals 2
2019-05-08 22:54:48 +00:00
iget-boolean v0, p0, Lrx/subscriptions/CompositeSubscription;->bDS:Z
2019-02-04 20:08:30 +00:00
if-nez v0, :cond_1
monitor-enter p0
:try_start_0
2019-05-08 22:54:48 +00:00
iget-boolean v0, p0, Lrx/subscriptions/CompositeSubscription;->bDS:Z
2019-02-04 20:08:30 +00:00
if-eqz v0, :cond_0
monitor-exit p0
return-void
:cond_0
const/4 v0, 0x1
2019-05-08 22:54:48 +00:00
iput-boolean v0, p0, Lrx/subscriptions/CompositeSubscription;->bDS:Z
2019-02-04 20:08:30 +00:00
2019-05-08 22:54:48 +00:00
iget-object v0, p0, Lrx/subscriptions/CompositeSubscription;->bMz:Ljava/util/Set;
2019-02-04 20:08:30 +00:00
const/4 v1, 0x0
2019-05-08 22:54:48 +00:00
iput-object v1, p0, Lrx/subscriptions/CompositeSubscription;->bMz:Ljava/util/Set;
2019-02-04 20:08:30 +00:00
monitor-exit p0
:try_end_0
.catchall {:try_start_0 .. :try_end_0} :catchall_0
2019-04-11 23:08:29 +00:00
invoke-static {v0}, Lrx/subscriptions/CompositeSubscription;->k(Ljava/util/Collection;)V
2019-02-04 20:08:30 +00:00
goto :goto_0
:catchall_0
move-exception v0
:try_start_1
monitor-exit p0
:try_end_1
.catchall {:try_start_1 .. :try_end_1} :catchall_0
throw v0
:cond_1
:goto_0
return-void
.end method