e.smali

.class public abstract Lio/reactivex/e;
.super Ljava/lang/Object;
.source "Flowable.java"

# interfaces
.implements Lf/b/b;


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


# static fields
.field static final a:I


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

    const-string v0, "rx2.buffer-size"

    const/16 v1, 0x80

    .line 1
    invoke-static {v0, v1}, Ljava/lang/Integer;->getInteger(Ljava/lang/String;I)Ljava/lang/Integer;

    move-result-object v0

    invoke-virtual {v0}, Ljava/lang/Integer;->intValue()I

    move-result v0

    const/4 v1, 0x1

    invoke-static {v1, v0}, Ljava/lang/Math;->max(II)I

    move-result v0

    sput v0, Lio/reactivex/e;->a:I

    return-void
.end method

.method public constructor <init>()V
    .registers 1

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

    return-void
.end method

.method public static a()I
    .registers 1

    .line 1
    sget v0, Lio/reactivex/e;->a:I

    return v0
.end method

.method private a(Lio/reactivex/b/g;Lio/reactivex/b/g;Lio/reactivex/b/a;Lio/reactivex/b/a;)Lio/reactivex/e;
    .registers 12
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Lio/reactivex/b/g<",
            "-TT;>;",
            "Lio/reactivex/b/g<",
            "-",
            "Ljava/lang/Throwable;",
            ">;",
            "Lio/reactivex/b/a;",
            "Lio/reactivex/b/a;",
            ")",
            "Lio/reactivex/e<",
            "TT;>;"
        }
    .end annotation

    const-string v0, "onNext is null"

    .line 30
    invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;

    const-string v0, "onError is null"

    .line 31
    invoke-static {p2, v0}, Lio/reactivex/internal/functions/a;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;

    const-string v0, "onComplete is null"

    .line 32
    invoke-static {p3, v0}, Lio/reactivex/internal/functions/a;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;

    const-string v0, "onAfterTerminate is null"

    .line 33
    invoke-static {p4, v0}, Lio/reactivex/internal/functions/a;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;

    .line 34
    new-instance v0, Lio/reactivex/internal/operators/flowable/d;

    move-object v1, v0

    move-object v2, p0

    move-object v3, p1

    move-object v4, p2

    move-object v5, p3

    move-object v6, p4

    invoke-direct/range {v1 .. v6}, Lio/reactivex/internal/operators/flowable/d;-><init>(Lio/reactivex/e;Lio/reactivex/b/g;Lio/reactivex/b/g;Lio/reactivex/b/a;Lio/reactivex/b/a;)V

    invoke-static {v0}, Lio/reactivex/e/a;->a(Lio/reactivex/e;)Lio/reactivex/e;

    move-result-object p1

    return-object p1
.end method

.method public static a(Lio/reactivex/g;Lio/reactivex/BackpressureStrategy;)Lio/reactivex/e;
    .registers 3
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "<T:",
            "Ljava/lang/Object;",
            ">(",
            "Lio/reactivex/g<",
            "TT;>;",
            "Lio/reactivex/BackpressureStrategy;",
            ")",
            "Lio/reactivex/e<",
            "TT;>;"
        }
    .end annotation

    const-string v0, "source is null"

    .line 4
    invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;

    const-string v0, "mode is null"

    .line 5
    invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;

    .line 6
    new-instance v0, Lio/reactivex/internal/operators/flowable/FlowableCreate;

    invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/flowable/FlowableCreate;-><init>(Lio/reactivex/g;Lio/reactivex/BackpressureStrategy;)V

    invoke-static {v0}, Lio/reactivex/e/a;->a(Lio/reactivex/e;)Lio/reactivex/e;

    move-result-object p0

    return-object p0
.end method

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

    const-string v0, "sources is null"

    .line 2
    invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;

    .line 3
    invoke-static {p0}, Lio/reactivex/e;->b(Ljava/lang/Iterable;)Lio/reactivex/e;

    move-result-object p0

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

    move-result-object v0

    invoke-virtual {p0, v0}, Lio/reactivex/e;->a(Lio/reactivex/b/o;)Lio/reactivex/e;

    move-result-object p0

    return-object p0
.end method

.method public static a(Ljava/lang/Iterable;I)Lio/reactivex/e;
    .registers 4
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "<T:",
            "Ljava/lang/Object;",
            ">(",
            "Ljava/lang/Iterable<",
            "+",
            "Lf/b/b<",
            "+TT;>;>;I)",
            "Lio/reactivex/e<",
            "TT;>;"
        }
    .end annotation

    .line 19
    invoke-static {p0}, Lio/reactivex/e;->b(Ljava/lang/Iterable;)Lio/reactivex/e;

    move-result-object p0

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

    move-result-object v0

    const/4 v1, 0x1

    invoke-virtual {p0, v0, v1, p1}, Lio/reactivex/e;->a(Lio/reactivex/b/o;ZI)Lio/reactivex/e;

    move-result-object p0

    return-object p0
