gz.smali

.class final Lio/reactivex/internal/operators/observable/gz;
.super Lio/reactivex/internal/observers/k;
.source "ObservableWindowTimed.java"

# interfaces
.implements Lio/reactivex/disposables/b;


# annotations
.annotation system Ldalvik/annotation/Signature;
    value = {
        "<T:",
        "Ljava/lang/Object;",
        ">",
        "Lio/reactivex/internal/observers/k",
        "<TT;",
        "Ljava/lang/Object;",
        "Lio/reactivex/k",
        "<TT;>;>;",
        "Lio/reactivex/disposables/b;"
    }
.end annotation


# instance fields
.field private CJ:J

.field private bPt:J

.field private bPv:Z

.field private bPx:J

.field private bufferSize:I

.field private count:J

.field private s:Lio/reactivex/disposables/b;

.field private scheduler:Lio/reactivex/s;

.field volatile terminated:Z

.field private timer:Ljava/util/concurrent/atomic/AtomicReference;
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "Ljava/util/concurrent/atomic/AtomicReference",
            "<",
            "Lio/reactivex/disposables/b;",
            ">;"
        }
    .end annotation
.end field

.field private unit:Ljava/util/concurrent/TimeUnit;

.field private window:Lio/reactivex/subjects/UnicastSubject;
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "Lio/reactivex/subjects/UnicastSubject",
            "<TT;>;"
        }
    .end annotation
.end field

.field private worker:Lio/reactivex/v;


# direct methods
.method constructor <init>(Lio/reactivex/r;JLjava/util/concurrent/TimeUnit;Lio/reactivex/s;IJZ)V
    .registers 11
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Lio/reactivex/r",
            "<-",
            "Lio/reactivex/k",
            "<TT;>;>;J",
            "Ljava/util/concurrent/TimeUnit;",
            "Lio/reactivex/s;",
            "IJZ)V"
        }
    .end annotation

    .prologue
    .line 276
    new-instance v0, Lio/reactivex/internal/queue/MpscLinkedQueue;

    invoke-direct {v0}, Lio/reactivex/internal/queue/MpscLinkedQueue;-><init>()V

    invoke-direct {p0, p1, v0}, Lio/reactivex/internal/observers/k;-><init>(Lio/reactivex/r;Lio/reactivex/internal/a/f;)V

    .line 270
    new-instance v0, Ljava/util/concurrent/atomic/AtomicReference;

    invoke-direct {v0}, Ljava/util/concurrent/atomic/AtomicReference;-><init>()V

    iput-object v0, p0, Lio/reactivex/internal/operators/observable/gz;->timer:Ljava/util/concurrent/atomic/AtomicReference;

    .line 277
    iput-wide p2, p0, Lio/reactivex/internal/operators/observable/gz;->bPt:J

    .line 278
    iput-object p4, p0, Lio/reactivex/internal/operators/observable/gz;->unit:Ljava/util/concurrent/TimeUnit;

    .line 279
    iput-object p5, p0, Lio/reactivex/internal/operators/observable/gz;->scheduler:Lio/reactivex/s;

    .line 280
    iput p6, p0, Lio/reactivex/internal/operators/observable/gz;->bufferSize:I

    .line 281
    iput-wide p7, p0, Lio/reactivex/internal/operators/observable/gz;->CJ:J

    .line 282
    iput-boolean p9, p0, Lio/reactivex/internal/operators/observable/gz;->bPv:Z

    .line 283
    if-eqz p9, :cond_24

    .line 284
    invoke-virtual {p5}, Lio/reactivex/s;->Pv()Lio/reactivex/v;

    move-result-object v0

    iput-object v0, p0, Lio/reactivex/internal/operators/observable/gz;->worker:Lio/reactivex/v;

    .line 288
    :goto_23
    return-void

    .line 286
    :cond_24
    const/4 v0, 0x0

    iput-object v0, p0, Lio/reactivex/internal/operators/observable/gz;->worker:Lio/reactivex/v;

    goto :goto_23
.end method

.method static synthetic a(Lio/reactivex/internal/operators/observable/gz;)Z
    .registers 2

    .prologue
    .line 247
    iget-boolean v0, p0, Lio/reactivex/internal/operators/observable/gz;->cancelled:Z

    return v0
.end method

