ha.smali

.class final Lio/reactivex/internal/operators/observable/ha;
.super Ljava/lang/Object;
.source "ObservableWindowTimed.java"

# interfaces
.implements Ljava/lang/Runnable;


# instance fields
.field private bRK:Lio/reactivex/internal/operators/observable/gz;
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "Lio/reactivex/internal/operators/observable/gz",
            "<*>;"
        }
    .end annotation
.end field

.field final index:J


# direct methods
.method constructor <init>(JLio/reactivex/internal/operators/observable/gz;)V
    .registers 5
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(J",
            "Lio/reactivex/internal/operators/observable/gz",
            "<*>;)V"
        }
    .end annotation

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

    .line 499
    iput-wide p1, p0, Lio/reactivex/internal/operators/observable/ha;->index:J

    .line 500
    iput-object p3, p0, Lio/reactivex/internal/operators/observable/ha;->bRK:Lio/reactivex/internal/operators/observable/gz;

    .line 501
    return-void
.end method


# virtual methods
.method public final run()V
    .registers 3

    .prologue
    .line 505
    iget-object v0, p0, Lio/reactivex/internal/operators/observable/ha;->bRK:Lio/reactivex/internal/operators/observable/gz;

    .line 507
    invoke-static {v0}, Lio/reactivex/internal/operators/observable/gz;->a(Lio/reactivex/internal/operators/observable/gz;)Z

    move-result v1

    if-nez v1, :cond_19

    .line 508
    invoke-static {v0}, Lio/reactivex/internal/operators/observable/gz;->b(Lio/reactivex/internal/operators/observable/gz;)Lio/reactivex/internal/a/f;

    move-result-object v1

    invoke-interface {v1, p0}, Lio/reactivex/internal/a/f;->offer(Ljava/lang/Object;)Z

    .line 513
    :goto_f
    invoke-virtual {v0}, Lio/reactivex/internal/operators/observable/gz;->PR()Z

    move-result v1

    if-eqz v1, :cond_18

    .line 514
    invoke-virtual {v0}, Lio/reactivex/internal/operators/observable/gz;->drainLoop()V

    .line 516
    :cond_18
    return-void

    .line 510
    :cond_19
    const/4 v1, 0x1

    iput-boolean v1, v0, Lio/reactivex/internal/operators/observable/gz;->terminated:Z

    .line 511
    invoke-virtual {v0}, Lio/reactivex/internal/operators/observable/gz;->PX()V

    goto :goto_f
.end method