.end method

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

    const-string v0, "item is null"

    .line 17
    invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;

    .line 18
    new-instance v0, Lio/reactivex/internal/operators/flowable/i;

    invoke-direct {v0, p0}, Lio/reactivex/internal/operators/flowable/i;-><init>(Ljava/lang/Object;)V

    invoke-static {v0}, Lio/reactivex/e/a;->a(Lio/reactivex/e;)Lio/reactivex/e;

    move-result-object p0

    return-object p0
.end method

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

    const-string v0, "throwable is null"

    .line 9
    invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;

    .line 10
    invoke-static {p0}, Lio/reactivex/internal/functions/Functions;->b(Ljava/lang/Object;)Ljava/util/concurrent/Callable;

    move-result-object p0

    invoke-static {p0}, Lio/reactivex/e;->a(Ljava/util/concurrent/Callable;)Lio/reactivex/e;

    move-result-object p0

    return-object p0
.end method

.method public static a(Ljava/util/concurrent/Callable;)Lio/reactivex/e;
    .registers 2
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "<T:",
            "Ljava/lang/Object;",
            ">(",
            "Ljava/util/concurrent/Callable<",
            "+",
            "Ljava/lang/Throwable;",
            ">;)",
            "Lio/reactivex/e<",
            "TT;>;"
        }
    .end annotation

    const-string v0, "supplier is null"

    .line 7
    invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;

    .line 8
    new-instance v0, Lio/reactivex/internal/operators/flowable/g;

    invoke-direct {v0, p0}, Lio/reactivex/internal/operators/flowable/g;-><init>(Ljava/util/concurrent/Callable;)V

    invoke-static {v0}, Lio/reactivex/e/a;->a(Lio/reactivex/e;)Lio/reactivex/e;

    move-result-object p0

    return-object p0
.end method

.method public static a(Ljava/util/concurrent/Callable;Lio/reactivex/b/b;Lio/reactivex/b/g;)Lio/reactivex/e;
    .registers 4
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "<T:",
            "Ljava/lang/Object;",
            "S:",
            "Ljava/lang/Object;",
            ">(",
            "Ljava/util/concurrent/Callable<",
            "TS;>;",
            "Lio/reactivex/b/b<",
            "TS;",
            "Lio/reactivex/d<",
            "TT;>;>;",
            "Lio/reactivex/b/g<",
            "-TS;>;)",
            "Lio/reactivex/e<",
            "TT;>;"
        }
    .end annotation

    const-string v0, "generator is null"

    .line 11
    invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;

    .line 12
    invoke-static {p1}, Lio/reactivex/internal/operators/flowable/FlowableInternalHelper;->a(Lio/reactivex/b/b;)Lio/reactivex/b/c;

    move-result-object p1

    invoke-static {p0, p1, p2}, Lio/reactivex/e;->a(Ljava/util/concurrent/Callable;Lio/reactivex/b/c;Lio/reactivex/b/g;)Lio/reactivex/e;

    move-result-object p0

    return-object p0
.end method

.method public static a(Ljava/util/concurrent/Callable;Lio/reactivex/b/c;Lio/reactivex/b/g;)Lio/reactivex/e;
    .registers 4
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "<T:",
            "Ljava/lang/Object;",
            "S:",
            "Ljava/lang/Object;",
            ">(",
            "Ljava/util/concurrent/Callable<",
            "TS;>;",
            "Lio/reactivex/b/c<",
            "TS;",
            "Lio/reactivex/d<",
            "TT;>;TS;>;",
            "Lio/reactivex/b/g<",
            "-TS;>;)",
            "Lio/reactivex/e<",
            "TT;>;"
        }
    .end annotation

    const-string v0, "initialState is null"

    .line 13
    invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;

    const-string v0, "generator is null"

    .line 14
    invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;

    const-string v0, "disposeState is null"

    .line 15
    invoke-static {p2, v0}, Lio/reactivex/internal/functions/a;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;

    .line 16
    new-instance v0, Lio/reactivex/internal/operators/flowable/FlowableGenerate;

    invoke-direct {v0, p0, p1, p2}, Lio/reactivex/internal/operators/flowable/FlowableGenerate;-><init>(Ljava/util/concurrent/Callable;Lio/reactivex/b/c;Lio/reactivex/b/g;)V

    invoke-static {v0}, Lio/reactivex/e/a;->a(Lio/reactivex/e;)Lio/reactivex/e;

    move-result-object p0

    return-object p0
.end method

.method public static b()Lio/reactivex/e;
    .registers 1
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "<T:",
            "Ljava/lang/Object;",
            ">()",
            "Lio/reactivex/e<",
            "TT;>;"
        }
    .end annotation

    .line 1
    sget-object v0, Lio/reactivex/internal/operators/flowable/f;->b:Lio/reactivex/e;

    invoke-static {v0}, Lio/reactivex/e/a;->a(Lio/reactivex/e;)Lio/reactivex/e;

    move-result-object v0

    return-object v0