.method static synthetic b(Lio/reactivex/internal/operators/observable/gz;)Lio/reactivex/internal/a/f;
    .registers 2

    .prologue
    .line 247
    iget-object v0, p0, Lio/reactivex/internal/operators/observable/gz;->queue:Lio/reactivex/internal/a/f;

    return-object v0
.end method


# virtual methods
.method final PX()V
    .registers 2

    .prologue
    .line 399
    iget-object v0, p0, Lio/reactivex/internal/operators/observable/gz;->timer:Ljava/util/concurrent/atomic/AtomicReference;

    invoke-static {v0}, Lio/reactivex/internal/disposables/DisposableHelper;->dispose(Ljava/util/concurrent/atomic/AtomicReference;)Z

    .line 400
    iget-object v0, p0, Lio/reactivex/internal/operators/observable/gz;->worker:Lio/reactivex/v;

    .line 401
    if-eqz v0, :cond_c

    .line 402
    invoke-virtual {v0}, Lio/reactivex/v;->dispose()V

    .line 404
    :cond_c
    return-void
.end method

.method public final dispose()V
    .registers 2

    .prologue
    .line 390
    const/4 v0, 0x1

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

    .line 391
    return-void
.end method

.method final drainLoop()V
    .registers 13

    .prologue
    .line 407
    iget-object v0, p0, Lio/reactivex/internal/operators/observable/gz;->queue:Lio/reactivex/internal/a/f;

    move-object v7, v0

    check-cast v7, Lio/reactivex/internal/queue/MpscLinkedQueue;

    .line 408
    iget-object v11, p0, Lio/reactivex/internal/operators/observable/gz;->actual:Lio/reactivex/r;

    .line 409
    iget-object v1, p0, Lio/reactivex/internal/operators/observable/gz;->window:Lio/reactivex/subjects/UnicastSubject;

    .line 411
    const/4 v0, 0x1

    move v9, v0

    .line 415
    :cond_b
    :goto_b
    iget-boolean v0, p0, Lio/reactivex/internal/operators/observable/gz;->terminated:Z

    if-eqz v0, :cond_1b

    .line 416
    iget-object v0, p0, Lio/reactivex/internal/operators/observable/gz;->s:Lio/reactivex/disposables/b;

    invoke-interface {v0}, Lio/reactivex/disposables/b;->dispose()V

    .line 417
    invoke-virtual {v7}, Lio/reactivex/internal/queue/MpscLinkedQueue;->clear()V

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

    .line 493
    :cond_1a
    :goto_1a
    return-void

    .line 422
    :cond_1b
    iget-boolean v3, p0, Lio/reactivex/internal/operators/observable/gz;->done:Z

    .line 424
    invoke-virtual {v7}, Lio/reactivex/internal/queue/MpscLinkedQueue;->poll()Ljava/lang/Object;

    move-result-object v0

    .line 426
    if-nez v0, :cond_3d

    const/4 v2, 0x1

    .line 427
    :goto_24
    instance-of v4, v0, Lio/reactivex/internal/operators/observable/ha;

    .line 429
    if-eqz v3, :cond_43

    if-nez v2, :cond_2c

    if-eqz v4, :cond_43

    .line 430
    :cond_2c
    const/4 v0, 0x0

    iput-object v0, p0, Lio/reactivex/internal/operators/observable/gz;->window:Lio/reactivex/subjects/UnicastSubject;

    .line 431
    invoke-virtual {v7}, Lio/reactivex/internal/queue/MpscLinkedQueue;->clear()V

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

    .line 433
    iget-object v0, p0, Lio/reactivex/internal/operators/observable/gz;->error:Ljava/lang/Throwable;

    .line 434
    if-eqz v0, :cond_3f

    .line 435
    invoke-virtual {v1, v0}, Lio/reactivex/subjects/UnicastSubject;->onError(Ljava/lang/Throwable;)V

    goto :goto_1a

    .line 426
    :cond_3d
    const/4 v2, 0x0

    goto :goto_24

    .line 437
    :cond_3f
    invoke-virtual {v1}, Lio/reactivex/subjects/UnicastSubject;->onComplete()V

    goto :goto_1a

    .line 442
    :cond_43
    if-nez v2, :cond_cd

    .line 446
    if-eqz v4, :cond_69

    .line 447
    check-cast v0, Lio/reactivex/internal/operators/observable/ha;

    .line 448
    iget-boolean v2, p0, Lio/reactivex/internal/operators/observable/gz;->bPv:Z

    if-nez v2, :cond_55

    iget-wide v2, p0, Lio/reactivex/internal/operators/observable/gz;->bPx:J

    iget-wide v4, v0, Lio/reactivex/internal/operators/observable/ha;->index:J

    cmp-long v0, v2, v4

    if-nez v0, :cond_b

    .line 449
    :cond_55
    invoke-virtual {v1}, Lio/reactivex/subjects/UnicastSubject;->onComplete()V

    .line 450
    const-wide/16 v0, 0x0

    iput-wide v0, p0, Lio/reactivex/internal/operators/observable/gz;->count:J

    .line 451
    iget v0, p0, Lio/reactivex/internal/operators/observable/gz;->bufferSize:I

    invoke-static {v0}, Lio/reactivex/subjects/UnicastSubject;->fj(I)Lio/reactivex/subjects/UnicastSubject;

    move-result-object v0

    .line 452
    iput-object v0, p0, Lio/reactivex/internal/operators/observable/gz;->window:Lio/reactivex/subjects/UnicastSubject;

    .line 454
    invoke-interface {v11, v0}, Lio/reactivex/r;->onNext(Ljava/lang/Object;)V

    move-object v1, v0

    goto :goto_b

    .line 459
    :cond_69
    invoke-static {v0}, Lio/reactivex/internal/util/NotificationLite;->getValue(Ljava/lang/Object;)Ljava/lang/Object;

    move-result-object v0

    invoke-virtual {v1, v0}, Lio/reactivex/subjects/UnicastSubject;->onNext(Ljava/lang/Object;)V

    .line 460
    iget-wide v2, p0, Lio/reactivex/internal/operators/observable/gz;->count:J

    const-wide/16 v4, 0x1

    add-long/2addr v2, v4

    .line 462
    iget-wide v4, p0, Lio/reactivex/internal/operators/observable/gz;->CJ:J

    cmp-long v0, v2, v4

    if-ltz v0, :cond_c7

    .line 463
    iget-wide v2, p0, Lio/reactivex/internal/operators/observable/gz;->bPx:J

    const-wide/16 v4, 0x1

    add-long/2addr v2, v4

    iput-wide v2, p0, Lio/reactivex/internal/operators/observable/gz;->bPx:J

    .line 464
    const-wide/16 v2, 0x0

    iput-wide v2, p0, Lio/reactivex/internal/operators/observable/gz;->count:J

    .line 466
    invoke-virtual {v1}, Lio/reactivex/subjects/UnicastSubject;->onComplete()V

    .line 468
    iget v0, p0, Lio/reactivex/internal/operators/observable/gz;->bufferSize:I

    invoke-static {v0}, Lio/reactivex/subjects/UnicastSubject;->fj(I)Lio/reactivex/subjects/UnicastSubject;

    move-result-object v10

    .line 469
    iput-object v10, p0, Lio/reactivex/internal/operators/observable/gz;->window:Lio/reactivex/subjects/UnicastSubject;

    .line 470
    iget-object v0, p0, Lio/reactivex/internal/operators/observable/gz;->actual:Lio/reactivex/r;

    invoke-interface {v0, v10}, Lio/reactivex/r;->onNext(Ljava/lang/Object;)V

    .line 472
    iget-boolean v0, p0, Lio/reactivex/internal/operators/observable/gz;->bPv:Z

    if-eqz v0, :cond_d7

    .line 473
    iget-object v0, p0, Lio/reactivex/internal/operators/observable/gz;->timer:Ljava/util/concurrent/atomic/AtomicReference;

    invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object;

    move-result-object v0

    move-object v8, v0

    check-cast v8, Lio/reactivex/disposables/b;

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

    .line 476
    iget-object v0, p0, Lio/reactivex/internal/operators/observable/gz;->worker:Lio/reactivex/v;

    new-instance v1, Lio/reactivex/internal/operators/observable/ha;

    iget-wide v2, p0, Lio/reactivex/internal/operators/observable/gz;->bPx:J

    invoke-direct {v1, v2, v3, p0}, Lio/reactivex/internal/operators/observable/ha;-><init>(JLio/reactivex/internal/operators/observable/gz;)V

    iget-wide v2, p0, Lio/reactivex/internal/operators/observable/gz;->bPt:J

    iget-wide v4, p0, Lio/reactivex/internal/operators/observable/gz;->bPt:J

    iget-object v6, p0, Lio/reactivex/internal/operators/observable/gz;->unit:Ljava/util/concurrent/TimeUnit;

    invoke-virtual/range {v0 .. v6}, Lio/reactivex/v;->c(Ljava/lang/Runnable;JJLjava/util/concurrent/TimeUnit;)Lio/reactivex/disposables/b;

    move-result-object v0

    .line 478
    iget-object v1, p0, Lio/reactivex/internal/operators/observable/gz;->timer:Ljava/util/concurrent/atomic/AtomicReference;

    invoke-virtual {v1, v8, v0}, Ljava/util/concurrent/atomic/AtomicReference;->compareAndSet(Ljava/lang/Object;Ljava/lang/Object;)Z

    move-result v1

    if-nez v1, :cond_c4

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

    :cond_c4
    move-object v1, v10

    .line 481
    goto/16 :goto_b

    .line 484
    :cond_c7
    iput-wide v2, p0, Lio/reactivex/internal/operators/observable/gz;->count:J

    move-object v0, v1

    :goto_ca
    move-object v1, v0

    .line 486
    goto/16 :goto_b

    .line 488
    :cond_cd
    neg-int v0, v9

    invoke-virtual {p0, v0}, Lio/reactivex/internal/operators/observable/gz;->ff(I)I

    move-result v0

    .line 489
    if-eqz v0, :cond_1a

    move v9, v0

    goto/16 :goto_b

    :cond_d7
    move-object v0, v10

    goto :goto_ca
