c.smali

.class public final Lio/reactivex/rxkotlin/c;
.super Ljava/lang/Object;
.source "subscribers.kt"


# static fields
.field private static final a:Lkotlin/jvm/a/l;
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "Lkotlin/jvm/a/l<",
            "Ljava/lang/Object;",
            "Lkotlin/n;",
            ">;"
        }
    .end annotation
.end field

.field private static final b:Lkotlin/jvm/a/l;
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "Lkotlin/jvm/a/l<",
            "Ljava/lang/Throwable;",
            "Lkotlin/n;",
            ">;"
        }
    .end annotation
.end field

.field private static final c:Lkotlin/jvm/a/a;
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "Lkotlin/jvm/a/a<",
            "Lkotlin/n;",
            ">;"
        }
    .end annotation
.end field


# direct methods
.method static constructor <clinit>()V
    .registers 1

    .line 1
    sget-object v0, Lio/reactivex/rxkotlin/SubscribersKt$onNextStub$1;->INSTANCE:Lio/reactivex/rxkotlin/SubscribersKt$onNextStub$1;

    sput-object v0, Lio/reactivex/rxkotlin/c;->a:Lkotlin/jvm/a/l;

    .line 2
    sget-object v0, Lio/reactivex/rxkotlin/SubscribersKt$onErrorStub$1;->INSTANCE:Lio/reactivex/rxkotlin/SubscribersKt$onErrorStub$1;

    sput-object v0, Lio/reactivex/rxkotlin/c;->b:Lkotlin/jvm/a/l;

    .line 3
    sget-object v0, Lio/reactivex/rxkotlin/SubscribersKt$onCompleteStub$1;->INSTANCE:Lio/reactivex/rxkotlin/SubscribersKt$onCompleteStub$1;

    sput-object v0, Lio/reactivex/rxkotlin/c;->c:Lkotlin/jvm/a/a;

    return-void
.end method

.method private static final a(Lkotlin/jvm/a/a;)Lio/reactivex/b/a;
    .registers 2
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Lkotlin/jvm/a/a<",
            "Lkotlin/n;",
            ">;)",
            "Lio/reactivex/b/a;"
        }
    .end annotation

    .line 2
    sget-object v0, Lio/reactivex/rxkotlin/c;->c:Lkotlin/jvm/a/a;

    if-ne p0, v0, :cond_c

    sget-object p0, Lio/reactivex/internal/functions/Functions;->c:Lio/reactivex/b/a;

    const-string v0, "Functions.EMPTY_ACTION"

    invoke-static {p0, v0}, Lkotlin/jvm/internal/i;->a(Ljava/lang/Object;Ljava/lang/String;)V

    goto :goto_16

    :cond_c
    if-eqz p0, :cond_14

    new-instance v0, Lio/reactivex/rxkotlin/a;

    invoke-direct {v0, p0}, Lio/reactivex/rxkotlin/a;-><init>(Lkotlin/jvm/a/a;)V

    move-object p0, v0

    :cond_14
    check-cast p0, Lio/reactivex/b/a;

    :goto_16
    return-object p0
.end method

.method private static final a(Lkotlin/jvm/a/l;)Lio/reactivex/b/g;
    .registers 2
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "<T:",
            "Ljava/lang/Object;",
            ">(",
            "Lkotlin/jvm/a/l<",
            "-TT;",
            "Lkotlin/n;",
            ">;)",
            "Lio/reactivex/b/g<",
            "TT;>;"
        }
    .end annotation

    .line 1
    sget-object v0, Lio/reactivex/rxkotlin/c;->a:Lkotlin/jvm/a/l;

    if-ne p0, v0, :cond_e

    invoke-static {}, Lio/reactivex/internal/functions/Functions;->d()Lio/reactivex/b/g;

    move-result-object p0

    const-string v0, "Functions.emptyConsumer()"

    invoke-static {p0, v0}, Lkotlin/jvm/internal/i;->a(Ljava/lang/Object;Ljava/lang/String;)V

    goto :goto_18

    :cond_e
    if-eqz p0, :cond_16

    new-instance v0, Lio/reactivex/rxkotlin/b;

    invoke-direct {v0, p0}, Lio/reactivex/rxkotlin/b;-><init>(Lkotlin/jvm/a/l;)V

    move-object p0, v0

    :cond_16
    check-cast p0, Lio/reactivex/b/g;

    :goto_18
    return-object p0
.end method