.end method

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

    const-string v0, "source is null"

    .line 2
    invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;

    .line 3
    new-instance v0, Lio/reactivex/internal/operators/flowable/FlowableFromIterable;

    invoke-direct {v0, p0}, Lio/reactivex/internal/operators/flowable/FlowableFromIterable;-><init>(Ljava/lang/Iterable;)V

    invoke-static {v0}, Lio/reactivex/e/a;->a(Lio/reactivex/e;)Lio/reactivex/e;

    move-result-object p0

    return-object p0
.end method

.method public static c(Ljava/lang/Iterable;)Lio/reactivex/e;
    .registers 3
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "<T:",
            "Ljava/lang/Object;",
            ">(",
            "Ljava/lang/Iterable<",
            "+",
            "Lf/b/b<",
            "+TT;>;>;)",
            "Lio/reactivex/e<",
            "TT;>;"
        }
    .end annotation

    .line 1
    invoke-static {p0}, Lio/reactivex/e;->b(Ljava/lang/Iterable;)Lio/reactivex/e;

    move-result-object p0

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

    move-result-object v0

    const/4 v1, 0x1

    invoke-virtual {p0, v0, v1}, Lio/reactivex/e;->a(Lio/reactivex/b/o;Z)Lio/reactivex/e;

    move-result-object p0

    return-object p0
.end method


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

    const-string v0, "bufferSize"

    .line 56
    invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->a(ILjava/lang/String;)I

    .line 57
    invoke-static {p0, p1}, Lio/reactivex/internal/operators/flowable/FlowablePublish;->a(Lio/reactivex/e;I)Lio/reactivex/a/a;

    move-result-object p1

    return-object p1
.end method

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

    .line 66
    sget-object v0, Lio/reactivex/internal/operators/flowable/FlowableInternalHelper$RequestMax;->INSTANCE:Lio/reactivex/internal/operators/flowable/FlowableInternalHelper$RequestMax;

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

    move-result-object p1

    return-object p1
.end method

.method public final a(Lio/reactivex/b/g;Lio/reactivex/b/g;Lio/reactivex/b/a;Lio/reactivex/b/g;)Lio/reactivex/disposables/b;
    .registers 6
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Lio/reactivex/b/g<",
            "-TT;>;",
            "Lio/reactivex/b/g<",
            "-",
            "Ljava/lang/Throwable;",
            ">;",
            "Lio/reactivex/b/a;",
            "Lio/reactivex/b/g<",
            "-",
            "Lf/b/d;",
            ">;)",
            "Lio/reactivex/disposables/b;"
        }
    .end annotation

    const-string v0, "onNext is null"

    .line 67
    invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;

    const-string v0, "onError is null"

    .line 68
    invoke-static {p2, v0}, Lio/reactivex/internal/functions/a;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;

    const-string v0, "onComplete is null"

    .line 69
    invoke-static {p3, v0}, Lio/reactivex/internal/functions/a;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;

    const-string v0, "onSubscribe is null"

    .line 70
    invoke-static {p4, v0}, Lio/reactivex/internal/functions/a;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;

    .line 71
    new-instance v0, Lio/reactivex/internal/subscribers/LambdaSubscriber;

    invoke-direct {v0, p1, p2, p3, p4}, Lio/reactivex/internal/subscribers/LambdaSubscriber;-><init>(Lio/reactivex/b/g;Lio/reactivex/b/g;Lio/reactivex/b/a;Lio/reactivex/b/g;)V

    .line 72
    invoke-virtual {p0, v0}, Lio/reactivex/e;->a(Lio/reactivex/h;)V

    return-object v0
.end method

.method public final a(IZZ)Lio/reactivex/e;
    .registers 11
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(IZZ)",
            "Lio/reactivex/e<",
            "TT;>;"
        }
    .end annotation

    const-string v0, "capacity"

    .line 54
    invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->a(ILjava/lang/String;)I

    .line 55
    new-instance v0, Lio/reactivex/internal/operators/flowable/FlowableOnBackpressureBuffer;

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

    move-object v1, v0

    move-object v2, p0

    move v3, p1

    move v4, p3

    move v5, p2

    invoke-direct/range {v1 .. v6}, Lio/reactivex/internal/operators/flowable/FlowableOnBackpressureBuffer;-><init>(Lio/reactivex/e;IZZLio/reactivex/b/a;)V

    invoke-static {v0}, Lio/reactivex/e/a;->a(Lio/reactivex/e;)Lio/reactivex/e;

    move-result-object p1

    return-object p1
.end method

