c.smali

.class public Lrx/c;
.super Ljava/lang/Object;
.source "SourceFile"


# annotations
.annotation system Ldalvik/annotation/MemberClasses;
    value = {
        Lrx/c$c;,
        Lrx/c$b;,
        Lrx/c$a;
    }
.end annotation

.annotation system Ldalvik/annotation/Signature;
    value = {
        "<T:",
        "Ljava/lang/Object;",
        ">",
        "Ljava/lang/Object;"
    }
.end annotation


# instance fields
.field final a:Lrx/c$a;
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "Lrx/c$a<",
            "TT;>;"
        }
    .end annotation
.end field


# direct methods
.method public constructor <init>(Lrx/c$a;)V
    .registers 2
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Lrx/c$a<",
            "TT;>;)V"
        }
    .end annotation

    .line 58
    invoke-direct {p0}, Ljava/lang/Object;-><init>()V

    .line 59
    iput-object p1, p0, Lrx/c;->a:Lrx/c$a;

    return-void
.end method

.method public static a(JJLjava/util/concurrent/TimeUnit;Lrx/f;)Lrx/c;
    .registers 14
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(JJ",
            "Ljava/util/concurrent/TimeUnit;",
            "Lrx/f;",
            ")",
            "Lrx/c<",
            "Ljava/lang/Long;",
            ">;"
        }
    .end annotation

    .line 2151
    new-instance v7, Lrx/c/a/v;

    move-object v0, v7

    move-wide v1, p0

    move-wide v3, p2

    move-object v5, p4

    move-object v6, p5

    invoke-direct/range {v0 .. v6}, Lrx/c/a/v;-><init>(JJLjava/util/concurrent/TimeUnit;Lrx/f;)V

    invoke-static {v7}, Lrx/c;->a(Lrx/c$a;)Lrx/c;

    move-result-object p0

    return-object p0
.end method

.method public static a(JLjava/util/concurrent/TimeUnit;)Lrx/c;
    .registers 9
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(J",
            "Ljava/util/concurrent/TimeUnit;",
            ")",
            "Lrx/c<",
            "Ljava/lang/Long;",
            ">;"
        }
    .end annotation

    .line 2120
    invoke-static {}, Lrx/g/a;->b()Lrx/f;

    move-result-object v5

    const-wide/16 v2, 0x1

    move-wide v0, p0

    move-object v4, p2

    invoke-static/range {v0 .. v5}, Lrx/c;->a(JJLjava/util/concurrent/TimeUnit;Lrx/f;)Lrx/c;

    move-result-object p0

    return-object p0
.end method

.method public static a(Ljava/lang/Iterable;)Lrx/c;
    .registers 2
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "<T:",
            "Ljava/lang/Object;",
            ">(",
            "Ljava/lang/Iterable<",
            "+TT;>;)",
            "Lrx/c<",
            "TT;>;"
        }
    .end annotation

    .line 1940
    new-instance v0, Lrx/c/a/m;

    invoke-direct {v0, p0}, Lrx/c/a/m;-><init>(Ljava/lang/Iterable;)V

    invoke-static {v0}, Lrx/c;->a(Lrx/c$a;)Lrx/c;

    move-result-object p0

    return-object p0
.end method

.method public static a(Ljava/util/concurrent/TimeUnit;)Lrx/c;
    .registers 7
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Ljava/util/concurrent/TimeUnit;",
            ")",
            "Lrx/c<",
            "Ljava/lang/Long;",
            ">;"
        }
    .end annotation

    .line 2064
    invoke-static {}, Lrx/g/a;->b()Lrx/f;

    move-result-object v5

    const-wide/16 v2, 0x2

    move-wide v0, v2

    move-object v4, p0

    invoke-static/range {v0 .. v5}, Lrx/c;->a(JJLjava/util/concurrent/TimeUnit;Lrx/f;)Lrx/c;

    move-result-object p0

    return-object p0
.end method

.method public static a(Lrx/c$a;)Lrx/c;
    .registers 2
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "<T:",
            "Ljava/lang/Object;",
            ">(",
            "Lrx/c$a<",
            "TT;>;)",
            "Lrx/c<",
            "TT;>;"
        }
    .end annotation

    .line 98
    new-instance v0, Lrx/c;

    invoke-static {p0}, Lrx/f/c;->a(Lrx/c$a;)Lrx/c$a;

    move-result-object p0

    invoke-direct {v0, p0}, Lrx/c;-><init>(Lrx/c$a;)V

    return-object v0
.end method

.method public static a(Lrx/c;)Lrx/c;
    .registers 2
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "<T:",
            "Ljava/lang/Object;",
            ">(",
            "Lrx/c<",
            "+",
            "Lrx/c<",
            "+TT;>;>;)",
            "Lrx/c<",
            "TT;>;"
        }
    .end annotation

    .line 12054
    new-instance v0, Lrx/c/e/o$1;

    invoke-direct {v0}, Lrx/c/e/o$1;-><init>()V

    .line 1154
    invoke-virtual {p0, v0}, Lrx/c;->a(Lrx/b/f;)Lrx/c;

    move-result-object p0

    return-object p0
.end method