.end method

.method public final isDisposed()Z
    .registers 2

    .prologue
    .line 395
    iget-boolean v0, p0, Lio/reactivex/internal/operators/observable/gz;->cancelled:Z

    return v0
.end method

.method public final onComplete()V
    .registers 2

    .prologue
    .line 379
    const/4 v0, 0x1

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

    .line 380
    invoke-virtual {p0}, Lio/reactivex/internal/operators/observable/gz;->PR()Z

    move-result v0

    if-eqz v0, :cond_c

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

    .line 384
    :cond_c
    iget-object v0, p0, Lio/reactivex/internal/operators/observable/gz;->actual:Lio/reactivex/r;

    invoke-interface {v0}, Lio/reactivex/r;->onComplete()V

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

    .line 386
    return-void
.end method

.method public final onError(Ljava/lang/Throwable;)V
    .registers 3

    .prologue
    .line 367
    iput-object p1, p0, Lio/reactivex/internal/operators/observable/gz;->error:Ljava/lang/Throwable;

    .line 368
    const/4 v0, 0x1

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

    .line 369
    invoke-virtual {p0}, Lio/reactivex/internal/operators/observable/gz;->PR()Z

    move-result v0

    if-eqz v0, :cond_e

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

    .line 373
    :cond_e
    iget-object v0, p0, Lio/reactivex/internal/operators/observable/gz;->actual:Lio/reactivex/r;

    invoke-interface {v0, p1}, Lio/reactivex/r;->onError(Ljava/lang/Throwable;)V

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

    .line 375
    return-void