.method public final a(JLjava/util/concurrent/TimeUnit;)Lio/reactivex/e;
    .registers 5
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(J",
            "Ljava/util/concurrent/TimeUnit;",
            ")",
            "Lio/reactivex/e<",
            "TT;>;"
        }
    .end annotation

    .line 58
    invoke-static {}, Lio/reactivex/f/b;->a()Lio/reactivex/x;

    move-result-object v0

    invoke-virtual {p0, p1, p2, p3, v0}, Lio/reactivex/e;->a(JLjava/util/concurrent/TimeUnit;Lio/reactivex/x;)Lio/reactivex/e;

    move-result-object p1

    return-object p1
.end method

.method public final a(JLjava/util/concurrent/TimeUnit;Lio/reactivex/x;)Lio/reactivex/e;
    .registers 13
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(J",
            "Ljava/util/concurrent/TimeUnit;",
            "Lio/reactivex/x;",
            ")",
            "Lio/reactivex/e<",
            "TT;>;"
        }
    .end annotation

    const-string v0, "unit is null"

    .line 60
    invoke-static {p3, v0}, Lio/reactivex/internal/functions/a;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;

    const-string v0, "scheduler is null"

    .line 61
    invoke-static {p4, v0}, Lio/reactivex/internal/functions/a;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;

    .line 62
    new-instance v0, Lio/reactivex/internal/operators/flowable/FlowableSampleTimed;

    const/4 v7, 0x0

    move-object v1, v0

    move-object v2, p0

    move-wide v3, p1

    move-object v5, p3

    move-object v6, p4

    invoke-direct/range {v1 .. v7}, Lio/reactivex/internal/operators/flowable/FlowableSampleTimed;-><init>(Lio/reactivex/e;JLjava/util/concurrent/TimeUnit;Lio/reactivex/x;Z)V

    invoke-static {v0}, Lio/reactivex/e/a;->a(Lio/reactivex/e;)Lio/reactivex/e;

    move-result-object p1

    return-object p1
.end method

.method public final a(JLjava/util/concurrent/TimeUnit;Lio/reactivex/x;Z)Lio/reactivex/e;
    .registers 14
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(J",
            "Ljava/util/concurrent/TimeUnit;",
            "Lio/reactivex/x;",
            "Z)",
            "Lio/reactivex/e<",
            "TT;>;"
        }
    .end annotation

    const-string v0, "unit is null"

    .line 63
    invoke-static {p3, v0}, Lio/reactivex/internal/functions/a;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;

    const-string v0, "scheduler is null"

    .line 64
    invoke-static {p4, v0}, Lio/reactivex/internal/functions/a;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;

    .line 65
    new-instance v0, Lio/reactivex/internal/operators/flowable/FlowableSampleTimed;

    move-object v1, v0

    move-object v2, p0

    move-wide v3, p1

    move-object v5, p3

    move-object v6, p4

    move v7, p5

    invoke-direct/range {v1 .. v7}, Lio/reactivex/internal/operators/flowable/FlowableSampleTimed;-><init>(Lio/reactivex/e;JLjava/util/concurrent/TimeUnit;Lio/reactivex/x;Z)V

    invoke-static {v0}, Lio/reactivex/e/a;->a(Lio/reactivex/e;)Lio/reactivex/e;

    move-result-object p1

    return-object p1
.end method

.method public final a(JLjava/util/concurrent/TimeUnit;Z)Lio/reactivex/e;
    .registers 11
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(J",
            "Ljava/util/concurrent/TimeUnit;",
            "Z)",
            "Lio/reactivex/e<",
            "TT;>;"
        }
    .end annotation

    .line 59
    invoke-static {}, Lio/reactivex/f/b;->a()Lio/reactivex/x;

    move-result-object v4

    move-object v0, p0

    move-wide v1, p1

    move-object v3, p3

    move v5, p4

    invoke-virtual/range {v0 .. v5}, Lio/reactivex/e;->a(JLjava/util/concurrent/TimeUnit;Lio/reactivex/x;Z)Lio/reactivex/e;

    move-result-object p1

    return-object p1
.end method

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

    const-string v0, "onFinally is null"

    .line 28
    invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;

    .line 29
    new-instance v0, Lio/reactivex/internal/operators/flowable/FlowableDoFinally;

    invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/flowable/FlowableDoFinally;-><init>(Lio/reactivex/e;Lio/reactivex/b/a;)V

    invoke-static {v0}, Lio/reactivex/e/a;->a(Lio/reactivex/e;)Lio/reactivex/e;

    move-result-object p1

    return-object p1
.end method

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

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

    move-result-object v0

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

    invoke-direct {p0, v0, p1, v1, v1}, Lio/reactivex/e;->a(Lio/reactivex/b/g;Lio/reactivex/b/g;Lio/reactivex/b/a;Lio/reactivex/b/a;)Lio/reactivex/e;

    move-result-object p1

    return-object p1
.end method