.method public static a(Lrx/c;Lrx/c;)Lrx/c;
    .registers 4
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "<T:",
            "Ljava/lang/Object;",
            ">(",
            "Lrx/c<",
            "+TT;>;",
            "Lrx/c<",
            "+TT;>;)",
            "Lrx/c<",
            "TT;>;"
        }
    .end annotation

    const/4 v0, 0x2

    new-array v0, v0, [Lrx/c;

    const/4 v1, 0x0

    aput-object p0, v0, v1

    const/4 p0, 0x1

    aput-object p1, v0, p0

    .line 14918
    invoke-static {v0}, Lrx/c;->a([Ljava/lang/Object;)Lrx/c;

    move-result-object p0

    invoke-static {p0}, Lrx/c;->e(Lrx/c;)Lrx/c;

    move-result-object p0

    return-object p0
.end method

.method public static a(Lrx/c;Lrx/c;Lrx/b/g;)Lrx/c;
    .registers 5
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "<T1:",
            "Ljava/lang/Object;",
            "T2:",
            "Ljava/lang/Object;",
            "R:",
            "Ljava/lang/Object;",
            ">(",
            "Lrx/c<",
            "+TT1;>;",
            "Lrx/c<",
            "+TT2;>;",
            "Lrx/b/g<",
            "-TT1;-TT2;+TR;>;)",
            "Lrx/c<",
            "TR;>;"
        }
    .end annotation

    const/4 v0, 0x2

    new-array v0, v0, [Lrx/c;

    const/4 v1, 0x0

    aput-object p0, v0, v1

    const/4 p0, 0x1

    aput-object p1, v0, p0

    .line 16181
    invoke-static {v0}, Lrx/c/e/k;->a(Ljava/lang/Object;)Lrx/c/e/k;

    move-result-object p0

    .line 4013
    new-instance p1, Lrx/c/a/as;

    invoke-direct {p1, p2}, Lrx/c/a/as;-><init>(Lrx/b/g;)V

    invoke-virtual {p0, p1}, Lrx/c;->a(Lrx/c$b;)Lrx/c;

    move-result-object p0

    return-object p0
.end method

.method public static a(Lrx/c;Lrx/c;Lrx/c;Lrx/b/h;)Lrx/c;
    .registers 6
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "<T1:",
            "Ljava/lang/Object;",
            "T2:",
            "Ljava/lang/Object;",
            "T3:",
            "Ljava/lang/Object;",
            "R:",
            "Ljava/lang/Object;",
            ">(",
            "Lrx/c<",
            "+TT1;>;",
            "Lrx/c<",
            "+TT2;>;",
            "Lrx/c<",
            "+TT3;>;",
            "Lrx/b/h<",
            "-TT1;-TT2;-TT3;+TR;>;)",
            "Lrx/c<",
            "TR;>;"
        }
    .end annotation

    const/4 v0, 0x3

    new-array v0, v0, [Lrx/c;

    const/4 v1, 0x0

    aput-object p0, v0, v1

    const/4 p0, 0x1

    aput-object p1, v0, p0

    const/4 p0, 0x2

    aput-object p2, v0, p0

    .line 17181
    invoke-static {v0}, Lrx/c/e/k;->a(Ljava/lang/Object;)Lrx/c/e/k;

    move-result-object p0

    .line 4069
    new-instance p1, Lrx/c/a/as;

    invoke-direct {p1, p3}, Lrx/c/a/as;-><init>(Lrx/b/h;)V

    invoke-virtual {p0, p1}, Lrx/c;->a(Lrx/c$b;)Lrx/c;

    move-result-object p0

    return-object p0
.end method

.method public static a([Ljava/lang/Object;)Lrx/c;
    .registers 3
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "<T:",
            "Ljava/lang/Object;",
            ">([TT;)",
            "Lrx/c<",
            "TT;>;"
        }
    .end annotation

    .line 1963
    array-length v0, p0

    if-nez v0, :cond_8

    .line 12795
    invoke-static {}, Lrx/c/a/d;->instance()Lrx/c;

    move-result-object p0

    return-object p0

    :cond_8
    const/4 v1, 0x1

    if-ne v0, v1, :cond_13

    const/4 v0, 0x0

    .line 1968
    aget-object p0, p0, v0

    .line 13181
    invoke-static {p0}, Lrx/c/e/k;->a(Ljava/lang/Object;)Lrx/c/e/k;

    move-result-object p0

    return-object p0

    .line 1970
    :cond_13
    new-instance v0, Lrx/c/a/l;

    invoke-direct {v0, p0}, Lrx/c/a/l;-><init>([Ljava/lang/Object;)V

    invoke-static {v0}, Lrx/c;->a(Lrx/c$a;)Lrx/c;

    move-result-object p0

    return-object p0
.end method

.method public static a(Lrx/i;Lrx/c;)Lrx/j;
    .registers 5
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "<T:",
            "Ljava/lang/Object;",
            ">(",
            "Lrx/i<",
            "-TT;>;",
            "Lrx/c<",
            "TT;>;)",
            "Lrx/j;"
        }
    .end annotation

    if-eqz p0, :cond_6b

    .line 10221
    iget-object v0, p1, Lrx/c;->a:Lrx/c$a;

    if-eqz v0, :cond_63

    .line 10230
    invoke-virtual {p0}, Lrx/i;->b()V

    .line 10237
    instance-of v0, p0, Lrx/e/b;

    if-nez v0, :cond_13

    .line 10239
    new-instance v0, Lrx/e/b;

    invoke-direct {v0, p0}, Lrx/e/b;-><init>(Lrx/i;)V

    move-object p0, v0

    .line 10246
    :cond_13
    :try_start_13
    iget-object v0, p1, Lrx/c;->a:Lrx/c$a;

    invoke-static {p1, v0}, Lrx/f/c;->a(Lrx/c;Lrx/c$a;)Lrx/c$a;

    move-result-object p1

    invoke-interface {p1, p0}, Lrx/c$a;->call(Ljava/lang/Object;)V

    .line 10247
    invoke-static {p0}, Lrx/f/c;->a(Lrx/j;)Lrx/j;

    move-result-object p0
    :try_end_20
    .catchall {:try_start_13 .. :try_end_20} :catchall_21

    return-object p0

    :catchall_21
    move-exception p1

    .line 10250
    invoke-static {p1}, Lrx/exceptions/a;->b(Ljava/lang/Throwable;)V

    .line 10252
    invoke-virtual {p0}, Lrx/i;->isUnsubscribed()Z

    move-result v0

    if-eqz v0, :cond_33

    .line 10253
    invoke-static {p1}, Lrx/f/c;->b(Ljava/lang/Throwable;)Ljava/lang/Throwable;

    move-result-object p0

    invoke-static {p0}, Lrx/f/c;->a(Ljava/lang/Throwable;)V

    goto :goto_3a

    .line 10257
    :cond_33
    :try_start_33
    invoke-static {p1}, Lrx/f/c;->b(Ljava/lang/Throwable;)Ljava/lang/Throwable;

    move-result-object v0

    invoke-virtual {p0, v0}, Lrx/i;->a(Ljava/lang/Throwable;)V
    :try_end_3a
    .catchall {:try_start_33 .. :try_end_3a} :catchall_3f

    .line 10269
    :goto_3a
    invoke-static {}, Lrx/i/d;->b()Lrx/j;

    move-result-object p0

    return-object p0

    :catchall_3f
    move-exception p0

    .line 10259
    invoke-static {p0}, Lrx/exceptions/a;->b(Ljava/lang/Throwable;)V

    .line 10262
    new-instance v0, Lrx/exceptions/OnErrorFailedException;

    new-instance v1, Ljava/lang/StringBuilder;

    const-string v2, "Error occurred attempting to subscribe ["

    invoke-direct {v1, v2}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V

    invoke-virtual {p1}, Ljava/lang/Throwable;->getMessage()Ljava/lang/String;

    move-result-object p1

    invoke-virtual {v1, p1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;

    const-string p1, "] and then again while trying to pass to onError."

    invoke-virtual {v1, p1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;

    invoke-virtual {v1}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;

    move-result-object p1

    invoke-direct {v0, p1, p0}, Lrx/exceptions/OnErrorFailedException;-><init>(Ljava/lang/String;Ljava/lang/Throwable;)V

    .line 10264
    invoke-static {v0}, Lrx/f/c;->b(Ljava/lang/Throwable;)Ljava/lang/Throwable;

    .line 10266
    throw v0

    .line 10222
    :cond_63
    new-instance p0, Ljava/lang/IllegalStateException;

    const-string p1, "onSubscribe function can not be null."

    invoke-direct {p0, p1}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V

    throw p0

    .line 10219
    :cond_6b
    new-instance p0, Ljava/lang/IllegalArgumentException;

    const-string p1, "subscriber can not be null"

    invoke-direct {p0, p1}, Ljava/lang/IllegalArgumentException;-><init>(Ljava/lang/String;)V

    throw p0
.end method

.method public static b(JLjava/util/concurrent/TimeUnit;)Lrx/c;
    .registers 5
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(J",
            "Ljava/util/concurrent/TimeUnit;",
            ")",
            "Lrx/c<",
            "Ljava/lang/Long;",
            ">;"
        }
    .end annotation

    .line 3717
    invoke-static {}, Lrx/g/a;->b()Lrx/f;

    move-result-object v0

    .line 15744
    new-instance v1, Lrx/c/a/u;

    invoke-direct {v1, p0, p1, p2, v0}, Lrx/c/a/u;-><init>(JLjava/util/concurrent/TimeUnit;Lrx/f;)V

    invoke-static {v1}, Lrx/c;->a(Lrx/c$a;)Lrx/c;

    move-result-object p0

    return-object p0
.end method

.method private static e(Lrx/c;)Lrx/c;
    .registers 3
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "<T:",
            "Ljava/lang/Object;",
            ">(",
            "Lrx/c<",
            "+",
            "Lrx/c<",
            "+TT;>;>;)",
            "Lrx/c<",
            "TT;>;"
        }
    .end annotation

    .line 2573
    invoke-virtual {p0}, Ljava/lang/Object;->getClass()Ljava/lang/Class;

    move-result-object v0

    const-class v1, Lrx/c/e/k;

    if-ne v0, v1, :cond_14

    .line 2574
    check-cast p0, Lrx/c/e/k;

    .line 14054
    new-instance v0, Lrx/c/e/o$1;

    invoke-direct {v0}, Lrx/c/e/o$1;-><init>()V

    .line 2574
    invoke-virtual {p0, v0}, Lrx/c/e/k;->f(Lrx/b/f;)Lrx/c;

    move-result-object p0

    return-object p0

    .line 2576
    :cond_14
    invoke-static {}, Lrx/c/a/ac;->a()Lrx/c/a/ac;

    move-result-object v0

    invoke-virtual {p0, v0}, Lrx/c;->a(Lrx/c$b;)Lrx/c;

    move-result-object p0

    return-object p0
.end method


# virtual methods
.method public final a(I)Lrx/c;
    .registers 3
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(I)",
            "Lrx/c<",
            "Ljava/util/List<",
            "TT;>;>;"
        }
    .end annotation

    .line 17615
    new-instance v0, Lrx/c/a/y;

    invoke-direct {v0, p1, p1}, Lrx/c/a/y;-><init>(II)V

    invoke-virtual {p0, v0}, Lrx/c;->a(Lrx/c$b;)Lrx/c;

    move-result-object p1

    return-object p1
.end method

.method public final a(Lrx/b/b;)Lrx/c;
    .registers 5
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Lrx/b/b<",
            "Ljava/lang/Throwable;",
            ">;)",
            "Lrx/c<",
            "TT;>;"
        }
    .end annotation

    .line 5875
    invoke-static {}, Lrx/b/d;->a()Lrx/b/d$a;

    move-result-object v0

    .line 5876
    invoke-static {}, Lrx/b/d;->a()Lrx/b/d$a;

    move-result-object v1

    .line 5877
    new-instance v2, Lrx/c/e/a;

    invoke-direct {v2, v0, p1, v1}, Lrx/c/e/a;-><init>(Lrx/b/b;Lrx/b/b;Lrx/b/a;)V

    .line 5879
    new-instance p1, Lrx/c/a/i;

    invoke-direct {p1, p0, v2}, Lrx/c/a/i;-><init>(Lrx/c;Lrx/d;)V

    invoke-static {p1}, Lrx/c;->a(Lrx/c$a;)Lrx/c;

    move-result-object p1

    return-object p1
.end method

.method public final a(Lrx/b/e;Lrx/b/c;)Lrx/c;
    .registers 4
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "<R:",
            "Ljava/lang/Object;",
            ">(",
            "Lrx/b/e<",
            "TR;>;",
            "Lrx/b/c<",
            "TR;-TT;>;)",
            "Lrx/c<",
            "TR;>;"
        }
    .end annotation

    .line 5081
    new-instance v0, Lrx/c/a/g;

    invoke-direct {v0, p0, p1, p2}, Lrx/c/a/g;-><init>(Lrx/c;Lrx/b/e;Lrx/b/c;)V

    invoke-static {v0}, Lrx/c;->a(Lrx/c$a;)Lrx/c;

    move-result-object p1

    return-object p1
