c.smali

.class public abstract Lnp/c;
.super Ljava/lang/Object;
.source "Flowable.java"

# interfaces
.implements Lmq/a;


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


# static fields
.field public static final a:I


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

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

    const/16 v1, 0x80

    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, Lnp/c;->a:I

    return-void
.end method

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

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

    return-void
.end method

.method public static a()I
    .registers 1

    sget v0, Lnp/c;->a:I

    return v0
.end method

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

    const-string v0, "source is null"

    invoke-static {p0, v0}, Lup/a;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;

    const-string v0, "mode is null"

    invoke-static {p1, v0}, Lup/a;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;

    new-instance v0, Lwp/b;

    invoke-direct {v0, p0, p1}, Lwp/b;-><init>(Lnp/e;Lio/reactivex/BackpressureStrategy;)V

    invoke-static {v0}, Lfq/a;->a(Lnp/c;)Lnp/c;

    move-result-object p0

    return-object p0
.end method


# virtual methods
.method public final a(Lnp/l;)Lnp/c;
    .registers 4
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Lnp/l;",
            ")",
            "Lnp/c<",
            "TT;>;"
        }
    .end annotation

    invoke-static {}, Lnp/c;->a()I

    move-result v0

    const/4 v1, 0x0

    invoke-virtual {p0, p1, v1, v0}, Lnp/c;->a(Lnp/l;ZI)Lnp/c;

    move-result-object p1

    return-object p1
.end method

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

    const-string v0, "scheduler is null"

    invoke-static {p1, v0}, Lup/a;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;

    const-string v0, "bufferSize"

    invoke-static {p3, v0}, Lup/a;->a(ILjava/lang/String;)I

    new-instance v0, Lwp/c;

    invoke-direct {v0, p0, p1, p2, p3}, Lwp/c;-><init>(Lnp/c;Lnp/l;ZI)V

    invoke-static {v0}, Lfq/a;->a(Lnp/c;)Lnp/c;

    move-result-object p1

    return-object p1
.end method

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

    sget-object v0, Lio/reactivex/internal/functions/Functions;->a:Lsp/a;

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

    invoke-virtual {p0, p1, p2, v0, v1}, Lnp/c;->a(Lsp/c;Lsp/c;Lsp/a;Lsp/c;)Lqp/b;

    move-result-object p1

    return-object p1
.end method

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

    const-string v0, "onNext is null"

    invoke-static {p1, v0}, Lup/a;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;

    const-string v0, "onError is null"

    invoke-static {p2, v0}, Lup/a;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;

    const-string v0, "onComplete is null"

    invoke-static {p3, v0}, Lup/a;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;

    const-string v0, "onSubscribe is null"

    invoke-static {p4, v0}, Lup/a;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;

    new-instance v0, Lbq/a;

    invoke-direct {v0, p1, p2, p3, p4}, Lbq/a;-><init>(Lsp/c;Lsp/c;Lsp/a;Lsp/c;)V

    invoke-virtual {p0, v0}, Lnp/c;->a(Lnp/f;)V

    return-object v0
.end method

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

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

    const-string v0, "s is null"

    invoke-static {p1, v0}, Lup/a;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;

    :try_start_5
    invoke-static {p0, p1}, Lfq/a;->a(Lnp/c;Lmq/b;)Lmq/b;

    move-result-object p1

    const-string v0, "Plugin returned null Subscriber"

    invoke-static {p1, v0}, Lup/a;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;

    invoke-virtual {p0, p1}, Lnp/c;->a(Lmq/b;)V
    :try_end_11
    .catch Ljava/lang/NullPointerException; {:try_start_5 .. :try_end_11} :catch_24
    .catchall {:try_start_5 .. :try_end_11} :catchall_12

    return-void

    :catchall_12
    move-exception p1

    invoke-static {p1}, Lrp/b;->b(Ljava/lang/Throwable;)V

    invoke-static {p1}, Lfq/a;->b(Ljava/lang/Throwable;)V

    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

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

    throw v0

    :catch_24
    move-exception p1

    throw p1
.end method