k.smali

.class public final Lio/reactivex/internal/util/k;
.super Ljava/lang/Object;
.source "QueueDrainHelper.java"


# direct methods
.method public static a(Lio/reactivex/internal/a/f;Lio/reactivex/r;Lio/reactivex/disposables/b;Lio/reactivex/internal/util/h;)V
    .registers 13
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "<T:",
            "Ljava/lang/Object;",
            "U:",
            "Ljava/lang/Object;",
            ">(",
            "Lio/reactivex/internal/a/f",
            "<TT;>;",
            "Lio/reactivex/r",
            "<-TU;>;",
            "Lio/reactivex/disposables/b;",
            "Lio/reactivex/internal/util/h",
            "<TT;TU;>;)V"
        }
    .end annotation

    .prologue
    const/4 v7, 0x1

    .line 130
    move v6, v7

    .line 133
    :goto_2
    invoke-interface {p3}, Lio/reactivex/internal/util/h;->PQ()Z

    move-result v0

    invoke-interface {p0}, Lio/reactivex/internal/a/f;->isEmpty()Z

    move-result v1

    move-object v2, p1

    move-object v3, p0

    move-object v4, p2

    move-object v5, p3

    invoke-static/range {v0 .. v5}, Lio/reactivex/internal/util/k;->a(ZZLio/reactivex/r;Lio/reactivex/internal/a/g;Lio/reactivex/disposables/b;Lio/reactivex/internal/util/h;)Z

    move-result v0

    if-eqz v0, :cond_1a

    .line 158
    :cond_14
    :goto_14
    return-void

    .line 146
    :cond_15
    if-nez v1, :cond_32

    .line 150
    invoke-interface {p3, p1, v8}, Lio/reactivex/internal/util/h;->a(Lio/reactivex/r;Ljava/lang/Object;)V

    .line 138
    :cond_1a
    invoke-interface {p3}, Lio/reactivex/internal/util/h;->PQ()Z

    move-result v0

    .line 139
    invoke-interface {p0}, Lio/reactivex/internal/a/f;->poll()Ljava/lang/Object;

    move-result-object v8

    .line 140
    if-nez v8, :cond_30

    move v1, v7

    :goto_25
    move-object v2, p1

    move-object v3, p0

    move-object v4, p2

    move-object v5, p3

    .line 142
    invoke-static/range {v0 .. v5}, Lio/reactivex/internal/util/k;->a(ZZLio/reactivex/r;Lio/reactivex/internal/a/g;Lio/reactivex/disposables/b;Lio/reactivex/internal/util/h;)Z

    move-result v0

    if-eqz v0, :cond_15

    goto :goto_14

    .line 140
    :cond_30
    const/4 v1, 0x0

    goto :goto_25

    .line 153
    :cond_32
    neg-int v0, v6

    invoke-interface {p3, v0}, Lio/reactivex/internal/util/h;->ff(I)I

    move-result v0

    .line 154
    if-eqz v0, :cond_14

    move v6, v0

    goto :goto_2
.end method

.method private static a(ZZLio/reactivex/r;Lio/reactivex/internal/a/g;Lio/reactivex/disposables/b;Lio/reactivex/internal/util/h;)Z
    .registers 8
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "<T:",
            "Ljava/lang/Object;",
            "U:",
            "Ljava/lang/Object;",
            ">(ZZ",
            "Lio/reactivex/r",
            "<*>;",
            "Lio/reactivex/internal/a/g",
            "<*>;",
            "Lio/reactivex/disposables/b;",
            "Lio/reactivex/internal/util/h",
            "<TT;TU;>;)Z"
        }
    .end annotation

    .prologue
    const/4 v0, 0x1

    .line 162
    invoke-interface {p5}, Lio/reactivex/internal/util/h;->PP()Z

    move-result v1

    if-eqz v1, :cond_e

    .line 163
    invoke-interface {p3}, Lio/reactivex/internal/a/g;->clear()V

    .line 164
    invoke-interface {p4}, Lio/reactivex/disposables/b;->dispose()V

    .line 202
    :goto_d
    return v0

    .line 168
    :cond_e
    if-eqz p0, :cond_2d

    .line 183
    invoke-interface {p5}, Lio/reactivex/internal/util/h;->error()Ljava/lang/Throwable;

    move-result-object v1

    .line 184
    if-eqz v1, :cond_22

    .line 185
    invoke-interface {p3}, Lio/reactivex/internal/a/g;->clear()V

    .line 186
    if-eqz p4, :cond_1e

    .line 187
    invoke-interface {p4}, Lio/reactivex/disposables/b;->dispose()V

    .line 189
    :cond_1e
    invoke-interface {p2, v1}, Lio/reactivex/r;->onError(Ljava/lang/Throwable;)V

    goto :goto_d

    .line 192
    :cond_22
    if-eqz p1, :cond_2d

    .line 193
    if-eqz p4, :cond_29

    .line 194
    invoke-interface {p4}, Lio/reactivex/disposables/b;->dispose()V

    .line 196
    :cond_29
    invoke-interface {p2}, Lio/reactivex/r;->onComplete()V

    goto :goto_d

    .line 202
    :cond_2d
    const/4 v0, 0x0

    goto :goto_d
.end method