.end method

.method public final a(Lrx/b/f;)Lrx/c;
    .registers 5
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "<R:",
            "Ljava/lang/Object;",
            ">(",
            "Lrx/b/f<",
            "-TT;+",
            "Lrx/c<",
            "+TR;>;>;)",
            "Lrx/c<",
            "TR;>;"
        }
    .end annotation

    .line 5110
    instance-of v0, p0, Lrx/c/e/k;

    if-eqz v0, :cond_c

    .line 5111
    move-object v0, p0

    check-cast v0, Lrx/c/e/k;

    .line 5112
    invoke-virtual {v0, p1}, Lrx/c/e/k;->f(Lrx/b/f;)Lrx/c;

    move-result-object p1

    return-object p1

    .line 5114
    :cond_c
    new-instance v0, Lrx/c/a/h;

    const/4 v1, 0x2

    const/4 v2, 0x0

    invoke-direct {v0, p0, p1, v1, v2}, Lrx/c/a/h;-><init>(Lrx/c;Lrx/b/f;II)V

    invoke-static {v0}, Lrx/c;->a(Lrx/c$a;)Lrx/c;

    move-result-object p1

    return-object p1
.end method

.method public final a(Lrx/b/f;Lrx/b/f;)Lrx/c;
    .registers 4
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "<K:",
            "Ljava/lang/Object;",
            "V:",
            "Ljava/lang/Object;",
            ">(",
            "Lrx/b/f<",
            "-TT;+TK;>;",
            "Lrx/b/f<",
            "-TT;+TV;>;)",
            "Lrx/c<",
            "Ljava/util/Map<",
            "TK;TV;>;>;"
        }
    .end annotation

    .line 11480
    new-instance v0, Lrx/c/a/w;

    invoke-direct {v0, p0, p1, p2}, Lrx/c/a/w;-><init>(Lrx/c;Lrx/b/f;Lrx/b/f;)V

    invoke-static {v0}, Lrx/c;->a(Lrx/c$a;)Lrx/c;

    move-result-object p1

    return-object p1