.method public static final a(Lio/reactivex/e;Lkotlin/jvm/a/l;Lkotlin/jvm/a/a;Lkotlin/jvm/a/l;)Lio/reactivex/disposables/b;
    .registers 5
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "<T:",
            "Ljava/lang/Object;",
            ">(",
            "Lio/reactivex/e<",
            "TT;>;",
            "Lkotlin/jvm/a/l<",
            "-",
            "Ljava/lang/Throwable;",
            "Lkotlin/n;",
            ">;",
            "Lkotlin/jvm/a/a<",
            "Lkotlin/n;",
            ">;",
            "Lkotlin/jvm/a/l<",
            "-TT;",
            "Lkotlin/n;",
            ">;)",
            "Lio/reactivex/disposables/b;"
        }
    .end annotation

    const-string v0, "$this$subscribeBy"

    invoke-static {p0, v0}, Lkotlin/jvm/internal/i;->d(Ljava/lang/Object;Ljava/lang/String;)V

    const-string v0, "onError"

    invoke-static {p1, v0}, Lkotlin/jvm/internal/i;->d(Ljava/lang/Object;Ljava/lang/String;)V

    const-string v0, "onComplete"

    invoke-static {p2, v0}, Lkotlin/jvm/internal/i;->d(Ljava/lang/Object;Ljava/lang/String;)V

    const-string v0, "onNext"

    invoke-static {p3, v0}, Lkotlin/jvm/internal/i;->d(Ljava/lang/Object;Ljava/lang/String;)V

    .line 6
    invoke-static {p3}, Lio/reactivex/rxkotlin/c;->a(Lkotlin/jvm/a/l;)Lio/reactivex/b/g;

    move-result-object p3

    invoke-static {p1}, Lio/reactivex/rxkotlin/c;->b(Lkotlin/jvm/a/l;)Lio/reactivex/b/g;

    move-result-object p1

    invoke-static {p2}, Lio/reactivex/rxkotlin/c;->a(Lkotlin/jvm/a/a;)Lio/reactivex/b/a;

    move-result-object p2

    invoke-virtual {p0, p3, p1, p2}, Lio/reactivex/e;->a(Lio/reactivex/b/g;Lio/reactivex/b/g;Lio/reactivex/b/a;)Lio/reactivex/disposables/b;

    move-result-object p0

    const-string p1, "subscribe(onNext.asConsu\u2026ete.asOnCompleteAction())"

    invoke-static {p0, p1}, Lkotlin/jvm/internal/i;->a(Ljava/lang/Object;Ljava/lang/String;)V

    return-object p0
.end method

.method public static synthetic a(Lio/reactivex/e;Lkotlin/jvm/a/l;Lkotlin/jvm/a/a;Lkotlin/jvm/a/l;ILjava/lang/Object;)Lio/reactivex/disposables/b;
    .registers 6

    and-int/lit8 p5, p4, 0x1

    if-eqz p5, :cond_6

    .line 3
    sget-object p1, Lio/reactivex/rxkotlin/c;->b:Lkotlin/jvm/a/l;

    :cond_6
    and-int/lit8 p5, p4, 0x2

    if-eqz p5, :cond_c

    .line 4
    sget-object p2, Lio/reactivex/rxkotlin/c;->c:Lkotlin/jvm/a/a;

    :cond_c
    and-int/lit8 p4, p4, 0x4

    if-eqz p4, :cond_12

    .line 5
    sget-object p3, Lio/reactivex/rxkotlin/c;->a:Lkotlin/jvm/a/l;

    :cond_12
    invoke-static {p0, p1, p2, p3}, Lio/reactivex/rxkotlin/c;->a(Lio/reactivex/e;Lkotlin/jvm/a/l;Lkotlin/jvm/a/a;Lkotlin/jvm/a/l;)Lio/reactivex/disposables/b;

    move-result-object p0

    return-object p0
.end method

.method private static final b(Lkotlin/jvm/a/l;)Lio/reactivex/b/g;
    .registers 2
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Lkotlin/jvm/a/l<",
            "-",
            "Ljava/lang/Throwable;",
            "Lkotlin/n;",
            ">;)",
            "Lio/reactivex/b/g<",
            "Ljava/lang/Throwable;",
            ">;"
        }
    .end annotation

    .line 1
    sget-object v0, Lio/reactivex/rxkotlin/c;->b:Lkotlin/jvm/a/l;

    if-ne p0, v0, :cond_c

    sget-object p0, Lio/reactivex/internal/functions/Functions;->f:Lio/reactivex/b/g;

    const-string v0, "Functions.ON_ERROR_MISSING"

    invoke-static {p0, v0}, Lkotlin/jvm/internal/i;->a(Ljava/lang/Object;Ljava/lang/String;)V

    goto :goto_16

    :cond_c
    if-eqz p0, :cond_14

    new-instance v0, Lio/reactivex/rxkotlin/b;

    invoke-direct {v0, p0}, Lio/reactivex/rxkotlin/b;-><init>(Lkotlin/jvm/a/l;)V

    move-object p0, v0

    :cond_14
    check-cast p0, Lio/reactivex/b/g;

    :goto_16
    return-object p0
.end method