f.smali

.class final Lrx/internal/schedulers/f;
.super Lrx/k;
.source "EventLoopsScheduler.java"


# instance fields
.field private final cbL:Lrx/internal/util/k;

.field private final cbM:Lrx/g/b;

.field private final cbN:Lrx/internal/util/k;

.field private final cbO:Lrx/internal/schedulers/h;


# direct methods
.method constructor <init>(Lrx/internal/schedulers/h;)V
    .registers 6

    .prologue
    .line 145
    invoke-direct {p0}, Lrx/k;-><init>()V

    .line 140
    new-instance v0, Lrx/internal/util/k;

    invoke-direct {v0}, Lrx/internal/util/k;-><init>()V

    iput-object v0, p0, Lrx/internal/schedulers/f;->cbL:Lrx/internal/util/k;

    .line 141
    new-instance v0, Lrx/g/b;

    invoke-direct {v0}, Lrx/g/b;-><init>()V

    iput-object v0, p0, Lrx/internal/schedulers/f;->cbM:Lrx/g/b;

    .line 142
    new-instance v0, Lrx/internal/util/k;

    const/4 v1, 0x2

    new-array v1, v1, [Lrx/p;

    const/4 v2, 0x0

    iget-object v3, p0, Lrx/internal/schedulers/f;->cbL:Lrx/internal/util/k;

    aput-object v3, v1, v2

    const/4 v2, 0x1

    iget-object v3, p0, Lrx/internal/schedulers/f;->cbM:Lrx/g/b;

    aput-object v3, v1, v2

    invoke-direct {v0, v1}, Lrx/internal/util/k;-><init>([Lrx/p;)V

    iput-object v0, p0, Lrx/internal/schedulers/f;->cbN:Lrx/internal/util/k;

    .line 146
    iput-object p1, p0, Lrx/internal/schedulers/f;->cbO:Lrx/internal/schedulers/h;

    .line 148
    return-void
.end method


# virtual methods
.method public final b(Lrx/b/a;)Lrx/p;
    .registers 8

    .prologue
    const-wide/16 v4, 0x0

    .line 162
    invoke-virtual {p0}, Lrx/internal/schedulers/f;->isUnsubscribed()Z

    move-result v0

    if-eqz v0, :cond_d

    .line 163
    invoke-static {}, Lrx/g/e;->TA()Lrx/p;

    move-result-object v0

    .line 166
    :goto_c
    return-object v0

    :cond_d
    iget-object v0, p0, Lrx/internal/schedulers/f;->cbO:Lrx/internal/schedulers/h;

    new-instance v1, Lrx/internal/schedulers/f$1;

    invoke-direct {v1, p0, p1}, Lrx/internal/schedulers/f$1;-><init>(Lrx/internal/schedulers/f;Lrx/b/a;)V

    iget-object v2, p0, Lrx/internal/schedulers/f;->cbL:Lrx/internal/util/k;

    .line 1269
    invoke-static {v1}, Lrx/d/c;->e(Lrx/b/a;)Lrx/b/a;

    move-result-object v3

    .line 1270
    new-instance v1, Lrx/internal/schedulers/ScheduledAction;

    invoke-direct {v1, v3, v2}, Lrx/internal/schedulers/ScheduledAction;-><init>(Lrx/b/a;Lrx/internal/util/k;)V

    .line 1271
    invoke-virtual {v2, v1}, Lrx/internal/util/k;->add(Lrx/p;)V

    .line 1274
    cmp-long v2, v4, v4

    if-gtz v2, :cond_31

    .line 1275
    iget-object v0, v0, Lrx/internal/schedulers/m;->aQs:Ljava/util/concurrent/ScheduledExecutorService;

    invoke-interface {v0, v1}, Ljava/util/concurrent/ScheduledExecutorService;->submit(Ljava/lang/Runnable;)Ljava/util/concurrent/Future;

    move-result-object v0

    .line 1279
    :goto_2c
    invoke-virtual {v1, v0}, Lrx/internal/schedulers/ScheduledAction;->add(Ljava/util/concurrent/Future;)V

    move-object v0, v1

    .line 166
    goto :goto_c

    .line 1277
    :cond_31
    iget-object v0, v0, Lrx/internal/schedulers/m;->aQs:Ljava/util/concurrent/ScheduledExecutorService;

    const/4 v2, 0x0

    invoke-interface {v0, v1, v4, v5, v2}, Ljava/util/concurrent/ScheduledExecutorService;->schedule(Ljava/lang/Runnable;JLjava/util/concurrent/TimeUnit;)Ljava/util/concurrent/ScheduledFuture;

    move-result-object v0

    goto :goto_2c
.end method

.method public final isUnsubscribed()Z
    .registers 2

    .prologue
    .line 157
    iget-object v0, p0, Lrx/internal/schedulers/f;->cbN:Lrx/internal/util/k;

    invoke-virtual {v0}, Lrx/internal/util/k;->isUnsubscribed()Z

    move-result v0

    return v0
.end method

.method public final unsubscribe()V
    .registers 2

    .prologue
    .line 152
    iget-object v0, p0, Lrx/internal/schedulers/f;->cbN:Lrx/internal/util/k;

    invoke-virtual {v0}, Lrx/internal/util/k;->unsubscribe()V

    .line 153
    return-void
.end method