.end method

.method public final a(Lrx/b/g;)Lrx/c;
    .registers 4
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Lrx/b/g<",
            "-TT;-TT;",
            "Ljava/lang/Integer;",
            ">;)",
            "Lrx/c<",
            "TT;>;"
        }
    .end annotation

    .line 24671
    new-instance v0, Lrx/c/a/ar;

    const/16 v1, 0xa

    invoke-direct {v0, p1, v1}, Lrx/c/a/ar;-><init>(Lrx/b/g;I)V

    invoke-virtual {p0, v0}, Lrx/c;->a(Lrx/c$b;)Lrx/c;

    move-result-object p1

    .line 25054
    new-instance v0, Lrx/c/e/o$1;

    invoke-direct {v0}, Lrx/c/e/o$1;-><init>()V

    .line 25938
    sget v1, Lrx/c/e/i;->b:I

    .line 25972
    invoke-static {p1, v0, v1}, Lrx/c/a/k;->a(Lrx/c;Lrx/b/f;I)Lrx/c;

    move-result-object p1

    return-object p1
.end method

.method public final a(Lrx/c$b;)Lrx/c;
    .registers 4
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "<R:",
            "Ljava/lang/Object;",
            ">(",
            "Lrx/c$b<",
            "+TR;-TT;>;)",
            "Lrx/c<",
            "TR;>;"
        }
    .end annotation

    .line 267
    new-instance v0, Lrx/c/a/n;

    iget-object v1, p0, Lrx/c;->a:Lrx/c$a;

    invoke-direct {v0, v1, p1}, Lrx/c/a/n;-><init>(Lrx/c$a;Lrx/c$b;)V

    invoke-static {v0}, Lrx/c;->a(Lrx/c$a;)Lrx/c;

    move-result-object p1

    return-object p1