.method public final a(Lio/reactivex/b/g;Lio/reactivex/b/p;Lio/reactivex/b/a;)Lio/reactivex/e;
    .registers 5
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Lio/reactivex/b/g<",
            "-",
            "Lf/b/d;",
            ">;",
            "Lio/reactivex/b/p;",
            "Lio/reactivex/b/a;",
            ")",
            "Lio/reactivex/e<",
            "TT;>;"
        }
    .end annotation

    const-string v0, "onSubscribe is null"

    .line 36
    invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;

    const-string v0, "onRequest is null"

    .line 37
    invoke-static {p2, v0}, Lio/reactivex/internal/functions/a;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;

    const-string v0, "onCancel is null"

    .line 38
    invoke-static {p3, v0}, Lio/reactivex/internal/functions/a;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;

    .line 39
    new-instance v0, Lio/reactivex/internal/operators/flowable/e;

    invoke-direct {v0, p0, p1, p2, p3}, Lio/reactivex/internal/operators/flowable/e;-><init>(Lio/reactivex/e;Lio/reactivex/b/g;Lio/reactivex/b/p;Lio/reactivex/b/a;)V

    invoke-static {v0}, Lio/reactivex/e/a;->a(Lio/reactivex/e;)Lio/reactivex/e;

    move-result-object p1

    return-object p1
.end method

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

    const/4 v0, 0x2

    const/4 v1, 0x1

    .line 20
    invoke-virtual {p0, p1, v0, v1}, Lio/reactivex/e;->a(Lio/reactivex/b/o;IZ)Lio/reactivex/e;

    move-result-object p1

    return-object p1
.end method

.method public final a(Lio/reactivex/b/o;IZ)Lio/reactivex/e;
    .registers 5
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "<R:",
            "Ljava/lang/Object;",
            ">(",
            "Lio/reactivex/b/o<",
            "-TT;+",
            "Lf/b/b<",
            "+TR;>;>;IZ)",
            "Lio/reactivex/e<",
            "TR;>;"
        }
    .end annotation

    const-string v0, "mapper is null"

    .line 21
    invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;

    const-string v0, "prefetch"

    .line 22
    invoke-static {p2, v0}, Lio/reactivex/internal/functions/a;->a(ILjava/lang/String;)I

    .line 23
    instance-of v0, p0, Lio/reactivex/c/a/i;

    if-eqz v0, :cond_21

    .line 24
    move-object p2, p0

    check-cast p2, Lio/reactivex/c/a/i;

    invoke-interface {p2}, Lio/reactivex/c/a/i;->call()Ljava/lang/Object;

    move-result-object p2

    if-nez p2, :cond_1c

    .line 25
    invoke-static {}, Lio/reactivex/e;->b()Lio/reactivex/e;

    move-result-object p1

    return-object p1

    .line 26
    :cond_1c
    invoke-static {p2, p1}, Lio/reactivex/internal/operators/flowable/m;->a(Ljava/lang/Object;Lio/reactivex/b/o;)Lio/reactivex/e;

    move-result-object p1

    return-object p1

    .line 27
    :cond_21
    new-instance v0, Lio/reactivex/internal/operators/flowable/FlowableConcatMap;

    if-eqz p3, :cond_28

    sget-object p3, Lio/reactivex/internal/util/ErrorMode;->END:Lio/reactivex/internal/util/ErrorMode;

    goto :goto_2a

    :cond_28
    sget-object p3, Lio/reactivex/internal/util/ErrorMode;->BOUNDARY:Lio/reactivex/internal/util/ErrorMode;

    :goto_2a
    invoke-direct {v0, p0, p1, p2, p3}, Lio/reactivex/internal/operators/flowable/FlowableConcatMap;-><init>(Lio/reactivex/e;Lio/reactivex/b/o;ILio/reactivex/internal/util/ErrorMode;)V

    invoke-static {v0}, Lio/reactivex/e/a;->a(Lio/reactivex/e;)Lio/reactivex/e;

    move-result-object p1

    return-object p1
.end method

.method public final a(Lio/reactivex/b/o;Z)Lio/reactivex/e;
    .registers 5
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "<R:",
            "Ljava/lang/Object;",
            ">(",
            "Lio/reactivex/b/o<",
            "-TT;+",
            "Lf/b/b<",
            "+TR;>;>;Z)",
            "Lio/reactivex/e<",
            "TR;>;"
        }
    .end annotation

    .line 40
    invoke-static {}, Lio/reactivex/e;->a()I

    move-result v0

    invoke-static {}, Lio/reactivex/e;->a()I

    move-result v1

    invoke-virtual {p0, p1, p2, v0, v1}, Lio/reactivex/e;->a(Lio/reactivex/b/o;ZII)Lio/reactivex/e;

    move-result-object p1

    return-object p1
.end method

.method public final a(Lio/reactivex/b/o;ZI)Lio/reactivex/e;
    .registers 5
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "<R:",
            "Ljava/lang/Object;",
            ">(",
            "Lio/reactivex/b/o<",
            "-TT;+",
            "Lf/b/b<",
            "+TR;>;>;ZI)",
            "Lio/reactivex/e<",
            "TR;>;"
        }
    .end annotation

    .line 41
    invoke-static {}, Lio/reactivex/e;->a()I

    move-result v0

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

    move-result-object p1

    return-object p1