.end method

.method public final onNext(Ljava/lang/Object;)V
    .registers 10
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(TT;)V"
        }
    .end annotation

    .prologue
    const-wide/16 v6, 0x1

    .line 322
    iget-boolean v0, p0, Lio/reactivex/internal/operators/observable/gz;->terminated:Z

    if-eqz v0, :cond_7

    .line 363
    :cond_6
    :goto_6
    return-void

    .line 326
    :cond_7
    invoke-virtual {p0}, Lio/reactivex/internal/operators/observable/gz;->PS()Z

    move-result v0

    if-eqz v0, :cond_69

    .line 327
    iget-object v0, p0, Lio/reactivex/internal/operators/observable/gz;->window:Lio/reactivex/subjects/UnicastSubject;

    .line 328
    invoke-virtual {v0, p1}, Lio/reactivex/subjects/UnicastSubject;->onNext(Ljava/lang/Object;)V

    .line 330
    iget-wide v2, p0, Lio/reactivex/internal/operators/observable/gz;->count:J

    add-long/2addr v2, v6

    .line 332
    iget-wide v4, p0, Lio/reactivex/internal/operators/observable/gz;->CJ:J

    cmp-long v1, v2, v4

    if-ltz v1, :cond_66

    .line 333
    iget-wide v2, p0, Lio/reactivex/internal/operators/observable/gz;->bPx:J

    add-long/2addr v2, v6

    iput-wide v2, p0, Lio/reactivex/internal/operators/observable/gz;->bPx:J

    .line 334
    const-wide/16 v2, 0x0

    iput-wide v2, p0, Lio/reactivex/internal/operators/observable/gz;->count:J

    .line 336
    invoke-virtual {v0}, Lio/reactivex/subjects/UnicastSubject;->onComplete()V

    .line 338
    iget v0, p0, Lio/reactivex/internal/operators/observable/gz;->bufferSize:I

    invoke-static {v0}, Lio/reactivex/subjects/UnicastSubject;->fj(I)Lio/reactivex/subjects/UnicastSubject;

    move-result-object v0

    .line 339
    iput-object v0, p0, Lio/reactivex/internal/operators/observable/gz;->window:Lio/reactivex/subjects/UnicastSubject;

    .line 340
    iget-object v1, p0, Lio/reactivex/internal/operators/observable/gz;->actual:Lio/reactivex/r;

    invoke-interface {v1, v0}, Lio/reactivex/r;->onNext(Ljava/lang/Object;)V

    .line 341
    iget-boolean v0, p0, Lio/reactivex/internal/operators/observable/gz;->bPv:Z

    if-eqz v0, :cond_5b

    .line 342
    iget-object v0, p0, Lio/reactivex/internal/operators/observable/gz;->timer:Ljava/util/concurrent/atomic/AtomicReference;

    invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object;

    move-result-object v0

    check-cast v0, Lio/reactivex/disposables/b;

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

    .line 344
    iget-object v0, p0, Lio/reactivex/internal/operators/observable/gz;->worker:Lio/reactivex/v;

    new-instance v1, Lio/reactivex/internal/operators/observable/ha;

    iget-wide v2, p0, Lio/reactivex/internal/operators/observable/gz;->bPx:J

    invoke-direct {v1, v2, v3, p0}, Lio/reactivex/internal/operators/observable/ha;-><init>(JLio/reactivex/internal/operators/observable/gz;)V

    iget-wide v2, p0, Lio/reactivex/internal/operators/observable/gz;->bPt:J

    iget-wide v4, p0, Lio/reactivex/internal/operators/observable/gz;->bPt:J

    iget-object v6, p0, Lio/reactivex/internal/operators/observable/gz;->unit:Ljava/util/concurrent/TimeUnit;

    invoke-virtual/range {v0 .. v6}, Lio/reactivex/v;->c(Ljava/lang/Runnable;JJLjava/util/concurrent/TimeUnit;)Lio/reactivex/disposables/b;

    move-result-object v0

    .line 347
    iget-object v1, p0, Lio/reactivex/internal/operators/observable/gz;->timer:Ljava/util/concurrent/atomic/AtomicReference;

    invoke-static {v1, v0}, Lio/reactivex/internal/disposables/DisposableHelper;->replace(Ljava/util/concurrent/atomic/AtomicReference;Lio/reactivex/disposables/b;)Z

    .line 353
    :cond_5b
    :goto_5b
    const/4 v0, -0x1

    invoke-virtual {p0, v0}, Lio/reactivex/internal/operators/observable/gz;->ff(I)I

    move-result v0

    if-eqz v0, :cond_6

    .line 362
    :cond_62
    invoke-virtual {p0}, Lio/reactivex/internal/operators/observable/gz;->drainLoop()V

    goto :goto_6

    .line 350
    :cond_66
    iput-wide v2, p0, Lio/reactivex/internal/operators/observable/gz;->count:J

    goto :goto_5b

    .line 357
    :cond_69
    iget-object v0, p0, Lio/reactivex/internal/operators/observable/gz;->queue:Lio/reactivex/internal/a/f;

    invoke-static {p1}, Lio/reactivex/internal/util/NotificationLite;->next(Ljava/lang/Object;)Ljava/lang/Object;

    move-result-object v1

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

    .line 358
    invoke-virtual {p0}, Lio/reactivex/internal/operators/observable/gz;->PR()Z

    move-result v0

    if-nez v0, :cond_62

    goto :goto_6