.end method

.method public final a(Lrx/c$c;)Lrx/c;
    .registers 2
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "<R:",
            "Ljava/lang/Object;",
            ">(",
            "Lrx/c$c<",
            "-TT;+TR;>;)",
            "Lrx/c<",
            "TR;>;"
        }
    .end annotation

    .line 294
    invoke-interface {p1, p0}, Lrx/c$c;->call(Ljava/lang/Object;)Ljava/lang/Object;

    move-result-object p1

    check-cast p1, Lrx/c;

    return-object p1
.end method

.method public final a(Lrx/f;)Lrx/c;
    .registers 5
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Lrx/f;",
            ")",
            "Lrx/c<",
            "TT;>;"
        }
    .end annotation

    .line 7623
    sget v0, Lrx/c/e/i;->b:I

    .line 19728
    instance-of v1, p0, Lrx/c/e/k;

    if-eqz v1, :cond_e

    .line 19729
    move-object v0, p0

    check-cast v0, Lrx/c/e/k;

    invoke-virtual {v0, p1}, Lrx/c/e/k;->c(Lrx/f;)Lrx/c;

    move-result-object p1

    return-object p1

    .line 19731
    :cond_e
    new-instance v1, Lrx/c/a/ad;

    const/4 v2, 0x0

    invoke-direct {v1, p1, v2, v0}, Lrx/c/a/ad;-><init>(Lrx/f;ZI)V

    invoke-virtual {p0, v1}, Lrx/c;->a(Lrx/c$b;)Lrx/c;

    move-result-object p1

    return-object p1
.end method

.method public final a(Lrx/b/b;Lrx/b/b;)Lrx/j;
    .registers 5
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Lrx/b/b<",
            "-TT;>;",
            "Lrx/b/b<",
            "Ljava/lang/Throwable;",
            ">;)",
            "Lrx/j;"
        }
    .end annotation

    if-eqz p1, :cond_1a

    if-eqz p2, :cond_12

    .line 10052
    invoke-static {}, Lrx/b/d;->a()Lrx/b/d$a;

    move-result-object v0

    .line 10053
    new-instance v1, Lrx/c/e/b;

    invoke-direct {v1, p1, p2, v0}, Lrx/c/e/b;-><init>(Lrx/b/b;Lrx/b/b;Lrx/b/a;)V

    .line 21213
    invoke-static {v1, p0}, Lrx/c;->a(Lrx/i;Lrx/c;)Lrx/j;

    move-result-object p1

    return-object p1

    .line 10049
    :cond_12
    new-instance p1, Ljava/lang/IllegalArgumentException;

    const-string p2, "onError can not be null"

    invoke-direct {p1, p2}, Ljava/lang/IllegalArgumentException;-><init>(Ljava/lang/String;)V

    throw p1

    .line 10046
    :cond_1a
    new-instance p1, Ljava/lang/IllegalArgumentException;

    const-string p2, "onNext can not be null"

    invoke-direct {p1, p2}, Ljava/lang/IllegalArgumentException;-><init>(Ljava/lang/String;)V

    throw p1
.end method