.end method

.method public final a(Lio/reactivex/b/o;ZII)Lio/reactivex/e;
    .registers 12
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "<R:",
            "Ljava/lang/Object;",
            ">(",
            "Lio/reactivex/b/o<",
            "-TT;+",
            "Lf/b/b<",
            "+TR;>;>;ZII)",
            "Lio/reactivex/e<",
            "TR;>;"
        }
    .end annotation

    const-string v0, "mapper is null"

    .line 42
    invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;

    const-string v0, "maxConcurrency"

    .line 43
    invoke-static {p3, v0}, Lio/reactivex/internal/functions/a;->a(ILjava/lang/String;)I

    const-string v0, "bufferSize"

    .line 44
    invoke-static {p4, v0}, Lio/reactivex/internal/functions/a;->a(ILjava/lang/String;)I

    .line 45
    instance-of v0, p0, Lio/reactivex/c/a/i;

    if-eqz v0, :cond_26

    .line 46
    move-object p2, p0

    check-cast p2, Lio/reactivex/c/a/i;

    invoke-interface {p2}, Lio/reactivex/c/a/i;->call()Ljava/lang/Object;

    move-result-object p2

    if-nez p2, :cond_21

    .line 47
    invoke-static {}, Lio/reactivex/e;->b()Lio/reactivex/e;

    move-result-object p1

    return-object p1

    .line 48
    :cond_21
    invoke-static {p2, p1}, Lio/reactivex/internal/operators/flowable/m;->a(Ljava/lang/Object;Lio/reactivex/b/o;)Lio/reactivex/e;

    move-result-object p1

    return-object p1

    .line 49
    :cond_26
    new-instance v6, Lio/reactivex/internal/operators/flowable/FlowableFlatMap;

    move-object v0, v6

    move-object v1, p0

    move-object v2, p1

    move v3, p2

    move v4, p3

    move v5, p4

    invoke-direct/range {v0 .. v5}, Lio/reactivex/internal/operators/flowable/FlowableFlatMap;-><init>(Lio/reactivex/e;Lio/reactivex/b/o;ZII)V

    invoke-static {v6}, Lio/reactivex/e/a;->a(Lio/reactivex/e;)Lio/reactivex/e;

    move-result-object p1

    return-object p1
.end method

.method public final a(Lio/reactivex/x;)Lio/reactivex/e;
    .registers 4
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Lio/reactivex/x;",
            ")",
            "Lio/reactivex/e<",
            "TT;>;"
        }
    .end annotation

    .line 50
    invoke-static {}, Lio/reactivex/e;->a()I

    move-result v0

    const/4 v1, 0x0

    invoke-virtual {p0, p1, v1, v0}, Lio/reactivex/e;->a(Lio/reactivex/x;ZI)Lio/reactivex/e;

    move-result-object p1

    return-object p1
.end method

.method public final a(Lio/reactivex/x;Z)Lio/reactivex/e;
    .registers 4
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Lio/reactivex/x;",
            "Z)",
            "Lio/reactivex/e<",
            "TT;>;"
        }
    .end annotation

    const-string v0, "scheduler is null"

    .line 87
    invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;

    .line 88
    new-instance v0, Lio/reactivex/internal/operators/flowable/FlowableSubscribeOn;

    invoke-direct {v0, p0, p1, p2}, Lio/reactivex/internal/operators/flowable/FlowableSubscribeOn;-><init>(Lio/reactivex/e;Lio/reactivex/x;Z)V

    invoke-static {v0}, Lio/reactivex/e/a;->a(Lio/reactivex/e;)Lio/reactivex/e;

    move-result-object p1

    return-object p1
.end method

.method public final a(Lio/reactivex/x;ZI)Lio/reactivex/e;
    .registers 5
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Lio/reactivex/x;",
            "ZI)",
            "Lio/reactivex/e<",
            "TT;>;"
        }
    .end annotation

    const-string v0, "scheduler is null"

    .line 51
    invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;

    const-string v0, "bufferSize"

    .line 52
    invoke-static {p3, v0}, Lio/reactivex/internal/functions/a;->a(ILjava/lang/String;)I

    .line 53
    new-instance v0, Lio/reactivex/internal/operators/flowable/FlowableObserveOn;

    invoke-direct {v0, p0, p1, p2, p3}, Lio/reactivex/internal/operators/flowable/FlowableObserveOn;-><init>(Lio/reactivex/e;Lio/reactivex/x;ZI)V

    invoke-static {v0}, Lio/reactivex/e/a;->a(Lio/reactivex/e;)Lio/reactivex/e;

    move-result-object p1

    return-object p1
