Changes of com.discord v1349

This commit is contained in:
root 2020-11-30 22:35:21 +00:00
parent ee3363e6d6
commit 3f4974bc38
11672 changed files with 479129 additions and 478996 deletions

View file

@ -0,0 +1,60 @@
.class public final Lg0/n/a$a;
.super Ljava/lang/Object;
.source "Observers.java"
# interfaces
.implements Lg0/g;
# annotations
.annotation system Ldalvik/annotation/EnclosingClass;
value = Lg0/n/a;
.end annotation
.annotation system Ldalvik/annotation/InnerClass;
accessFlags = 0x9
name = null
.end annotation
.annotation system Ldalvik/annotation/Signature;
value = {
"Ljava/lang/Object;",
"Lg0/g<",
"Ljava/lang/Object;",
">;"
}
.end annotation
# direct methods
.method public constructor <init>()V
.locals 0
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
return-void
.end method
# virtual methods
.method public final onCompleted()V
.locals 0
return-void
.end method
.method public final onError(Ljava/lang/Throwable;)V
.locals 1
new-instance v0, Lrx/exceptions/OnErrorNotImplementedException;
invoke-direct {v0, p1}, Lrx/exceptions/OnErrorNotImplementedException;-><init>(Ljava/lang/Throwable;)V
throw v0
.end method
.method public final onNext(Ljava/lang/Object;)V
.locals 0
return-void
.end method

View file

@ -0,0 +1,29 @@
.class public final Lg0/n/a;
.super Ljava/lang/Object;
.source "Observers.java"
# static fields
.field public static final a:Lg0/g;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lg0/g<",
"Ljava/lang/Object;",
">;"
}
.end annotation
.end field
# direct methods
.method public static constructor <clinit>()V
.locals 1
new-instance v0, Lg0/n/a$a;
invoke-direct {v0}, Lg0/n/a$a;-><init>()V
sput-object v0, Lg0/n/a;->a:Lg0/g;
return-void
.end method

View file