.method public final a(Lrx/b/b;Lrx/b/b;Lrx/b/a;)Lrx/j;
    .registers 5
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Lrx/b/b<",
            "-TT;>;",
            "Lrx/b/b<",
            "Ljava/lang/Throwable;",
            ">;",
            "Lrx/b/a;",
            ")",
            "Lrx/j;"
        }
    .end annotation

    if-eqz p1, :cond_20

    if-eqz p2, :cond_18

    if-eqz p3, :cond_10

    .line 10094
    new-instance v0, Lrx/c/e/b;

    invoke-direct {v0, p1, p2, p3}, Lrx/c/e/b;-><init>(Lrx/b/b;Lrx/b/b;Lrx/b/a;)V

    .line 22213
    invoke-static {v0, p0}, Lrx/c;->a(Lrx/i;Lrx/c;)Lrx/j;

    move-result-object p1

    return-object p1

    .line 10091
    :cond_10
    new-instance p1, Ljava/lang/IllegalArgumentException;

    const-string p2, "onComplete can not be null"

    invoke-direct {p1, p2}, Ljava/lang/IllegalArgumentException;-><init>(Ljava/lang/String;)V

    throw p1

    .line 10088
    :cond_18
    new-instance p1, Ljava/lang/IllegalArgumentException;

    const-string p2, "onError can not be null"

    invoke-direct {p1, p2}, Ljava/lang/IllegalArgumentException;-><init>(Ljava/lang/String;)V

    throw p1

    .line 10085
    :cond_20
    new-instance p1, Ljava/lang/IllegalArgumentException;

    const-string p2, "onNext can not be null"

    invoke-direct {p1, p2}, Ljava/lang/IllegalArgumentException;-><init>(Ljava/lang/String;)V

    throw p1
.end method

.method public final a(Lrx/d;)Lrx/j;
    .registers 3
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Lrx/d<",
            "-TT;>;)",
            "Lrx/j;"
        }
    .end annotation

    .line 10115
    instance-of v0, p1, Lrx/i;

    if-eqz v0, :cond_b

    .line 10116
    check-cast p1, Lrx/i;

    .line 23213
    invoke-static {p1, p0}, Lrx/c;->a(Lrx/i;Lrx/c;)Lrx/j;

    move-result-object p1

    return-object p1

    .line 10121
    :cond_b
    new-instance v0, Lrx/c/e/f;

    invoke-direct {v0, p1}, Lrx/c/e/f;-><init>(Lrx/d;)V

    .line 24213
    invoke-static {v0, p0}, Lrx/c;->a(Lrx/i;Lrx/c;)Lrx/j;

    move-result-object p1

    return-object p1
.end method

.method public final a(Lrx/i;)Lrx/j;
    .registers 6
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Lrx/i<",
            "-TT;>;)",
            "Lrx/j;"
        }
    .end annotation

    .line 10148
    :try_start_0
    invoke-virtual {p1}, Lrx/i;->b()V

    .line 10150
    iget-object v0, p0, Lrx/c;->a:Lrx/c$a;

    invoke-static {p0, v0}, Lrx/f/c;->a(Lrx/c;Lrx/c$a;)Lrx/c$a;

    move-result-object v0

    invoke-interface {v0, p1}, Lrx/c$a;->call(Ljava/lang/Object;)V

    .line 10151
    invoke-static {p1}, Lrx/f/c;->a(Lrx/j;)Lrx/j;

    move-result-object p1
    :try_end_10
    .catchall {:try_start_0 .. :try_end_10} :catchall_11

    return-object p1

    :catchall_11
    move-exception v0

    .line 10154
    invoke-static {v0}, Lrx/exceptions/a;->b(Ljava/lang/Throwable;)V

    .line 10157
    :try_start_15
    invoke-static {v0}, Lrx/f/c;->b(Ljava/lang/Throwable;)Ljava/lang/Throwable;

    move-result-object v1

    invoke-virtual {p1, v1}, Lrx/i;->a(Ljava/lang/Throwable;)V
    :try_end_1c
    .catchall {:try_start_15 .. :try_end_1c} :catchall_21

    .line 10168
    invoke-static {}, Lrx/i/d;->b()Lrx/j;

    move-result-object p1

    return-object p1

    :catchall_21
    move-exception p1

    .line 10159
    invoke-static {p1}, Lrx/exceptions/a;->b(Ljava/lang/Throwable;)V

    .line 10162
    new-instance v1, Lrx/exceptions/OnErrorFailedException;

    new-instance v2, Ljava/lang/StringBuilder;

    const-string v3, "Error occurred attempting to subscribe ["

    invoke-direct {v2, v3}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V

    invoke-virtual {v0}, Ljava/lang/Throwable;->getMessage()Ljava/lang/String;

    move-result-object v0

    invoke-virtual {v2, v0}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;

    const-string v0, "] and then again while trying to pass to onError."

    invoke-virtual {v2, v0}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;

    invoke-virtual {v2}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;

    move-result-object v0

    invoke-direct {v1, v0, p1}, Lrx/exceptions/OnErrorFailedException;-><init>(Ljava/lang/String;Ljava/lang/Throwable;)V

    .line 10164
    invoke-static {v1}, Lrx/f/c;->b(Ljava/lang/Throwable;)Ljava/lang/Throwable;

    .line 10166
    throw v1
.end method

.method public final aL_()Lrx/g;
    .registers 3
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "()",
            "Lrx/g<",
            "TT;>;"
        }
    .end annotation

    .line 336
    new-instance v0, Lrx/g;

    invoke-static {p0}, Lrx/c/a/s;->a(Lrx/c;)Lrx/c/a/s;

    move-result-object v1

    invoke-direct {v0, v1}, Lrx/g;-><init>(Lrx/g$a;)V

    return-object v0
.end method