.end method

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

    .line 73
    instance-of v0, p1, Lio/reactivex/h;

    if-eqz v0, :cond_a

    .line 74
    check-cast p1, Lio/reactivex/h;

    invoke-virtual {p0, p1}, Lio/reactivex/e;->a(Lio/reactivex/h;)V

    goto :goto_17

    :cond_a
    const-string v0, "s is null"

    .line 75
    invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;

    .line 76
    new-instance v0, Lio/reactivex/internal/subscribers/StrictSubscriber;

    invoke-direct {v0, p1}, Lio/reactivex/internal/subscribers/StrictSubscriber;-><init>(Lf/b/c;)V

    invoke-virtual {p0, v0}, Lio/reactivex/e;->a(Lio/reactivex/h;)V

    :goto_17
    return-void
.end method

.method public final a(Lio/reactivex/h;)V
    .registers 4
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Lio/reactivex/h<",
            "-TT;>;)V"
        }
    .end annotation

    const-string v0, "s is null"

    .line 77
    invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;

    .line 78
    :try_start_5
    invoke-static {p0, p1}, Lio/reactivex/e/a;->a(Lio/reactivex/e;Lf/b/c;)Lf/b/c;

    move-result-object p1

    const-string v0, "The RxJavaPlugins.onSubscribe hook returned a null FlowableSubscriber. Please check the handler provided to RxJavaPlugins.setOnFlowableSubscribe for invalid null returns. Further reading: https://github.com/ReactiveX/RxJava/wiki/Plugins"

    .line 79
    invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;

    .line 80
    invoke-virtual {p0, p1}, Lio/reactivex/e;->b(Lf/b/c;)V
    :try_end_11
    .catch Ljava/lang/NullPointerException; {:try_start_5 .. :try_end_11} :catch_24
    .catch Ljava/lang/Throwable; {:try_start_5 .. :try_end_11} :catch_12

    return-void

    :catch_12
    move-exception p1

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

    .line 82
    invoke-static {p1}, Lio/reactivex/e/a;->b(Ljava/lang/Throwable;)V

    .line 83
    new-instance v0, Ljava/lang/NullPointerException;

    const-string v1, "Actually not, but can\'t throw other exceptions due to RS"

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

    .line 84
    invoke-virtual {v0, p1}, Ljava/lang/NullPointerException;->initCause(Ljava/lang/Throwable;)Ljava/lang/Throwable;

    .line 85
    throw v0

    :catch_24
    move-exception p1

    .line 86
    throw p1
.end method

.method public final b(Lio/reactivex/b/a;)Lio/reactivex/e;
    .registers 4
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Lio/reactivex/b/a;",
            ")",
            "Lio/reactivex/e<",
            "TT;>;"
        }
    .end annotation

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

    move-result-object v0

    sget-object v1, Lio/reactivex/internal/functions/Functions;->g:Lio/reactivex/b/p;

    invoke-virtual {p0, v0, v1, p1}, Lio/reactivex/e;->a(Lio/reactivex/b/g;Lio/reactivex/b/p;Lio/reactivex/b/a;)Lio/reactivex/e;

    move-result-object p1

    return-object p1
.end method

.method public final b(Lio/reactivex/b/g;)Lio/reactivex/e;
    .registers 4
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Lio/reactivex/b/g<",
            "-TT;>;)",
            "Lio/reactivex/e<",
            "TT;>;"
        }
    .end annotation

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

    move-result-object v0

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

    invoke-direct {p0, p1, v0, v1, v1}, Lio/reactivex/e;->a(Lio/reactivex/b/g;Lio/reactivex/b/g;Lio/reactivex/b/a;Lio/reactivex/b/a;)Lio/reactivex/e;

    move-result-object p1

    return-object p1
.end method

.method public final b(Lio/reactivex/b/o;)Lio/reactivex/e;
    .registers 5
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "<R:",
            "Ljava/lang/Object;",
            ">(",
            "Lio/reactivex/b/o<",
            "-TT;+",
            "Lf/b/b<",
            "+TR;>;>;)",
            "Lio/reactivex/e<",
            "TR;>;"
        }
    .end annotation

    .line 6
    invoke-static {}, Lio/reactivex/e;->a()I

    move-result v0

    invoke-static {}, Lio/reactivex/e;->a()I

    move-result v1

    const/4 v2, 0x0

    invoke-virtual {p0, p1, v2, v0, v1}, Lio/reactivex/e;->a(Lio/reactivex/b/o;ZII)Lio/reactivex/e;

    move-result-object p1

    return-object p1
.end method

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

    const-string v0, "scheduler is null"

    .line 7
    invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;

    .line 8
    instance-of v0, p0, Lio/reactivex/internal/operators/flowable/FlowableCreate;

    if-nez v0, :cond_b

    const/4 v0, 0x1

    goto :goto_c

    :cond_b
    const/4 v0, 0x0

    :goto_c
    invoke-virtual {p0, p1, v0}, Lio/reactivex/e;->a(Lio/reactivex/x;Z)Lio/reactivex/e;

    move-result-object p1

    return-object p1