@ -0,0 +1,328 @@
.class public Lg0/n/b;
.super Lrx/Subscriber;
.source "SafeSubscriber.java"
# annotations
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">",
"Lrx/Subscriber<",
"TT;>;"
}
.end annotation
# instance fields
.field public final d:Lrx/Subscriber;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lrx/Subscriber<",
"-TT;>;"
}
.end annotation
.end field
.field public e:Z
# direct methods
.method public constructor <init>(Lrx/Subscriber;)V
.locals 0
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lrx/Subscriber<",
"-TT;>;)V"
}
.end annotation
invoke-direct {p0, p1}, Lrx/Subscriber;-><init>(Lrx/Subscriber;)V
iput-object p1, p0, Lg0/n/b;->d:Lrx/Subscriber;
return-void
.end method
# virtual methods
.method public onCompleted()V
.locals 3
iget-boolean v0, p0, Lg0/n/b;->e:Z
if-nez v0, :cond_0
const/4 v0, 0x1
iput-boolean v0, p0, Lg0/n/b;->e:Z
:try_start_0
iget-object v0, p0, Lg0/n/b;->d:Lrx/Subscriber;
invoke-interface {v0}, Lg0/g;->onCompleted()V
:try_end_0
.catchall {:try_start_0 .. :try_end_0} :catchall_1
:try_start_1
invoke-virtual {p0}, Lrx/Subscriber;->unsubscribe()V
:try_end_1
.catchall {:try_start_1 .. :try_end_1} :catchall_0
goto :goto_0
:catchall_0
move-exception v0
invoke-static {v0}, Lg0/o/l;->b(Ljava/lang/Throwable;)V
new-instance v1, Lrx/exceptions/UnsubscribeFailedException;
invoke-virtual {v0}, Ljava/lang/Throwable;->getMessage()Ljava/lang/String;
move-result-object v2
invoke-direct {v1, v2, v0}, Lrx/exceptions/UnsubscribeFailedException;-><init>(Ljava/lang/String;Ljava/lang/Throwable;)V
throw v1
:catchall_1
move-exception v0
:try_start_2
invoke-static {v0}, Ly/a/g0;->P(Ljava/lang/Throwable;)V
invoke-static {v0}, Lg0/o/l;->b(Ljava/lang/Throwable;)V
new-instance v1, Lrx/exceptions/OnCompletedFailedException;
invoke-virtual {v0}, Ljava/lang/Throwable;->getMessage()Ljava/lang/String;
move-result-object v2
invoke-direct {v1, v2, v0}, Lrx/exceptions/OnCompletedFailedException;-><init>(Ljava/lang/String;Ljava/lang/Throwable;)V
throw v1
:try_end_2
.catchall {:try_start_2 .. :try_end_2} :catchall_2
:catchall_2
move-exception v0
:try_start_3
invoke-virtual {p0}, Lrx/Subscriber;->unsubscribe()V
:try_end_3
.catchall {:try_start_3 .. :try_end_3} :catchall_3
throw v0
:catchall_3
move-exception v0
invoke-static {v0}, Lg0/o/l;->b(Ljava/lang/Throwable;)V
new-instance v1, Lrx/exceptions/UnsubscribeFailedException;
invoke-virtual {v0}, Ljava/lang/Throwable;->getMessage()Ljava/lang/String;
move-result-object v2
invoke-direct {v1, v2, v0}, Lrx/exceptions/UnsubscribeFailedException;-><init>(Ljava/lang/String;Ljava/lang/Throwable;)V
throw v1
:cond_0
:goto_0
return-void
.end method
.method public onError(Ljava/lang/Throwable;)V
.locals 8
invoke-static {p1}, Ly/a/g0;->P(Ljava/lang/Throwable;)V
iget-boolean v0, p0, Lg0/n/b;->e:Z
if-nez v0, :cond_0
const/4 v0, 0x1
iput-boolean v0, p0, Lg0/n/b;->e:Z
sget-object v1, Lg0/o/o;->f:Lg0/o/o;
invoke-virtual {v1}, Lg0/o/o;->b()Lg0/o/b;
move-result-object v1
invoke-static {v1}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;)Ljava/lang/Object;
const/4 v1, 0x0
const/4 v2, 0x2
:try_start_0
iget-object v3, p0, Lg0/n/b;->d:Lrx/Subscriber;
invoke-interface {v3, p1}, Lg0/g;->onError(Ljava/lang/Throwable;)V
:try_end_0
.catch Lrx/exceptions/OnErrorNotImplementedException; {:try_start_0 .. :try_end_0} :catch_0
.catchall {:try_start_0 .. :try_end_0} :catchall_1
:try_start_1
invoke-virtual {p0}, Lrx/Subscriber;->unsubscribe()V
:try_end_1
.catchall {:try_start_1 .. :try_end_1} :catchall_0
goto :goto_0
:catchall_0
move-exception p1
invoke-static {p1}, Lg0/o/l;->b(Ljava/lang/Throwable;)V
new-instance v0, Lrx/exceptions/OnErrorFailedException;
invoke-direct {v0, p1}, Lrx/exceptions/OnErrorFailedException;-><init>(Ljava/lang/Throwable;)V
throw v0
:catchall_1
move-exception v3
invoke-static {v3}, Lg0/o/l;->b(Ljava/lang/Throwable;)V
:try_start_2
invoke-virtual {p0}, Lrx/Subscriber;->unsubscribe()V
:try_end_2
.catchall {:try_start_2 .. :try_end_2} :catchall_2
new-instance v4, Lrx/exceptions/OnErrorFailedException;
new-instance v5, Lrx/exceptions/CompositeException;
new-array v2, v2, [Ljava/lang/Throwable;
aput-object p1, v2, v1
aput-object v3, v2, v0
invoke-static {v2}, Ljava/util/Arrays;->asList([Ljava/lang/Object;)Ljava/util/List;
move-result-object p1
invoke-direct {v5, p1}, Lrx/exceptions/CompositeException;-><init>(Ljava/util/Collection;)V
const-string p1, "Error occurred when trying to propagate error to Observer.onError"
invoke-direct {v4, p1, v5}, Lrx/exceptions/OnErrorFailedException;-><init>(Ljava/lang/String;Ljava/lang/Throwable;)V
throw v4
:catchall_2
move-exception v4
invoke-static {v4}, Lg0/o/l;->b(Ljava/lang/Throwable;)V
new-instance v5, Lrx/exceptions/OnErrorFailedException;
new-instance v6, Lrx/exceptions/CompositeException;
const/4 v7, 0x3
new-array v7, v7, [Ljava/lang/Throwable;
aput-object p1, v7, v1
aput-object v3, v7, v0
aput-object v4, v7, v2
invoke-static {v7}, Ljava/util/Arrays;->asList([Ljava/lang/Object;)Ljava/util/List;
move-result-object p1
invoke-direct {v6, p1}, Lrx/exceptions/CompositeException;-><init>(Ljava/util/Collection;)V
const-string p1, "Error occurred when trying to propagate error to Observer.onError and during unsubscription."
invoke-direct {v5, p1, v6}, Lrx/exceptions/OnErrorFailedException;-><init>(Ljava/lang/String;Ljava/lang/Throwable;)V
throw v5
:catch_0
move-exception v3
:try_start_3
invoke-virtual {p0}, Lrx/Subscriber;->unsubscribe()V
:try_end_3
.catchall {:try_start_3 .. :try_end_3} :catchall_3
throw v3
:catchall_3
move-exception v3
invoke-static {v3}, Lg0/o/l;->b(Ljava/lang/Throwable;)V
new-instance v4, Lrx/exceptions/OnErrorNotImplementedException;
new-instance v5, Lrx/exceptions/CompositeException;
new-array v2, v2, [Ljava/lang/Throwable;
aput-object p1, v2, v1
aput-object v3, v2, v0
invoke-static {v2}, Ljava/util/Arrays;->asList([Ljava/lang/Object;)Ljava/util/List;
move-result-object p1
invoke-direct {v5, p1}, Lrx/exceptions/CompositeException;-><init>(Ljava/util/Collection;)V
const-string p1, "Observer.onError not implemented and error while unsubscribing."
invoke-direct {v4, p1, v5}, Lrx/exceptions/OnErrorNotImplementedException;-><init>(Ljava/lang/String;Ljava/lang/Throwable;)V
throw v4
:cond_0
:goto_0
return-void
.end method
.method public onNext(Ljava/lang/Object;)V
.locals 1
.annotation system Ldalvik/annotation/Signature;
value = {
"(TT;)V"
}
.end annotation
:try_start_0
iget-boolean v0, p0, Lg0/n/b;->e:Z
if-nez v0, :cond_0
iget-object v0, p0, Lg0/n/b;->d:Lrx/Subscriber;
invoke-interface {v0, p1}, Lg0/g;->onNext(Ljava/lang/Object;)V
:try_end_0
.catchall {:try_start_0 .. :try_end_0} :catchall_0
goto :goto_0
:catchall_0
move-exception p1
invoke-static {p1}, Ly/a/g0;->P(Ljava/lang/Throwable;)V
invoke-virtual {p0, p1}, Lg0/n/b;->onError(Ljava/lang/Throwable;)V
:cond_0
:goto_0
return-void
.end method

View file

@ -0,0 +1,79 @@
.class public final Lg0/n/c$a;
.super Ljava/lang/Object;
.source "SerializedObserver.java"
# annotations
.annotation system Ldalvik/annotation/EnclosingClass;
value = Lg0/n/c;
.end annotation
.annotation system Ldalvik/annotation/InnerClass;
accessFlags = 0x19
name = "a"
.end annotation
# instance fields
.field public a:[Ljava/lang/Object;
.field public b:I
# direct methods
.method public constructor <init>()V
.locals 0
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
return-void
.end method
# virtual methods
.method public a(Ljava/lang/Object;)V
.locals 4
iget v0, p0, Lg0/n/c$a;->b:I
iget-object v1, p0, Lg0/n/c$a;->a:[Ljava/lang/Object;
if-nez v1, :cond_0
const/16 v1, 0x10
new-array v1, v1, [Ljava/lang/Object;
iput-object v1, p0, Lg0/n/c$a;->a:[Ljava/lang/Object;
goto :goto_0
:cond_0
array-length v2, v1
if-ne v0, v2, :cond_1
shr-int/lit8 v2, v0, 0x2
add-int/2addr v2, v0
new-array v2, v2, [Ljava/lang/Object;
const/4 v3, 0x0
invoke-static {v1, v3, v2, v3, v0}, Ljava/lang/System;->arraycopy(Ljava/lang/Object;ILjava/lang/Object;II)V
iput-object v2, p0, Lg0/n/c$a;->a:[Ljava/lang/Object;
move-object v1, v2
:cond_1
:goto_0
aput-object p1, v1, v0
add-int/lit8 v0, v0, 0x1
iput v0, p0, Lg0/n/c$a;->b:I
return-void
.end method

View file

@ -0,0 +1,391 @@
.class public Lg0/n/c;
.super Ljava/lang/Object;
.source "SerializedObserver.java"
# interfaces
.implements Lg0/g;
# annotations
.annotation system Ldalvik/annotation/MemberClasses;
value = {
Lg0/n/c$a;
}
.end annotation
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">",
"Ljava/lang/Object;",
"Lg0/g<",
"TT;>;"
}
.end annotation
# instance fields
.field public final d:Lg0/g;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lg0/g<",
"-TT;>;"
}
.end annotation
.end field
.field public e:Z
.field public volatile f:Z
.field public g:Lg0/n/c$a;
# direct methods
.method public constructor <init>(Lg0/g;)V
.locals 0
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lg0/g<",
"-TT;>;)V"
}
.end annotation
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
iput-object p1, p0, Lg0/n/c;->d:Lg0/g;
return-void
.end method
# virtual methods
.method public onCompleted()V
.locals 2
iget-boolean v0, p0, Lg0/n/c;->f:Z
if-eqz v0, :cond_0
return-void
:cond_0
monitor-enter p0
:try_start_0
iget-boolean v0, p0, Lg0/n/c;->f:Z
if-eqz v0, :cond_1
monitor-exit p0
return-void
:cond_1
const/4 v0, 0x1
iput-boolean v0, p0, Lg0/n/c;->f:Z
iget-boolean v1, p0, Lg0/n/c;->e:Z
if-eqz v1, :cond_3
iget-object v0, p0, Lg0/n/c;->g:Lg0/n/c$a;
if-nez v0, :cond_2
new-instance v0, Lg0/n/c$a;
invoke-direct {v0}, Lg0/n/c$a;-><init>()V
iput-object v0, p0, Lg0/n/c;->g:Lg0/n/c$a;
:cond_2
sget-object v1, Lg0/l/a/h;->a:Ljava/lang/Object;
invoke-virtual {v0, v1}, Lg0/n/c$a;->a(Ljava/lang/Object;)V
monitor-exit p0
return-void
:cond_3
iput-boolean v0, p0, Lg0/n/c;->e:Z
monitor-exit p0
:try_end_0
.catchall {:try_start_0 .. :try_end_0} :catchall_0
iget-object v0, p0, Lg0/n/c;->d:Lg0/g;
invoke-interface {v0}, Lg0/g;->onCompleted()V
return-void
: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
.end method
.method public onError(Ljava/lang/Throwable;)V
.locals 2
invoke-static {p1}, Ly/a/g0;->P(Ljava/lang/Throwable;)V
iget-boolean v0, p0, Lg0/n/c;->f:Z
if-eqz v0, :cond_0
return-void
:cond_0
monitor-enter p0
:try_start_0
iget-boolean v0, p0, Lg0/n/c;->f:Z
if-eqz v0, :cond_1
monitor-exit p0
return-void
:cond_1
const/4 v0, 0x1
iput-boolean v0, p0, Lg0/n/c;->f:Z
iget-boolean v1, p0, Lg0/n/c;->e:Z
if-eqz v1, :cond_3
iget-object v0, p0, Lg0/n/c;->g:Lg0/n/c$a;
if-nez v0, :cond_2
new-instance v0, Lg0/n/c$a;
invoke-direct {v0}, Lg0/n/c$a;-><init>()V
iput-object v0, p0, Lg0/n/c;->g:Lg0/n/c$a;
:cond_2
new-instance v1, Lg0/l/a/h$c;
invoke-direct {v1, p1}, Lg0/l/a/h$c;-><init>(Ljava/lang/Throwable;)V
invoke-virtual {v0, v1}, Lg0/n/c$a;->a(Ljava/lang/Object;)V
monitor-exit p0
return-void
:cond_3
iput-boolean v0, p0, Lg0/n/c;->e:Z
monitor-exit p0
:try_end_0
.catchall {:try_start_0 .. :try_end_0} :catchall_0
iget-object v0, p0, Lg0/n/c;->d:Lg0/g;
invoke-interface {v0, p1}, Lg0/g;->onError(Ljava/lang/Throwable;)V
return-void
:catchall_0
move-exception p1
:try_start_1
monitor-exit p0
:try_end_1
.catchall {:try_start_1 .. :try_end_1} :catchall_0
throw p1
.end method
.method public onNext(Ljava/lang/Object;)V
.locals 6
.annotation system Ldalvik/annotation/Signature;
value = {
"(TT;)V"
}
.end annotation
iget-boolean v0, p0, Lg0/n/c;->f:Z
if-eqz v0, :cond_0
return-void
:cond_0
monitor-enter p0
:try_start_0
iget-boolean v0, p0, Lg0/n/c;->f:Z
if-eqz v0, :cond_1
monitor-exit p0
return-void
:cond_1
iget-boolean v0, p0, Lg0/n/c;->e:Z
if-eqz v0, :cond_4
iget-object v0, p0, Lg0/n/c;->g:Lg0/n/c$a;
if-nez v0, :cond_2
new-instance v0, Lg0/n/c$a;
invoke-direct {v0}, Lg0/n/c$a;-><init>()V
iput-object v0, p0, Lg0/n/c;->g:Lg0/n/c$a;
:cond_2
if-nez p1, :cond_3
sget-object p1, Lg0/l/a/h;->b:Ljava/lang/Object;
:cond_3
invoke-virtual {v0, p1}, Lg0/n/c$a;->a(Ljava/lang/Object;)V
monitor-exit p0
return-void
:cond_4
const/4 v0, 0x1
iput-boolean v0, p0, Lg0/n/c;->e:Z
monitor-exit p0
:try_end_0
.catchall {:try_start_0 .. :try_end_0} :catchall_3
:try_start_1
iget-object v1, p0, Lg0/n/c;->d:Lg0/g;
invoke-interface {v1, p1}, Lg0/g;->onNext(Ljava/lang/Object;)V
:try_end_1
.catchall {:try_start_1 .. :try_end_1} :catchall_2
:cond_5
:goto_0
monitor-enter p0
:try_start_2
iget-object v1, p0, Lg0/n/c;->g:Lg0/n/c$a;
const/4 v2, 0x0
if-nez v1, :cond_6
iput-boolean v2, p0, Lg0/n/c;->e:Z
monitor-exit p0
return-void
:cond_6
const/4 v3, 0x0
iput-object v3, p0, Lg0/n/c;->g:Lg0/n/c$a;
monitor-exit p0
:try_end_2
.catchall {:try_start_2 .. :try_end_2} :catchall_1
iget-object v1, v1, Lg0/n/c$a;->a:[Ljava/lang/Object;
array-length v3, v1
:goto_1
if-ge v2, v3, :cond_5
aget-object v4, v1, v2
if-nez v4, :cond_7
goto :goto_0
:cond_7
:try_start_3
iget-object v5, p0, Lg0/n/c;->d:Lg0/g;
invoke-static {v5, v4}, Lg0/l/a/h;->a(Lg0/g;Ljava/lang/Object;)Z
move-result v4
if-eqz v4, :cond_8
iput-boolean v0, p0, Lg0/n/c;->f:Z
:try_end_3
.catchall {:try_start_3 .. :try_end_3} :catchall_0
return-void
:cond_8
add-int/lit8 v2, v2, 0x1
goto :goto_1
:catchall_0
move-exception v1
iput-boolean v0, p0, Lg0/n/c;->f:Z
invoke-static {v1}, Ly/a/g0;->P(Ljava/lang/Throwable;)V
iget-object v0, p0, Lg0/n/c;->d:Lg0/g;
invoke-static {v1, p1}, Lrx/exceptions/OnErrorThrowable;->a(Ljava/lang/Throwable;Ljava/lang/Object;)Ljava/lang/Throwable;
move-result-object p1
invoke-interface {v0, p1}, Lg0/g;->onError(Ljava/lang/Throwable;)V
return-void
:catchall_1
move-exception p1
:try_start_4
monitor-exit p0
:try_end_4
.catchall {:try_start_4 .. :try_end_4} :catchall_1
throw p1
:catchall_2
move-exception v1
iput-boolean v0, p0, Lg0/n/c;->f:Z
iget-object v0, p0, Lg0/n/c;->d:Lg0/g;
invoke-static {v1, v0, p1}, Ly/a/g0;->Q(Ljava/lang/Throwable;Lg0/g;Ljava/lang/Object;)V
return-void
:catchall_3
move-exception p1
:try_start_5
monitor-exit p0
:try_end_5
.catchall {:try_start_5 .. :try_end_5} :catchall_3
throw p1
.end method

View file

@ -0,0 +1,65 @@
.class public final Lg0/n/d;
.super Lrx/Subscriber;
.source "Subscribers.java"
# annotations
.annotation system Ldalvik/annotation/Signature;
value = {
"Lrx/Subscriber<",
"TT;>;"
}
.end annotation
# instance fields
.field public final synthetic d:Lg0/g;
# direct methods
.method public constructor <init>(Lg0/g;)V
.locals 0
iput-object p1, p0, Lg0/n/d;->d:Lg0/g;
invoke-direct {p0}, Lrx/Subscriber;-><init>()V
return-void
.end method
# virtual methods
.method public onCompleted()V
.locals 1
iget-object v0, p0, Lg0/n/d;->d:Lg0/g;
invoke-interface {v0}, Lg0/g;->onCompleted()V
return-void
.end method
.method public onError(Ljava/lang/Throwable;)V
.locals 1
iget-object v0, p0, Lg0/n/d;->d:Lg0/g;
invoke-interface {v0, p1}, Lg0/g;->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, Lg0/n/d;->d:Lg0/g;
invoke-interface {v0, p1}, Lg0/g;->onNext(Ljava/lang/Object;)V
return-void
.end method

View file

@ -0,0 +1,65 @@
.class public final Lg0/n/e;
.super Lrx/Subscriber;
.source "Subscribers.java"
# annotations
.annotation system Ldalvik/annotation/Signature;
value = {
"Lrx/Subscriber<",
"TT;>;"
}
.end annotation
# instance fields
.field public final synthetic d:Lrx/Subscriber;
# direct methods
.method public constructor <init>(Lrx/Subscriber;Lrx/Subscriber;)V
.locals 0
iput-object p2, p0, Lg0/n/e;->d:Lrx/Subscriber;
invoke-direct {p0, p1}, Lrx/Subscriber;-><init>(Lrx/Subscriber;)V
return-void
.end method
# virtual methods
.method public onCompleted()V
.locals 1
iget-object v0, p0, Lg0/n/e;->d:Lrx/Subscriber;
invoke-interface {v0}, Lg0/g;->onCompleted()V
return-void
.end method
.method public onError(Ljava/lang/Throwable;)V
.locals 1
iget-object v0, p0, Lg0/n/e;->d:Lrx/Subscriber;
invoke-interface {v0, p1}, Lg0/g;->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, Lg0/n/e;->d:Lrx/Subscriber;
invoke-interface {v0, p1}, Lg0/g;->onNext(Ljava/lang/Object;)V
return-void
.end method