.method public final b()Lrx/c;
    .registers 3
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "()",
            "Lrx/c<",
            "TT;>;"
        }
    .end annotation

    const/4 v0, 0x1

    .line 6634
    invoke-virtual {p0, v0}, Lrx/c;->b(I)Lrx/c;

    move-result-object v0

    .line 19336
    invoke-static {}, Lrx/c/a/aj;->a()Lrx/c/a/aj;

    move-result-object v1

    invoke-virtual {v0, v1}, Lrx/c;->a(Lrx/c$b;)Lrx/c;

    move-result-object v0

    return-object v0
.end method

.method public final b(I)Lrx/c;
    .registers 3
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(I)",
            "Lrx/c<",
            "TT;>;"
        }
    .end annotation

    .line 10389
    new-instance v0, Lrx/c/a/am;

    invoke-direct {v0, p1}, Lrx/c/a/am;-><init>(I)V

    invoke-virtual {p0, v0}, Lrx/c;->a(Lrx/c$b;)Lrx/c;

    move-result-object p1

    return-object p1
.end method

.method public final b(Ljava/util/concurrent/TimeUnit;)Lrx/c;
    .registers 9
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Ljava/util/concurrent/TimeUnit;",
            ")",
            "Lrx/c<",
            "TT;>;"
        }
    .end annotation

    .line 11242
    invoke-static {}, Lrx/g/a;->b()Lrx/f;

    move-result-object v5

    .line 24303
    new-instance v6, Lrx/c/a/ao;

    const-wide/16 v1, 0x2

    const/4 v4, 0x0

    move-object v0, v6

    move-object v3, p1

    invoke-direct/range {v0 .. v5}, Lrx/c/a/ao;-><init>(JLjava/util/concurrent/TimeUnit;Lrx/c;Lrx/f;)V

    invoke-virtual {p0, v6}, Lrx/c;->a(Lrx/c$b;)Lrx/c;

    move-result-object p1

    return-object p1
.end method

.method public final b(Lrx/b/b;)Lrx/c;
    .registers 5
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Lrx/b/b<",
            "-TT;>;)",
            "Lrx/c<",
            "TT;>;"
        }
    .end annotation

    .line 5900
    invoke-static {}, Lrx/b/d;->a()Lrx/b/d$a;

    move-result-object v0

    .line 5901
    invoke-static {}, Lrx/b/d;->a()Lrx/b/d$a;

    move-result-object v1

    .line 5902
    new-instance v2, Lrx/c/e/a;

    invoke-direct {v2, p1, v0, v1}, Lrx/c/e/a;-><init>(Lrx/b/b;Lrx/b/b;Lrx/b/a;)V

    .line 5904
    new-instance p1, Lrx/c/a/i;

    invoke-direct {p1, p0, v2}, Lrx/c/a/i;-><init>(Lrx/c;Lrx/d;)V

    invoke-static {p1}, Lrx/c;->a(Lrx/c$a;)Lrx/c;

    move-result-object p1

    return-object p1
.end method

.method public final b(Lrx/b/f;)Lrx/c;
    .registers 3
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "<R:",
            "Ljava/lang/Object;",
            ">(",
            "Lrx/b/f<",
            "-TT;+",
            "Ljava/lang/Iterable<",
            "+TR;>;>;)",
            "Lrx/c<",
            "TR;>;"
        }
    .end annotation

    .line 5171
    sget v0, Lrx/c/e/i;->b:I

    invoke-static {p0, p1, v0}, Lrx/c/a/k;->a(Lrx/c;Lrx/b/f;I)Lrx/c;

    move-result-object p1

    return-object p1
.end method

.method public final b(Lrx/c;)Lrx/c;
    .registers 4
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Lrx/c<",
            "+TT;>;)",
            "Lrx/c<",
            "TT;>;"
        }
    .end annotation

    const/4 v0, 0x2

    new-array v0, v0, [Ljava/lang/Object;

    const/4 v1, 0x0

    aput-object p0, v0, v1

    const/4 v1, 0x1

    aput-object p1, v0, v1

    .line 18207
    check-cast v0, [Ljava/lang/Object;

    invoke-static {v0}, Lrx/c;->a([Ljava/lang/Object;)Lrx/c;

    move-result-object p1

    .line 18182
    invoke-static {p1}, Lrx/c;->a(Lrx/c;)Lrx/c;

    move-result-object p1

    return-object p1
.end method

.method public final b(Lrx/f;)Lrx/c;
    .registers 3
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Lrx/f;",
            ")",
            "Lrx/c<",
            "TT;>;"
        }
    .end annotation

    .line 10294
    instance-of v0, p0, Lrx/c/e/k;

    if-eqz v0, :cond_c

    .line 10295
    move-object v0, p0

    check-cast v0, Lrx/c/e/k;

    invoke-virtual {v0, p1}, Lrx/c/e/k;->c(Lrx/f;)Lrx/c;

    move-result-object p1

    return-object p1

    .line 10297
    :cond_c
    new-instance v0, Lrx/c/a/ak;

    invoke-direct {v0, p0, p1}, Lrx/c/a/ak;-><init>(Lrx/c;Lrx/f;)V

    invoke-static {v0}, Lrx/c;->a(Lrx/c$a;)Lrx/c;

    move-result-object p1

    return-object p1
.end method

.method public final c(JLjava/util/concurrent/TimeUnit;)Lrx/c;
    .registers 6
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(J",
            "Ljava/util/concurrent/TimeUnit;",
            ")",
            "Lrx/c<",
            "TT;>;"
        }
    .end annotation

    .line 5325
    invoke-static {}, Lrx/g/a;->b()Lrx/f;

    move-result-object v0

    .line 18367
    new-instance v1, Lrx/c/a/z;

    invoke-direct {v1, p1, p2, p3, v0}, Lrx/c/a/z;-><init>(JLjava/util/concurrent/TimeUnit;Lrx/f;)V

    invoke-virtual {p0, v1}, Lrx/c;->a(Lrx/c$b;)Lrx/c;

    move-result-object p1

    return-object p1
.end method

.method public final c(Lrx/b/f;)Lrx/c;
    .registers 3
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Lrx/b/f<",
            "-TT;",
            "Ljava/lang/Boolean;",
            ">;)",
            "Lrx/c<",
            "TT;>;"
        }
    .end annotation

    .line 6563
    new-instance v0, Lrx/c/a/j;

    invoke-direct {v0, p0, p1}, Lrx/c/a/j;-><init>(Lrx/c;Lrx/b/f;)V

    invoke-static {v0}, Lrx/c;->a(Lrx/c$a;)Lrx/c;

    move-result-object p1

    return-object p1
.end method

.method public final c(Lrx/c;)Lrx/c;
    .registers 3
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Lrx/c<",
            "+TT;>;)",
            "Lrx/c<",
            "TT;>;"
        }
    .end annotation

    .line 5418
    new-instance v0, Lrx/c/a/al;

    invoke-direct {v0, p1}, Lrx/c/a/al;-><init>(Lrx/c;)V

    invoke-virtual {p0, v0}, Lrx/c;->a(Lrx/c$b;)Lrx/c;

    move-result-object p1

    return-object p1