.end method

.method public final onSubscribe(Lio/reactivex/disposables/b;)V
    .registers 9

    .prologue
    .line 292
    iget-object v0, p0, Lio/reactivex/internal/operators/observable/gz;->s:Lio/reactivex/disposables/b;

    invoke-static {v0, p1}, Lio/reactivex/internal/disposables/DisposableHelper;->validate(Lio/reactivex/disposables/b;Lio/reactivex/disposables/b;)Z

    move-result v0

    if-eqz v0, :cond_13

    .line 293
    iput-object p1, p0, Lio/reactivex/internal/operators/observable/gz;->s:Lio/reactivex/disposables/b;

    .line 295
    iget-object v0, p0, Lio/reactivex/internal/operators/observable/gz;->actual:Lio/reactivex/r;

    .line 297
    invoke-interface {v0, p0}, Lio/reactivex/r;->onSubscribe(Lio/reactivex/disposables/b;)V

    .line 299
    iget-boolean v1, p0, Lio/reactivex/internal/operators/observable/gz;->cancelled:Z

    if-eqz v1, :cond_14

    .line 318
    :cond_13
    :goto_13
    return-void

    .line 303
    :cond_14
    iget v1, p0, Lio/reactivex/internal/operators/observable/gz;->bufferSize:I

    invoke-static {v1}, Lio/reactivex/subjects/UnicastSubject;->fj(I)Lio/reactivex/subjects/UnicastSubject;

    move-result-object v1

    .line 304
    iput-object v1, p0, Lio/reactivex/internal/operators/observable/gz;->window:Lio/reactivex/subjects/UnicastSubject;

    .line 306
    invoke-interface {v0, v1}, Lio/reactivex/r;->onNext(Ljava/lang/Object;)V

    .line 309
    new-instance v1, Lio/reactivex/internal/operators/observable/ha;

    iget-wide v2, p0, Lio/reactivex/internal/operators/observable/gz;->bPx:J

    invoke-direct {v1, v2, v3, p0}, Lio/reactivex/internal/operators/observable/ha;-><init>(JLio/reactivex/internal/operators/observable/gz;)V

    .line 310
    iget-boolean v0, p0, Lio/reactivex/internal/operators/observable/gz;->bPv:Z

    if-eqz v0, :cond_3c

    .line 311
    iget-object v0, p0, Lio/reactivex/internal/operators/observable/gz;->worker:Lio/reactivex/v;

    iget-wide v2, p0, Lio/reactivex/internal/operators/observable/gz;->bPt:J

    iget-wide v4, p0, Lio/reactivex/internal/operators/observable/gz;->bPt:J

    iget-object v6, p0, Lio/reactivex/internal/operators/observable/gz;->unit:Ljava/util/concurrent/TimeUnit;

    invoke-virtual/range {v0 .. v6}, Lio/reactivex/v;->c(Ljava/lang/Runnable;JJLjava/util/concurrent/TimeUnit;)Lio/reactivex/disposables/b;

    move-result-object v0

    .line 316
    :goto_36
    iget-object v1, p0, Lio/reactivex/internal/operators/observable/gz;->timer:Ljava/util/concurrent/atomic/AtomicReference;

    invoke-static {v1, v0}, Lio/reactivex/internal/disposables/DisposableHelper;->replace(Ljava/util/concurrent/atomic/AtomicReference;Lio/reactivex/disposables/b;)Z

    goto :goto_13

    .line 313
    :cond_3c
    iget-object v0, p0, Lio/reactivex/internal/operators/observable/gz;->scheduler:Lio/reactivex/s;

    iget-wide v2, p0, Lio/reactivex/internal/operators/observable/gz;->bPt:J

    iget-wide v4, p0, Lio/reactivex/internal/operators/observable/gz;->bPt:J

    iget-object v6, p0, Lio/reactivex/internal/operators/observable/gz;->unit:Ljava/util/concurrent/TimeUnit;

    invoke-virtual/range {v0 .. v6}, Lio/reactivex/s;->b(Ljava/lang/Runnable;JJLjava/util/concurrent/TimeUnit;)Lio/reactivex/disposables/b;

    move-result-object v0

    goto :goto_36
.end method