.end method

.method protected abstract b(Lf/b/c;)V
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Lf/b/c<",
            "-TT;>;)V"
        }
    .end annotation
.end method

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

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

    move-result-object v0

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

    move-result-object v1

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

    invoke-direct {p0, v0, v1, p1, v2}, Lio/reactivex/e;->a(Lio/reactivex/b/g;Lio/reactivex/b/g;Lio/reactivex/b/a;Lio/reactivex/b/a;)Lio/reactivex/e;

    move-result-object p1

    return-object p1
.end method

.method public final c(Lio/reactivex/b/g;)Lio/reactivex/e;
    .registers 4
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Lio/reactivex/b/g<",
            "-",
            "Lf/b/d;",
            ">;)",
            "Lio/reactivex/e<",
            "TT;>;"
        }
    .end annotation

    .line 3
    sget-object v0, Lio/reactivex/internal/functions/Functions;->g:Lio/reactivex/b/p;

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

    invoke-virtual {p0, p1, v0, v1}, Lio/reactivex/e;->a(Lio/reactivex/b/g;Lio/reactivex/b/p;Lio/reactivex/b/a;)Lio/reactivex/e;

    move-result-object p1

    return-object p1
.end method

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

    const-string v0, "mapper is null"

    .line 5
    invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;

    .line 6
    new-instance v0, Lio/reactivex/internal/operators/flowable/k;

    invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/flowable/k;-><init>(Lio/reactivex/e;Lio/reactivex/b/o;)V

    invoke-static {v0}, Lio/reactivex/e/a;->a(Lio/reactivex/e;)Lio/reactivex/e;

    move-result-object p1

    return-object p1
.end method

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

    .line 4
    new-instance v0, Lio/reactivex/internal/operators/flowable/j;

    invoke-direct {v0, p0}, Lio/reactivex/internal/operators/flowable/j;-><init>(Lf/b/b;)V

    invoke-static {v0}, Lio/reactivex/e/a;->a(Lio/reactivex/i;)Lio/reactivex/i;

    move-result-object v0

    return-object v0
.end method

.method public final d(Lio/reactivex/b/g;)Lio/reactivex/disposables/b;
    .registers 5
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Lio/reactivex/b/g<",
            "-TT;>;)",
            "Lio/reactivex/disposables/b;"
        }
    .end annotation

    .line 2
    sget-object v0, Lio/reactivex/internal/functions/Functions;->f:Lio/reactivex/b/g;

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

    sget-object v2, Lio/reactivex/internal/operators/flowable/FlowableInternalHelper$RequestMax;->INSTANCE:Lio/reactivex/internal/operators/flowable/FlowableInternalHelper$RequestMax;

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

    move-result-object p1

    return-object p1
.end method

.method public final d()Lio/reactivex/e;
    .registers 4
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "()",
            "Lio/reactivex/e<",
            "TT;>;"
        }
    .end annotation

    .line 1
    invoke-static {}, Lio/reactivex/e;->a()I

    move-result v0

    const/4 v1, 0x0

    const/4 v2, 0x1

    invoke-virtual {p0, v0, v1, v2}, Lio/reactivex/e;->a(IZZ)Lio/reactivex/e;

    move-result-object v0

    return-object v0
.end method

.method public final e()Lio/reactivex/e;
    .registers 2
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "()",
            "Lio/reactivex/e<",
            "TT;>;"
        }
    .end annotation

    .line 1
    new-instance v0, Lio/reactivex/internal/operators/flowable/FlowableOnBackpressureDrop;

    invoke-direct {v0, p0}, Lio/reactivex/internal/operators/flowable/FlowableOnBackpressureDrop;-><init>(Lio/reactivex/e;)V

    invoke-static {v0}, Lio/reactivex/e/a;->a(Lio/reactivex/e;)Lio/reactivex/e;

    move-result-object v0

    return-object v0
.end method

.method public final f()Lio/reactivex/e;
    .registers 2
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "()",
            "Lio/reactivex/e<",
            "TT;>;"
        }
    .end annotation

    .line 1
    new-instance v0, Lio/reactivex/internal/operators/flowable/FlowableOnBackpressureLatest;

    invoke-direct {v0, p0}, Lio/reactivex/internal/operators/flowable/FlowableOnBackpressureLatest;-><init>(Lio/reactivex/e;)V

    invoke-static {v0}, Lio/reactivex/e/a;->a(Lio/reactivex/e;)Lio/reactivex/e;

    move-result-object v0

    return-object v0
.end method

.method public final g()Lio/reactivex/a/a;
    .registers 2
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "()",
            "Lio/reactivex/a/a<",
            "TT;>;"
        }
    .end annotation

    .line 1
    invoke-static {}, Lio/reactivex/e;->a()I

    move-result v0

    invoke-virtual {p0, v0}, Lio/reactivex/e;->a(I)Lio/reactivex/a/a;

    move-result-object v0

    return-object v0
.end method