.end method

.method public final c(Lrx/b/b;)Lrx/j;
    .registers 5
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Lrx/b/b<",
            "-TT;>;)",
            "Lrx/j;"
        }
    .end annotation

    if-eqz p1, :cond_12

    .line 10016
    sget-object v0, Lrx/c/e/d;->ERROR_NOT_IMPLEMENTED:Lrx/b/b;

    .line 10017
    invoke-static {}, Lrx/b/d;->a()Lrx/b/d$a;

    move-result-object v1

    .line 10018
    new-instance v2, Lrx/c/e/b;

    invoke-direct {v2, p1, v0, v1}, Lrx/c/e/b;-><init>(Lrx/b/b;Lrx/b/b;Lrx/b/a;)V

    .line 20213
    invoke-static {v2, p0}, Lrx/c;->a(Lrx/i;Lrx/c;)Lrx/j;

    move-result-object p1

    return-object p1

    .line 10013
    :cond_12
    new-instance p1, Ljava/lang/IllegalArgumentException;

    const-string v0, "onNext can not be null"

    invoke-direct {p1, v0}, Ljava/lang/IllegalArgumentException;-><init>(Ljava/lang/String;)V

    throw p1
.end method

.method public final d(Lrx/b/f;)Lrx/c;
    .registers 4
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "<R:",
            "Ljava/lang/Object;",
            ">(",
            "Lrx/b/f<",
            "-TT;+",
            "Lrx/c<",
            "+TR;>;>;)",
            "Lrx/c<",
            "TR;>;"
        }
    .end annotation

    .line 6734
    invoke-virtual {p0}, Ljava/lang/Object;->getClass()Ljava/lang/Class;

    move-result-object v0

    const-class v1, Lrx/c/e/k;

    if-ne v0, v1, :cond_10

    .line 6735
    move-object v0, p0

    check-cast v0, Lrx/c/e/k;

    invoke-virtual {v0, p1}, Lrx/c/e/k;->f(Lrx/b/f;)Lrx/c;

    move-result-object p1

    return-object p1

    .line 6737
    :cond_10
    invoke-virtual {p0, p1}, Lrx/c;->e(Lrx/b/f;)Lrx/c;

    move-result-object p1

    invoke-static {p1}, Lrx/c;->e(Lrx/c;)Lrx/c;

    move-result-object p1

    return-object p1
.end method

.method public final d(Lrx/c;)Lrx/c;
    .registers 2
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Lrx/c<",
            "+TT;>;)",
            "Lrx/c<",
            "TT;>;"
        }
    .end annotation

    .line 8018
    invoke-static {p1}, Lrx/c/a/af;->a(Lrx/c;)Lrx/c/a/af;

    move-result-object p1

    invoke-virtual {p0, p1}, Lrx/c;->a(Lrx/c$b;)Lrx/c;

    move-result-object p1

    return-object p1
.end method

.method public final e(Lrx/b/f;)Lrx/c;
    .registers 3
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "<R:",
            "Ljava/lang/Object;",
            ">(",
            "Lrx/b/f<",
            "-TT;+TR;>;)",
            "Lrx/c<",
            "TR;>;"
        }
    .end annotation

    .line 7540
    new-instance v0, Lrx/c/a/o;

    invoke-direct {v0, p0, p1}, Lrx/c/a/o;-><init>(Lrx/c;Lrx/b/f;)V

    invoke-static {v0}, Lrx/c;->a(Lrx/c$a;)Lrx/c;

    move-result-object p1

    return-object p1
.end method