Changes of com.discord v1325

com.discord/smali_classes2/rx/subjects/BehaviorSubject$a.smali

@@ -0,0 +1,243 @@
+.class public final Lrx/subjects/BehaviorSubject$a;
+.super Ljava/lang/Object;
+.source "BehaviorSubject.java"
+
+# interfaces
+.implements Lrx/functions/Action1;
+
+
+# annotations
+.annotation system Ldalvik/annotation/EnclosingMethod;
+    value = Lrx/subjects/BehaviorSubject;->i0(Ljava/lang/Object;Z)Lrx/subjects/BehaviorSubject;
+.end annotation
+
+.annotation system Ldalvik/annotation/InnerClass;
+    accessFlags = 0x9
+    name = null
+.end annotation
+
+.annotation system Ldalvik/annotation/Signature;
+    value = {
+        "Ljava/lang/Object;",
+        "Lrx/functions/Action1<",
+        "Li0/q/c$b<",
+        "TT;>;>;"
+    }
+.end annotation
+
+
+# instance fields
+.field public final synthetic d:Li0/q/c;
+
+
+# direct methods
+.method public constructor <init>(Li0/q/c;)V
+    .locals 0
+
+    iput-object p1, p0, Lrx/subjects/BehaviorSubject$a;->d:Li0/q/c;
+
+    invoke-direct {p0}, Ljava/lang/Object;-><init>()V
+
+    return-void
+.end method
+
+
+# virtual methods
+.method public call(Ljava/lang/Object;)V
+    .locals 8
+
+    check-cast p1, Li0/q/c$b;
+
+    iget-object v0, p0, Lrx/subjects/BehaviorSubject$a;->d:Li0/q/c;
+
+    iget-object v0, v0, Li0/q/c;->latest:Ljava/lang/Object;
+
+    monitor-enter p1
+
+    :try_start_0
+    iget-boolean v1, p1, Li0/q/c$b;->e:Z
+
+    if-eqz v1, :cond_7
+
+    iget-boolean v1, p1, Li0/q/c$b;->f:Z
+
+    if-eqz v1, :cond_0
+
+    goto :goto_7
+
+    :cond_0
+    const/4 v1, 0x0
+
+    iput-boolean v1, p1, Li0/q/c$b;->e:Z
+
+    const/4 v2, 0x1
+
+    if-eqz v0, :cond_1
+
+    const/4 v3, 0x1
+
+    goto :goto_0
+
+    :cond_1
+    const/4 v3, 0x0
+
+    :goto_0
+    iput-boolean v3, p1, Li0/q/c$b;->f:Z
+
+    monitor-exit p1
+    :try_end_0
+    .catchall {:try_start_0 .. :try_end_0} :catchall_5
+
+    if-eqz v0, :cond_8
+
+    const/4 v3, 0x0
+
+    move-object v4, v3
+
+    const/4 v5, 0x1
+
+    :goto_1
+    if-eqz v4, :cond_3
+
+    :try_start_1
+    invoke-interface {v4}, Ljava/util/List;->iterator()Ljava/util/Iterator;
+
+    move-result-object v4
+
+    :cond_2
+    :goto_2
+    invoke-interface {v4}, Ljava/util/Iterator;->hasNext()Z
+
+    move-result v6
+
+    if-eqz v6, :cond_3
+
+    invoke-interface {v4}, Ljava/util/Iterator;->next()Ljava/lang/Object;
+
+    move-result-object v6
+
+    if-eqz v6, :cond_2
+
+    iget-object v7, p1, Li0/q/c$b;->d:Lrx/Subscriber;
+
+    invoke-static {v7, v6}, Li0/l/a/h;->a(Li0/g;Ljava/lang/Object;)Z
+
+    goto :goto_2
+
+    :catchall_0
+    move-exception v0
+
+    goto :goto_4
+
+    :cond_3
+    if-eqz v5, :cond_4
+
+    iget-object v4, p1, Li0/q/c$b;->d:Lrx/Subscriber;
+
+    invoke-static {v4, v0}, Li0/l/a/h;->a(Li0/g;Ljava/lang/Object;)Z
+
+    const/4 v5, 0x0
+
+    :cond_4
+    monitor-enter p1
+    :try_end_1
+    .catchall {:try_start_1 .. :try_end_1} :catchall_0
+
+    :try_start_2
+    iget-object v4, p1, Li0/q/c$b;->g:Ljava/util/List;
+
+    iput-object v3, p1, Li0/q/c$b;->g:Ljava/util/List;
+
+    if-nez v4, :cond_5
+
+    iput-boolean v1, p1, Li0/q/c$b;->f:Z
+    :try_end_2
+    .catchall {:try_start_2 .. :try_end_2} :catchall_1
+
+    :try_start_3
+    monitor-exit p1
+    :try_end_3
+    .catchall {:try_start_3 .. :try_end_3} :catchall_3
+
+    goto :goto_8
+
+    :cond_5
+    :try_start_4
+    monitor-exit p1
+    :try_end_4
+    .catchall {:try_start_4 .. :try_end_4} :catchall_1
+
+    goto :goto_1
+
+    :catchall_1
+    move-exception v0
+
+    const/4 v2, 0x0
+
+    :goto_3
+    :try_start_5
+    monitor-exit p1
+    :try_end_5
+    .catchall {:try_start_5 .. :try_end_5} :catchall_3
+
+    :try_start_6
+    throw v0
+    :try_end_6
+    .catchall {:try_start_6 .. :try_end_6} :catchall_2
+
+    :catchall_2
+    move-exception v0
+
+    goto :goto_5
+
+    :catchall_3
+    move-exception v0
+
+    goto :goto_3
+
+    :goto_4
+    const/4 v2, 0x0
+
+    :goto_5
+    if-nez v2, :cond_6
+
+    monitor-enter p1
+
+    :try_start_7
+    iput-boolean v1, p1, Li0/q/c$b;->f:Z
+
+    monitor-exit p1
+
+    goto :goto_6
+
+    :catchall_4
+    move-exception v0
+
+    monitor-exit p1
+    :try_end_7
+    .catchall {:try_start_7 .. :try_end_7} :catchall_4
+
+    throw v0
+
+    :cond_6
+    :goto_6
+    throw v0
+
+    :cond_7
+    :goto_7
+    :try_start_8
+    monitor-exit p1
+
+    :cond_8
+    :goto_8
+    return-void
+
+    :catchall_5
+    move-exception v0
+
+    monitor-exit p1
+    :try_end_8
+    .catchall {:try_start_8 .. :try_end_8} :catchall_5
+
+    throw v0
+.end method

