2022-06-10 21:38:30 +09:00

97 lines
2.1 KiB
Smali

.class public final Lio/reactivex/internal/operators/maybe/MaybeCreate;
.super Lkh/q;
.source "MaybeCreate.java"
# annotations
.annotation system Ldalvik/annotation/MemberClasses;
value = {
Lio/reactivex/internal/operators/maybe/MaybeCreate$Emitter;
}
.end annotation
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">",
"Lkh/q<",
"TT;>;"
}
.end annotation
# instance fields
.field public final a:Lkh/u;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lkh/u<",
"TT;>;"
}
.end annotation
.end field
# direct methods
.method public constructor <init>(Lkh/u;)V
.locals 0
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lkh/u<",
"TT;>;)V"
}
.end annotation
.line 1
invoke-direct {p0}, Lkh/q;-><init>()V
.line 2
iput-object p1, p0, Lio/reactivex/internal/operators/maybe/MaybeCreate;->a:Lkh/u;
return-void
.end method
# virtual methods
.method public p1(Lkh/t;)V
.locals 1
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lkh/t<",
"-TT;>;)V"
}
.end annotation
.line 1
new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeCreate$Emitter;
invoke-direct {v0, p1}, Lio/reactivex/internal/operators/maybe/MaybeCreate$Emitter;-><init>(Lkh/t;)V
.line 2
invoke-interface {p1, v0}, Lkh/t;->onSubscribe(Lio/reactivex/disposables/b;)V
.line 3
:try_start_0
iget-object p1, p0, Lio/reactivex/internal/operators/maybe/MaybeCreate;->a:Lkh/u;
invoke-interface {p1, v0}, Lkh/u;->a(Lkh/s;)V
:try_end_0
.catchall {:try_start_0 .. :try_end_0} :catchall_0
goto :goto_0
:catchall_0
move-exception p1
.line 4
invoke-static {p1}, Lio/reactivex/exceptions/a;->b(Ljava/lang/Throwable;)V
.line 5
invoke-virtual {v0, p1}, Lio/reactivex/internal/operators/maybe/MaybeCreate$Emitter;->onError(Ljava/lang/Throwable;)V
:goto_0
return-void
.end method