x.smali
.class public abstract Lio/reactivex/x;
.super Ljava/lang/Object;
.source "Single.java"
# interfaces
.implements Lio/reactivex/ab;
# annotations
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">",
"Ljava/lang/Object;",
"Lio/reactivex/ab",
"<TT;>;"
}
.end annotation
# direct methods
.method public constructor <init>()V
.registers 1
.prologue
.line 60
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
return-void
.end method
.method public static a(Lio/reactivex/aa;)Lio/reactivex/x;
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">(",
"Lio/reactivex/aa",
"<TT;>;)",
"Lio/reactivex/x",
"<TT;>;"
}
.end annotation
.prologue
.line 360
const-string v0, "source is null"
invoke-static {p0, v0}, Lio/reactivex/internal/functions/aj;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
.line 361
new-instance v0, Lio/reactivex/internal/operators/single/SingleCreate;
invoke-direct {v0, p0}, Lio/reactivex/internal/operators/single/SingleCreate;-><init>(Lio/reactivex/aa;)V
.line 4083
sget-object v1, Lio/reactivex/d/a;->bTz:Lio/reactivex/b/h;
.line 361
return-object v0
.end method
# virtual methods
.method public final Pw()Lio/reactivex/k;
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"()",
"Lio/reactivex/k",
"<TT;>;"
}
.end annotation
.prologue
.line 3462
instance-of v0, p0, Lio/reactivex/internal/a/a;
if-eqz v0, :cond_b
.line 3463
check-cast p0, Lio/reactivex/internal/a/a;
invoke-interface {p0}, Lio/reactivex/internal/a/a;->PO()Lio/reactivex/k;
move-result-object v0
.line 3465
:goto_a
return-object v0
:cond_b
new-instance v0, Lio/reactivex/internal/operators/single/c;
invoke-direct {v0, p0}, Lio/reactivex/internal/operators/single/c;-><init>(Lio/reactivex/ab;)V
.line 8051
sget-object v1, Lio/reactivex/d/a;->bTw:Lio/reactivex/b/h;
goto :goto_a
.end method
.method public final a(Lio/reactivex/b/h;)Lio/reactivex/x;
.registers 4
.annotation system Ldalvik/annotation/Signature;
value = {
"<R:",
"Ljava/lang/Object;",
">(",
"Lio/reactivex/b/h",
"<-TT;+TR;>;)",
"Lio/reactivex/x",
"<TR;>;"
}
.end annotation
.prologue
.line 2538
const-string v0, "mapper is null"
invoke-static {p1, v0}, Lio/reactivex/internal/functions/aj;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
.line 2539
new-instance v0, Lio/reactivex/internal/operators/single/a;
invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/single/a;-><init>(Lio/reactivex/ab;Lio/reactivex/b/h;)V
.line 5083
sget-object v1, Lio/reactivex/d/a;->bTz:Lio/reactivex/b/h;
.line 2539
return-object v0
.end method
.method public final a(Lio/reactivex/s;)Lio/reactivex/x;
.registers 4
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/s;",
")",
"Lio/reactivex/x",
"<TT;>;"
}
.end annotation
.prologue
.line 2628
const-string v0, "scheduler is null"
invoke-static {p1, v0}, Lio/reactivex/internal/functions/aj;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
.line 2629
new-instance v0, Lio/reactivex/internal/operators/single/SingleObserveOn;
invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/single/SingleObserveOn;-><init>(Lio/reactivex/ab;Lio/reactivex/s;)V
.line 6083
sget-object v1, Lio/reactivex/d/a;->bTz:Lio/reactivex/b/h;
.line 2629
return-object v0
.end method
.method public final b(Lio/reactivex/s;)Lio/reactivex/x;
.registers 4
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/s;",
")",
"Lio/reactivex/x",
"<TT;>;"
}
.end annotation
.prologue
.line 3163
const-string v0, "scheduler is null"
invoke-static {p1, v0}, Lio/reactivex/internal/functions/aj;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
.line 3164
new-instance v0, Lio/reactivex/internal/operators/single/SingleSubscribeOn;
invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/single/SingleSubscribeOn;-><init>(Lio/reactivex/ab;Lio/reactivex/s;)V
.line 7083
sget-object v1, Lio/reactivex/d/a;->bTz:Lio/reactivex/b/h;
.line 3164
return-object v0
.end method
.method public final b(Lio/reactivex/z;)V
.registers 5
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/z",
"<-TT;>;)V"
}
.end annotation
.prologue
.line 3089
const-string v0, "subscriber is null"
invoke-static {p1, v0}, Lio/reactivex/internal/functions/aj;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
.line 6955
sget-object v0, Lio/reactivex/d/a;->bTE:Lio/reactivex/b/c;
.line 3093
const-string v0, "subscriber returned by the RxJavaPlugins hook is null"
invoke-static {p1, v0}, Lio/reactivex/internal/functions/aj;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
.line 3096
:try_start_c
invoke-virtual {p0, p1}, Lio/reactivex/x;->c(Lio/reactivex/z;)V
:try_end_f
.catch Ljava/lang/NullPointerException; {:try_start_c .. :try_end_f} :catch_10
.catch Ljava/lang/Throwable; {:try_start_c .. :try_end_f} :catch_12
.line 3104
return-void
.line 3098
:catch_10
move-exception v0
throw v0
.line 3099
:catch_12
move-exception v0
.line 3100
invoke-static {v0}, Lio/reactivex/exceptions/d;->throwIfFatal(Ljava/lang/Throwable;)V
.line 3101
new-instance v1, Ljava/lang/NullPointerException;
const-string v2, "subscribeActual failed"
invoke-direct {v1, v2}, Ljava/lang/NullPointerException;-><init>(Ljava/lang/String;)V
.line 3102
invoke-virtual {v1, v0}, Ljava/lang/NullPointerException;->initCause(Ljava/lang/Throwable;)Ljava/lang/Throwable;
.line 3103
throw v1
.end method
.method public abstract c(Lio/reactivex/z;)V
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/z",
"<-TT;>;)V"
}
.end annotation
.end method
.method public final subscribe(Lio/reactivex/b/g;Lio/reactivex/b/g;)Lio/reactivex/disposables/b;
.registers 4
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/b/g",
"<-TT;>;",
"Lio/reactivex/b/g",
"<-",
"Ljava/lang/Throwable;",
">;)",
"Lio/reactivex/disposables/b;"
}
.end annotation
.prologue
.line 3078
const-string v0, "onSuccess is null"
invoke-static {p1, v0}, Lio/reactivex/internal/functions/aj;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
.line 3079
const-string v0, "onError is null"
invoke-static {p2, v0}, Lio/reactivex/internal/functions/aj;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
.line 3081
new-instance v0, Lio/reactivex/internal/observers/ConsumerSingleObserver;
invoke-direct {v0, p1, p2}, Lio/reactivex/internal/observers/ConsumerSingleObserver;-><init>(Lio/reactivex/b/g;Lio/reactivex/b/g;)V
.line 3082
invoke-virtual {p0, v0}, Lio/reactivex/x;->b(Lio/reactivex/z;)V
.line 3083
return-object v0
.end method