com.discord/smali_classes2/rx/subjects/BehaviorSubject.smali

@@ -0,0 +1,364 @@
+.class public final Lrx/subjects/BehaviorSubject;
+.super Lrx/subjects/Subject;
+.source "BehaviorSubject.java"
+
+
+# annotations
+.annotation system Ldalvik/annotation/Signature;
+    value = {
+        "<T:",
+        "Ljava/lang/Object;",
+        ">",
+        "Lrx/subjects/Subject<",
+        "TT;TT;>;"
+    }
+.end annotation
+
+
+# static fields
+.field public static final f:[Ljava/lang/Object;
+
+
+# instance fields
+.field public final e:Li0/q/c;
+    .annotation system Ldalvik/annotation/Signature;
+        value = {
+            "Li0/q/c<",
+            "TT;>;"
+        }
+    .end annotation
+.end field
+
+
+# direct methods
+.method public static constructor <clinit>()V
+    .locals 1
+
+    const/4 v0, 0x0
+
+    new-array v0, v0, [Ljava/lang/Object;
+
+    sput-object v0, Lrx/subjects/BehaviorSubject;->f:[Ljava/lang/Object;
+
+    return-void
+.end method
+
+.method public constructor <init>(Lrx/Observable$a;Li0/q/c;)V
+    .locals 0
+    .annotation system Ldalvik/annotation/Signature;
+        value = {
+            "(",
+            "Lrx/Observable$a<",
+            "TT;>;",
+            "Li0/q/c<",
+            "TT;>;)V"
+        }
+    .end annotation
+
+    invoke-direct {p0, p1}, Lrx/subjects/Subject;-><init>(Lrx/Observable$a;)V
+
+    iput-object p2, p0, Lrx/subjects/BehaviorSubject;->e:Li0/q/c;
+
+    return-void
+.end method
+
+.method public static g0()Lrx/subjects/BehaviorSubject;
+    .locals 2
+    .annotation system Ldalvik/annotation/Signature;
+        value = {
+            "<T:",
+            "Ljava/lang/Object;",
+            ">()",
+            "Lrx/subjects/BehaviorSubject<",
+            "TT;>;"
+        }
+    .end annotation
+
+    const/4 v0, 0x0
+
+    const/4 v1, 0x0
+
+    invoke-static {v0, v1}, Lrx/subjects/BehaviorSubject;->i0(Ljava/lang/Object;Z)Lrx/subjects/BehaviorSubject;
+
+    move-result-object v0
+
+    return-object v0
+.end method
+
+.method public static h0(Ljava/lang/Object;)Lrx/subjects/BehaviorSubject;
+    .locals 1
+    .annotation system Ldalvik/annotation/Signature;
+        value = {
+            "<T:",
+            "Ljava/lang/Object;",
+            ">(TT;)",
+            "Lrx/subjects/BehaviorSubject<",
+            "TT;>;"
+        }
+    .end annotation
+
+    const/4 v0, 0x1
+
+    invoke-static {p0, v0}, Lrx/subjects/BehaviorSubject;->i0(Ljava/lang/Object;Z)Lrx/subjects/BehaviorSubject;
+
+    move-result-object p0
+
+    return-object p0
+.end method
+
+.method public static i0(Ljava/lang/Object;Z)Lrx/subjects/BehaviorSubject;
+    .locals 1
+    .annotation system Ldalvik/annotation/Signature;
+        value = {
+            "<T:",
+            "Ljava/lang/Object;",
+            ">(TT;Z)",
+            "Lrx/subjects/BehaviorSubject<",
+            "TT;>;"
+        }
+    .end annotation
+
+    new-instance v0, Li0/q/c;
+
+    invoke-direct {v0}, Li0/q/c;-><init>()V
+
+    if-eqz p1, :cond_1
+
+    if-nez p0, :cond_0
+
+    sget-object p0, Li0/l/a/h;->b:Ljava/lang/Object;
+
+    :cond_0
+    iput-object p0, v0, Li0/q/c;->latest:Ljava/lang/Object;
+
+    :cond_1
+    new-instance p0, Lrx/subjects/BehaviorSubject$a;
+
+    invoke-direct {p0, v0}, Lrx/subjects/BehaviorSubject$a;-><init>(Li0/q/c;)V
+
+    iput-object p0, v0, Li0/q/c;->onAdded:Lrx/functions/Action1;
+
+    iput-object p0, v0, Li0/q/c;->onTerminated:Lrx/functions/Action1;
+
+    new-instance p0, Lrx/subjects/BehaviorSubject;
+
+    invoke-direct {p0, v0, v0}, Lrx/subjects/BehaviorSubject;-><init>(Lrx/Observable$a;Li0/q/c;)V
+
+    return-object p0
+.end method
+
+
+# virtual methods
+.method public j0()Ljava/lang/Object;
+    .locals 2
+    .annotation system Ldalvik/annotation/Signature;
+        value = {
+            "()TT;"
+        }
+    .end annotation
+
+    iget-object v0, p0, Lrx/subjects/BehaviorSubject;->e:Li0/q/c;
+
+    iget-object v0, v0, Li0/q/c;->latest:Ljava/lang/Object;
+
+    if-eqz v0, :cond_0
+
+    instance-of v1, v0, Li0/l/a/h$c;
+
+    if-nez v1, :cond_0
+
+    invoke-static {v0}, Li0/l/a/h;->c(Ljava/lang/Object;)Z
+
+    move-result v1
+
+    if-nez v1, :cond_0
+
+    const/4 v1, 0x1
+
+    goto :goto_0
+
+    :cond_0
+    const/4 v1, 0x0
+
+    :goto_0
+    if-eqz v1, :cond_1
+
+    invoke-static {v0}, Li0/l/a/h;->b(Ljava/lang/Object;)Ljava/lang/Object;
+
+    move-result-object v0
+
+    return-object v0
+
+    :cond_1
+    const/4 v0, 0x0
+
+    return-object v0
+.end method
+
+.method public onCompleted()V
+    .locals 5
+
+    iget-object v0, p0, Lrx/subjects/BehaviorSubject;->e:Li0/q/c;
+
+    iget-object v0, v0, Li0/q/c;->latest:Ljava/lang/Object;
+
+    if-eqz v0, :cond_0
+
+    iget-object v0, p0, Lrx/subjects/BehaviorSubject;->e:Li0/q/c;
+
+    iget-boolean v0, v0, Li0/q/c;->active:Z
+
+    if-eqz v0, :cond_1
+
+    :cond_0
+    sget-object v0, Li0/l/a/h;->a:Ljava/lang/Object;
+
+    iget-object v1, p0, Lrx/subjects/BehaviorSubject;->e:Li0/q/c;
+
+    invoke-virtual {v1, v0}, Li0/q/c;->b(Ljava/lang/Object;)[Li0/q/c$b;
+
+    move-result-object v1
+
+    array-length v2, v1
+
+    const/4 v3, 0x0
+
+    :goto_0
+    if-ge v3, v2, :cond_1
+
+    aget-object v4, v1, v3
+
+    invoke-virtual {v4, v0}, Li0/q/c$b;->a(Ljava/lang/Object;)V
+
+    add-int/lit8 v3, v3, 0x1
+
+    goto :goto_0
+
+    :cond_1
+    return-void
+.end method
+
+.method public onError(Ljava/lang/Throwable;)V
+    .locals 5
+
+    iget-object v0, p0, Lrx/subjects/BehaviorSubject;->e:Li0/q/c;
+
+    iget-object v0, v0, Li0/q/c;->latest:Ljava/lang/Object;
+
+    if-eqz v0, :cond_0
+
+    iget-object v0, p0, Lrx/subjects/BehaviorSubject;->e:Li0/q/c;
+
+    iget-boolean v0, v0, Li0/q/c;->active:Z
+
+    if-eqz v0, :cond_3
+
+    :cond_0
+    new-instance v0, Li0/l/a/h$c;
+
+    invoke-direct {v0, p1}, Li0/l/a/h$c;-><init>(Ljava/lang/Throwable;)V
+
+    const/4 p1, 0x0
+
+    iget-object v1, p0, Lrx/subjects/BehaviorSubject;->e:Li0/q/c;
+
+    invoke-virtual {v1, v0}, Li0/q/c;->b(Ljava/lang/Object;)[Li0/q/c$b;
+
+    move-result-object v1
+
+    array-length v2, v1
+
+    const/4 v3, 0x0
+
+    :goto_0
+    if-ge v3, v2, :cond_2
+
+    aget-object v4, v1, v3
+
+    :try_start_0
+    invoke-virtual {v4, v0}, Li0/q/c$b;->a(Ljava/lang/Object;)V
+    :try_end_0
+    .catchall {:try_start_0 .. :try_end_0} :catchall_0
+
+    goto :goto_1
+
+    :catchall_0
+    move-exception v4
+
+    if-nez p1, :cond_1
+
+    new-instance p1, Ljava/util/ArrayList;
+
+    invoke-direct {p1}, Ljava/util/ArrayList;-><init>()V
+
+    :cond_1
+    invoke-interface {p1, v4}, Ljava/util/List;->add(Ljava/lang/Object;)Z
+
+    :goto_1
+    add-int/lit8 v3, v3, 0x1
+
+    goto :goto_0
+
+    :cond_2
+    invoke-static {p1}, Lz/i/s;->W(Ljava/util/List;)V
+
+    :cond_3
+    return-void
+.end method
+
+.method public onNext(Ljava/lang/Object;)V
+    .locals 4
+    .annotation system Ldalvik/annotation/Signature;
+        value = {
+            "(TT;)V"
+        }
+    .end annotation
+
+    iget-object v0, p0, Lrx/subjects/BehaviorSubject;->e:Li0/q/c;
+
+    iget-object v0, v0, Li0/q/c;->latest:Ljava/lang/Object;
+
+    if-eqz v0, :cond_0
+
+    iget-object v0, p0, Lrx/subjects/BehaviorSubject;->e:Li0/q/c;
+
+    iget-boolean v0, v0, Li0/q/c;->active:Z
+
+    if-eqz v0, :cond_2
+
+    :cond_0
+    if-nez p1, :cond_1
+
+    sget-object p1, Li0/l/a/h;->b:Ljava/lang/Object;
+
+    :cond_1
+    iget-object v0, p0, Lrx/subjects/BehaviorSubject;->e:Li0/q/c;
+
+    iput-object p1, v0, Li0/q/c;->latest:Ljava/lang/Object;
+
+    invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object;
+
+    move-result-object v0
+
+    check-cast v0, Li0/q/c$a;
+
+    iget-object v0, v0, Li0/q/c$a;->b:[Li0/q/c$b;
+
+    array-length v1, v0
+
+    const/4 v2, 0x0
+
+    :goto_0
+    if-ge v2, v1, :cond_2
+
+    aget-object v3, v0, v2
+
+    invoke-virtual {v3, p1}, Li0/q/c$b;->a(Ljava/lang/Object;)V
+
+    add-int/lit8 v2, v2, 0x1
+
+    goto :goto_0
+
+    :cond_2
+    return-void
+.end method

com.discord/smali_classes2/rx/subjects/PublishSubject$a.smali

@@ -0,0 +1,261 @@
+.class public final Lrx/subjects/PublishSubject$a;
+.super Ljava/util/concurrent/atomic/AtomicLong;
+.source "PublishSubject.java"
+
+# interfaces
+.implements Lrx/Producer;
+.implements Lrx/Subscription;
+.implements Li0/g;
+
+
+# annotations
+.annotation system Ldalvik/annotation/EnclosingClass;
+    value = Lrx/subjects/PublishSubject;
+.end annotation
+
+.annotation system Ldalvik/annotation/InnerClass;
+    accessFlags = 0x19
+    name = "a"
+.end annotation
+
+.annotation system Ldalvik/annotation/Signature;
+    value = {
+        "<T:",
+        "Ljava/lang/Object;",
+        ">",
+        "Ljava/util/concurrent/atomic/AtomicLong;",
+        "Lrx/Producer;",
+        "Lrx/Subscription;",
+        "Li0/g<",
+        "TT;>;"
+    }
+.end annotation
+
+
+# static fields
+.field public static final serialVersionUID:J = 0x59896c1df8e78b00L
+
+
+# instance fields
+.field public final actual:Lrx/Subscriber;
+    .annotation system Ldalvik/annotation/Signature;
+        value = {
+            "Lrx/Subscriber<",
+            "-TT;>;"
+        }
+    .end annotation
+.end field
+
+.field public final parent:Lrx/subjects/PublishSubject$b;
+    .annotation system Ldalvik/annotation/Signature;
+        value = {
+            "Lrx/subjects/PublishSubject$b<",
+            "TT;>;"
+        }
+    .end annotation
+.end field
+
+.field public produced:J
+
+
+# direct methods
+.method public constructor <init>(Lrx/subjects/PublishSubject$b;Lrx/Subscriber;)V
+    .locals 0
+    .annotation system Ldalvik/annotation/Signature;
+        value = {
+            "(",
+            "Lrx/subjects/PublishSubject$b<",
+            "TT;>;",
+            "Lrx/Subscriber<",
+            "-TT;>;)V"
+        }
+    .end annotation
+
+    invoke-direct {p0}, Ljava/util/concurrent/atomic/AtomicLong;-><init>()V
+
+    iput-object p1, p0, Lrx/subjects/PublishSubject$a;->parent:Lrx/subjects/PublishSubject$b;
+
+    iput-object p2, p0, Lrx/subjects/PublishSubject$a;->actual:Lrx/Subscriber;
+
+    return-void
+.end method
+
+
+# virtual methods
+.method public isUnsubscribed()Z
+    .locals 5
+
+    invoke-virtual {p0}, Ljava/util/concurrent/atomic/AtomicLong;->get()J
+
+    move-result-wide v0
+
+    const-wide/high16 v2, -0x8000000000000000L
+
+    cmp-long v4, v0, v2
+
+    if-nez v4, :cond_0
+
+    const/4 v0, 0x1
+
+    goto :goto_0
+
+    :cond_0
+    const/4 v0, 0x0
+
+    :goto_0
+    return v0
+.end method
+
+.method public n(J)V
+    .locals 5
+
+    invoke-static {p1, p2}, Lz/i/s;->d0(J)Z
+
+    move-result v0
+
+    if-eqz v0, :cond_2
+
+    :cond_0
+    invoke-virtual {p0}, Ljava/util/concurrent/atomic/AtomicLong;->get()J
+
+    move-result-wide v0
+
+    const-wide/high16 v2, -0x8000000000000000L
+
+    cmp-long v4, v0, v2
+
+    if-nez v4, :cond_1
+
+    return-void
+
+    :cond_1
+    invoke-static {v0, v1, p1, p2}, Lz/i/s;->d(JJ)J
+
+    move-result-wide v2
+
+    invoke-virtual {p0, v0, v1, v2, v3}, Ljava/util/concurrent/atomic/AtomicLong;->compareAndSet(JJ)Z
+
+    move-result v0
+
+    if-eqz v0, :cond_0
+
+    :cond_2
+    return-void
+.end method
+
+.method public onCompleted()V
+    .locals 5
+
+    invoke-virtual {p0}, Ljava/util/concurrent/atomic/AtomicLong;->get()J
+
+    move-result-wide v0
+
+    const-wide/high16 v2, -0x8000000000000000L
+
+    cmp-long v4, v0, v2
+
+    if-eqz v4, :cond_0
+
+    iget-object v0, p0, Lrx/subjects/PublishSubject$a;->actual:Lrx/Subscriber;
+
+    invoke-interface {v0}, Li0/g;->onCompleted()V
+
+    :cond_0
+    return-void
+.end method
+
+.method public onError(Ljava/lang/Throwable;)V
+    .locals 5
+
+    invoke-virtual {p0}, Ljava/util/concurrent/atomic/AtomicLong;->get()J
+
+    move-result-wide v0
+
+    const-wide/high16 v2, -0x8000000000000000L
+
+    cmp-long v4, v0, v2
+
+    if-eqz v4, :cond_0
+
+    iget-object v0, p0, Lrx/subjects/PublishSubject$a;->actual:Lrx/Subscriber;
+
+    invoke-interface {v0, p1}, Li0/g;->onError(Ljava/lang/Throwable;)V
+
+    :cond_0
+    return-void
+.end method
+
+.method public onNext(Ljava/lang/Object;)V
+    .locals 5
+    .annotation system Ldalvik/annotation/Signature;
+        value = {
+            "(TT;)V"
+        }
+    .end annotation
+
+    invoke-virtual {p0}, Ljava/util/concurrent/atomic/AtomicLong;->get()J
+
+    move-result-wide v0
+
+    const-wide/high16 v2, -0x8000000000000000L
+
+    cmp-long v4, v0, v2
+
+    if-eqz v4, :cond_1
+
+    iget-wide v2, p0, Lrx/subjects/PublishSubject$a;->produced:J
+
+    cmp-long v4, v0, v2
+
+    if-eqz v4, :cond_0
+
+    const-wide/16 v0, 0x1
+
+    add-long/2addr v2, v0
+
+    iput-wide v2, p0, Lrx/subjects/PublishSubject$a;->produced:J
+
+    iget-object v0, p0, Lrx/subjects/PublishSubject$a;->actual:Lrx/Subscriber;
+
+    invoke-interface {v0, p1}, Li0/g;->onNext(Ljava/lang/Object;)V
+
+    goto :goto_0
+
+    :cond_0
+    invoke-virtual {p0}, Lrx/subjects/PublishSubject$a;->unsubscribe()V
+
+    iget-object p1, p0, Lrx/subjects/PublishSubject$a;->actual:Lrx/Subscriber;
+
+    new-instance v0, Lrx/exceptions/MissingBackpressureException;
+
+    const-string v1, "PublishSubject: could not emit value due to lack of requests"
+
+    invoke-direct {v0, v1}, Lrx/exceptions/MissingBackpressureException;-><init>(Ljava/lang/String;)V
+
+    invoke-interface {p1, v0}, Li0/g;->onError(Ljava/lang/Throwable;)V
+
+    :cond_1
+    :goto_0
+    return-void
+.end method
+
+.method public unsubscribe()V
+    .locals 5
+
+    const-wide/high16 v0, -0x8000000000000000L
+
+    invoke-virtual {p0, v0, v1}, Ljava/util/concurrent/atomic/AtomicLong;->getAndSet(J)J
+
+    move-result-wide v2
+
+    cmp-long v4, v2, v0
+
+    if-eqz v4, :cond_0
+
+    iget-object v0, p0, Lrx/subjects/PublishSubject$a;->parent:Lrx/subjects/PublishSubject$b;
+
+    invoke-virtual {v0, p0}, Lrx/subjects/PublishSubject$b;->a(Lrx/subjects/PublishSubject$a;)V
+
+    :cond_0
+    return-void
+.end method

com.discord/smali_classes2/rx/subjects/PublishSubject$b.smali

@@ -0,0 +1,368 @@
+.class public final Lrx/subjects/PublishSubject$b;
+.super Ljava/util/concurrent/atomic/AtomicReference;
+.source "PublishSubject.java"
+
+# interfaces
+.implements Lrx/Observable$a;
+.implements Li0/g;
+
+
+# annotations
+.annotation system Ldalvik/annotation/EnclosingClass;
+    value = Lrx/subjects/PublishSubject;
+.end annotation
+
+.annotation system Ldalvik/annotation/InnerClass;
+    accessFlags = 0x19
+    name = "b"
+.end annotation
+
+.annotation system Ldalvik/annotation/Signature;
+    value = {
+        "<T:",
+        "Ljava/lang/Object;",
+        ">",
+        "Ljava/util/concurrent/atomic/AtomicReference<",
+        "[",
+        "Lrx/subjects/PublishSubject$a<",
+        "TT;>;>;",
+        "Lrx/Observable$a<",
+        "TT;>;",
+        "Li0/g<",
+        "TT;>;"
+    }
+.end annotation
+
+
+# static fields
+.field public static final d:[Lrx/subjects/PublishSubject$a;
+
+.field public static final e:[Lrx/subjects/PublishSubject$a;
+
+.field public static final serialVersionUID:J = -0x690a478d773d9c84L
+
+
+# instance fields
+.field public error:Ljava/lang/Throwable;
+
+
+# direct methods
+.method public static constructor <clinit>()V
+    .locals 2
+
+    const/4 v0, 0x0
+
+    new-array v1, v0, [Lrx/subjects/PublishSubject$a;
+
+    sput-object v1, Lrx/subjects/PublishSubject$b;->d:[Lrx/subjects/PublishSubject$a;
+
+    new-array v0, v0, [Lrx/subjects/PublishSubject$a;
+
+    sput-object v0, Lrx/subjects/PublishSubject$b;->e:[Lrx/subjects/PublishSubject$a;
+
+    return-void
+.end method
+
+.method public constructor <init>()V
+    .locals 1
+
+    invoke-direct {p0}, Ljava/util/concurrent/atomic/AtomicReference;-><init>()V
+
+    sget-object v0, Lrx/subjects/PublishSubject$b;->d:[Lrx/subjects/PublishSubject$a;
+
+    invoke-virtual {p0, v0}, Ljava/util/concurrent/atomic/AtomicReference;->lazySet(Ljava/lang/Object;)V
+
+    return-void
+.end method
+
+
+# virtual methods
+.method public a(Lrx/subjects/PublishSubject$a;)V
+    .locals 6
+    .annotation system Ldalvik/annotation/Signature;
+        value = {
+            "(",
+            "Lrx/subjects/PublishSubject$a<",
+            "TT;>;)V"
+        }
+    .end annotation
+
+    :cond_0
+    invoke-virtual {p0}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object;
+
+    move-result-object v0
+
+    check-cast v0, [Lrx/subjects/PublishSubject$a;
+
+    sget-object v1, Lrx/subjects/PublishSubject$b;->e:[Lrx/subjects/PublishSubject$a;
+
+    if-eq v0, v1, :cond_6
+
+    sget-object v1, Lrx/subjects/PublishSubject$b;->d:[Lrx/subjects/PublishSubject$a;
+
+    if-ne v0, v1, :cond_1
+
+    goto :goto_3
+
+    :cond_1
+    array-length v1, v0
+
+    const/4 v2, 0x0
+
+    const/4 v3, 0x0
+
+    :goto_0
+    if-ge v3, v1, :cond_3
+
+    aget-object v4, v0, v3
+
+    if-ne v4, p1, :cond_2
+
+    goto :goto_1
+
+    :cond_2
+    add-int/lit8 v3, v3, 0x1
+
+    goto :goto_0
+
+    :cond_3
+    const/4 v3, -0x1
+
+    :goto_1
+    if-gez v3, :cond_4
+
+    return-void
+
+    :cond_4
+    const/4 v4, 0x1
+
+    if-ne v1, v4, :cond_5
+
+    sget-object v1, Lrx/subjects/PublishSubject$b;->d:[Lrx/subjects/PublishSubject$a;
+
+    goto :goto_2
+
+    :cond_5
+    add-int/lit8 v5, v1, -0x1
+
+    new-array v5, v5, [Lrx/subjects/PublishSubject$a;
+
+    invoke-static {v0, v2, v5, v2, v3}, Ljava/lang/System;->arraycopy(Ljava/lang/Object;ILjava/lang/Object;II)V
+
+    add-int/lit8 v2, v3, 0x1
+
+    sub-int/2addr v1, v3
+
+    sub-int/2addr v1, v4
+
+    invoke-static {v0, v2, v5, v3, v1}, Ljava/lang/System;->arraycopy(Ljava/lang/Object;ILjava/lang/Object;II)V
+
+    move-object v1, v5
+
+    :goto_2
+    invoke-virtual {p0, v0, v1}, Ljava/util/concurrent/atomic/AtomicReference;->compareAndSet(Ljava/lang/Object;Ljava/lang/Object;)Z
+
+    move-result v0
+
+    if-eqz v0, :cond_0
+
+    :cond_6
+    :goto_3
+    return-void
+.end method
+
+.method public call(Ljava/lang/Object;)V
+    .locals 5
+
+    check-cast p1, Lrx/Subscriber;
+
+    new-instance v0, Lrx/subjects/PublishSubject$a;
+
+    invoke-direct {v0, p0, p1}, Lrx/subjects/PublishSubject$a;-><init>(Lrx/subjects/PublishSubject$b;Lrx/Subscriber;)V
+
+    invoke-virtual {p1, v0}, Lrx/Subscriber;->add(Lrx/Subscription;)V
+
+    invoke-virtual {p1, v0}, Lrx/Subscriber;->setProducer(Lrx/Producer;)V
+
+    :cond_0
+    invoke-virtual {p0}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object;
+
+    move-result-object v1
+
+    check-cast v1, [Lrx/subjects/PublishSubject$a;
+
+    sget-object v2, Lrx/subjects/PublishSubject$b;->e:[Lrx/subjects/PublishSubject$a;
+
+    const/4 v3, 0x0
+
+    if-ne v1, v2, :cond_1
+
+    goto :goto_0
+
+    :cond_1
+    array-length v2, v1
+
+    add-int/lit8 v4, v2, 0x1
+
+    new-array v4, v4, [Lrx/subjects/PublishSubject$a;
+
+    invoke-static {v1, v3, v4, v3, v2}, Ljava/lang/System;->arraycopy(Ljava/lang/Object;ILjava/lang/Object;II)V
+
+    aput-object v0, v4, v2
+
+    invoke-virtual {p0, v1, v4}, Ljava/util/concurrent/atomic/AtomicReference;->compareAndSet(Ljava/lang/Object;Ljava/lang/Object;)Z
+
+    move-result v1
+
+    if-eqz v1, :cond_0
+
+    const/4 v3, 0x1
+
+    :goto_0
+    if-eqz v3, :cond_2
+
+    invoke-virtual {v0}, Lrx/subjects/PublishSubject$a;->isUnsubscribed()Z
+
+    move-result p1
+
+    if-eqz p1, :cond_4
+
+    invoke-virtual {p0, v0}, Lrx/subjects/PublishSubject$b;->a(Lrx/subjects/PublishSubject$a;)V
+
+    goto :goto_1
+
+    :cond_2
+    iget-object v0, p0, Lrx/subjects/PublishSubject$b;->error:Ljava/lang/Throwable;
+
+    if-eqz v0, :cond_3
+
+    invoke-interface {p1, v0}, Li0/g;->onError(Ljava/lang/Throwable;)V
+
+    goto :goto_1
+
+    :cond_3
+    invoke-interface {p1}, Li0/g;->onCompleted()V
+
+    :cond_4
+    :goto_1
+    return-void
+.end method
+
+.method public onCompleted()V
+    .locals 4
+
+    sget-object v0, Lrx/subjects/PublishSubject$b;->e:[Lrx/subjects/PublishSubject$a;
+
+    invoke-virtual {p0, v0}, Ljava/util/concurrent/atomic/AtomicReference;->getAndSet(Ljava/lang/Object;)Ljava/lang/Object;
+
+    move-result-object v0
+
+    check-cast v0, [Lrx/subjects/PublishSubject$a;
+
+    array-length v1, v0
+
+    const/4 v2, 0x0
+
+    :goto_0
+    if-ge v2, v1, :cond_0
+
+    aget-object v3, v0, v2
+
+    invoke-virtual {v3}, Lrx/subjects/PublishSubject$a;->onCompleted()V
+
+    add-int/lit8 v2, v2, 0x1
+
+    goto :goto_0
+
+    :cond_0
+    return-void
+.end method
+
+.method public onError(Ljava/lang/Throwable;)V
+    .locals 6
+
+    iput-object p1, p0, Lrx/subjects/PublishSubject$b;->error:Ljava/lang/Throwable;
+
+    sget-object v0, Lrx/subjects/PublishSubject$b;->e:[Lrx/subjects/PublishSubject$a;
+
+    invoke-virtual {p0, v0}, Ljava/util/concurrent/atomic/AtomicReference;->getAndSet(Ljava/lang/Object;)Ljava/lang/Object;
+
+    move-result-object v0
+
+    check-cast v0, [Lrx/subjects/PublishSubject$a;
+
+    array-length v1, v0
+
+    const/4 v2, 0x0
+
+    const/4 v3, 0x0
+
+    :goto_0
+    if-ge v3, v1, :cond_1
+
+    aget-object v4, v0, v3
+
+    :try_start_0
+    invoke-virtual {v4, p1}, Lrx/subjects/PublishSubject$a;->onError(Ljava/lang/Throwable;)V
+    :try_end_0
+    .catchall {:try_start_0 .. :try_end_0} :catchall_0
+
+    goto :goto_1
+
+    :catchall_0
+    move-exception v4
+
+    if-nez v2, :cond_0
+
+    new-instance v2, Ljava/util/ArrayList;
+
+    const/4 v5, 0x1
+
+    invoke-direct {v2, v5}, Ljava/util/ArrayList;-><init>(I)V
+
+    :cond_0
+    invoke-interface {v2, v4}, Ljava/util/List;->add(Ljava/lang/Object;)Z
+
+    :goto_1
+    add-int/lit8 v3, v3, 0x1
+
+    goto :goto_0
+
+    :cond_1
+    invoke-static {v2}, Lz/i/s;->W(Ljava/util/List;)V
+
+    return-void
+.end method
+
+.method public onNext(Ljava/lang/Object;)V
+    .locals 4
+    .annotation system Ldalvik/annotation/Signature;
+        value = {
+            "(TT;)V"
+        }
+    .end annotation
+
+    invoke-virtual {p0}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object;
+
+    move-result-object v0
+
+    check-cast v0, [Lrx/subjects/PublishSubject$a;
+
+    array-length v1, v0
+
+    const/4 v2, 0x0
+
+    :goto_0
+    if-ge v2, v1, :cond_0
+
+    aget-object v3, v0, v2
+
+    invoke-virtual {v3, p1}, Lrx/subjects/PublishSubject$a;->onNext(Ljava/lang/Object;)V
+
+    add-int/lit8 v2, v2, 0x1
+
+    goto :goto_0
+
+    :cond_0
+    return-void
+.end method

com.discord/smali_classes2/rx/subjects/PublishSubject.smali

@@ -0,0 +1,112 @@
+.class public final Lrx/subjects/PublishSubject;
+.super Lrx/subjects/Subject;
+.source "PublishSubject.java"
+
+
+# annotations
+.annotation system Ldalvik/annotation/MemberClasses;
+    value = {
+        Lrx/subjects/PublishSubject$a;,
+        Lrx/subjects/PublishSubject$b;
+    }
+.end annotation
+
+.annotation system Ldalvik/annotation/Signature;
+    value = {
+        "<T:",
+        "Ljava/lang/Object;",
+        ">",
+        "Lrx/subjects/Subject<",
+        "TT;TT;>;"
+    }
+.end annotation
+
+
+# instance fields
+.field public final e:Lrx/subjects/PublishSubject$b;
+    .annotation system Ldalvik/annotation/Signature;
+        value = {
+            "Lrx/subjects/PublishSubject$b<",
+            "TT;>;"
+        }
+    .end annotation
+.end field
+
+
+# direct methods
+.method public constructor <init>(Lrx/subjects/PublishSubject$b;)V
+    .locals 0
+    .annotation system Ldalvik/annotation/Signature;
+        value = {
+            "(",
+            "Lrx/subjects/PublishSubject$b<",
+            "TT;>;)V"
+        }
+    .end annotation
+
+    invoke-direct {p0, p1}, Lrx/subjects/Subject;-><init>(Lrx/Observable$a;)V
+
+    iput-object p1, p0, Lrx/subjects/PublishSubject;->e:Lrx/subjects/PublishSubject$b;
+
+    return-void
+.end method
+
+.method public static g0()Lrx/subjects/PublishSubject;
+    .locals 2
+    .annotation system Ldalvik/annotation/Signature;
+        value = {
+            "<T:",
+            "Ljava/lang/Object;",
+            ">()",
+            "Lrx/subjects/PublishSubject<",
+            "TT;>;"
+        }
+    .end annotation
+
+    new-instance v0, Lrx/subjects/PublishSubject;
+
+    new-instance v1, Lrx/subjects/PublishSubject$b;
+
+    invoke-direct {v1}, Lrx/subjects/PublishSubject$b;-><init>()V
+
+    invoke-direct {v0, v1}, Lrx/subjects/PublishSubject;-><init>(Lrx/subjects/PublishSubject$b;)V
+
+    return-object v0
+.end method
+
+
+# virtual methods
+.method public onCompleted()V
+    .locals 1
+
+    iget-object v0, p0, Lrx/subjects/PublishSubject;->e:Lrx/subjects/PublishSubject$b;
+
+    invoke-virtual {v0}, Lrx/subjects/PublishSubject$b;->onCompleted()V
+
+    return-void
+.end method
+
+.method public onError(Ljava/lang/Throwable;)V
+    .locals 1
+
+    iget-object v0, p0, Lrx/subjects/PublishSubject;->e:Lrx/subjects/PublishSubject$b;
+
+    invoke-virtual {v0, p1}, Lrx/subjects/PublishSubject$b;->onError(Ljava/lang/Throwable;)V
+
+    return-void
+.end method
+
+.method public onNext(Ljava/lang/Object;)V
+    .locals 1
+    .annotation system Ldalvik/annotation/Signature;
+        value = {
+            "(TT;)V"
+        }
+    .end annotation
+
+    iget-object v0, p0, Lrx/subjects/PublishSubject;->e:Lrx/subjects/PublishSubject$b;
+
+    invoke-virtual {v0, p1}, Lrx/subjects/PublishSubject$b;->onNext(Ljava/lang/Object;)V
+
+    return-void
+.end method

com.discord/smali_classes2/rx/subjects/SerializedSubject$a.smali

@@ -0,0 +1,55 @@
+.class public Lrx/subjects/SerializedSubject$a;
+.super Ljava/lang/Object;
+.source "SerializedSubject.java"
+
+# interfaces
+.implements Lrx/Observable$a;
+
+
+# annotations
+.annotation system Ldalvik/annotation/EnclosingMethod;
+    value = Lrx/subjects/SerializedSubject;-><init>(Lrx/subjects/Subject;)V
+.end annotation
+
+.annotation system Ldalvik/annotation/InnerClass;
+    accessFlags = 0x1
+    name = null
+.end annotation
+
+.annotation system Ldalvik/annotation/Signature;
+    value = {
+        "Ljava/lang/Object;",
+        "Lrx/Observable$a<",
+        "TR;>;"
+    }
+.end annotation
+
+
+# instance fields
+.field public final synthetic d:Lrx/subjects/Subject;
+
+
+# direct methods
+.method public constructor <init>(Lrx/subjects/Subject;)V
+    .locals 0
+
+    iput-object p1, p0, Lrx/subjects/SerializedSubject$a;->d:Lrx/subjects/Subject;
+
+    invoke-direct {p0}, Ljava/lang/Object;-><init>()V
+
+    return-void
+.end method
+
+
+# virtual methods
+.method public call(Ljava/lang/Object;)V
+    .locals 1
+
+    check-cast p1, Lrx/Subscriber;
+
+    iget-object v0, p0, Lrx/subjects/SerializedSubject$a;->d:Lrx/subjects/Subject;
+
+    invoke-virtual {v0, p1}, Lrx/Observable;->e0(Lrx/Subscriber;)Lrx/Subscription;
+
+    return-void
+.end method

com.discord/smali_classes2/rx/subjects/SerializedSubject.smali

@@ -0,0 +1,92 @@
+.class public Lrx/subjects/SerializedSubject;
+.super Lrx/subjects/Subject;
+.source "SerializedSubject.java"
+
+
+# annotations
+.annotation system Ldalvik/annotation/Signature;
+    value = {
+        "<T:",
+        "Ljava/lang/Object;",
+        "R:",
+        "Ljava/lang/Object;",
+        ">",
+        "Lrx/subjects/Subject<",
+        "TT;TR;>;"
+    }
+.end annotation
+
+
+# instance fields
+.field public final e:Li0/n/c;
+    .annotation system Ldalvik/annotation/Signature;
+        value = {
+            "Li0/n/c<",
+            "TT;>;"
+        }
+    .end annotation
+.end field
+
+
+# direct methods
+.method public constructor <init>(Lrx/subjects/Subject;)V
+    .locals 1
+    .annotation system Ldalvik/annotation/Signature;
+        value = {
+            "(",
+            "Lrx/subjects/Subject<",
+            "TT;TR;>;)V"
+        }
+    .end annotation
+
+    new-instance v0, Lrx/subjects/SerializedSubject$a;
+
+    invoke-direct {v0, p1}, Lrx/subjects/SerializedSubject$a;-><init>(Lrx/subjects/Subject;)V
+
+    invoke-direct {p0, v0}, Lrx/subjects/Subject;-><init>(Lrx/Observable$a;)V
+
+    new-instance v0, Li0/n/c;
+
+    invoke-direct {v0, p1}, Li0/n/c;-><init>(Li0/g;)V
+
+    iput-object v0, p0, Lrx/subjects/SerializedSubject;->e:Li0/n/c;
+
+    return-void
+.end method
+
+
+# virtual methods
+.method public onCompleted()V
+    .locals 1
+
+    iget-object v0, p0, Lrx/subjects/SerializedSubject;->e:Li0/n/c;
+
+    invoke-virtual {v0}, Li0/n/c;->onCompleted()V
+
+    return-void
+.end method
+
+.method public onError(Ljava/lang/Throwable;)V
+    .locals 1
+
+    iget-object v0, p0, Lrx/subjects/SerializedSubject;->e:Li0/n/c;
+
+    invoke-virtual {v0, p1}, Li0/n/c;->onError(Ljava/lang/Throwable;)V
+
+    return-void
+.end method
+
+.method public onNext(Ljava/lang/Object;)V
+    .locals 1
+    .annotation system Ldalvik/annotation/Signature;
+        value = {
+            "(TT;)V"
+        }
+    .end annotation
+
+    iget-object v0, p0, Lrx/subjects/SerializedSubject;->e:Li0/n/c;
+
+    invoke-virtual {v0, p1}, Li0/n/c;->onNext(Ljava/lang/Object;)V
+
+    return-void
+.end method

com.discord/smali_classes2/rx/subjects/Subject.smali

@@ -0,0 +1,39 @@
+.class public abstract Lrx/subjects/Subject;
+.super Lrx/Observable;
+.source "Subject.java"
+
+# interfaces
+.implements Li0/g;
+
+
+# annotations
+.annotation system Ldalvik/annotation/Signature;
+    value = {
+        "<T:",
+        "Ljava/lang/Object;",
+        "R:",
+        "Ljava/lang/Object;",
+        ">",
+        "Lrx/Observable<",
+        "TR;>;",
+        "Li0/g<",
+        "TT;>;"
+    }
+.end annotation
+
+
+# direct methods
+.method public constructor <init>(Lrx/Observable$a;)V
+    .locals 0
+    .annotation system Ldalvik/annotation/Signature;
+        value = {
+            "(",
+            "Lrx/Observable$a<",
+            "TR;>;)V"
+        }
+    .end annotation
+
+    invoke-direct {p0, p1}, Lrx/Observable;-><init>(Lrx/Observable$a;)V
+
+    return-void
+.end method