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