w$1$1$1.smali

.class final Lrx/internal/operators/w$1$1$1;
.super Ljava/lang/Object;
.source "OperatorSubscribeOn.java"

# interfaces
.implements Lrx/i;


# annotations
.annotation system Ldalvik/annotation/EnclosingMethod;
    value = Lrx/internal/operators/w$1$1;->a(Lrx/i;)V
.end annotation


# instance fields
.field final synthetic cbg:Lrx/i;

.field private synthetic cbh:Lrx/internal/operators/w$1$1;


# direct methods
.method constructor <init>(Lrx/internal/operators/w$1$1;Lrx/i;)V
    .registers 3

    .prologue
    .line 76
    iput-object p1, p0, Lrx/internal/operators/w$1$1$1;->cbh:Lrx/internal/operators/w$1$1;

    iput-object p2, p0, Lrx/internal/operators/w$1$1$1;->cbg:Lrx/i;

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

    return-void
.end method


# virtual methods
.method public final request(J)V
    .registers 6

    .prologue
    .line 79
    iget-object v0, p0, Lrx/internal/operators/w$1$1$1;->cbh:Lrx/internal/operators/w$1$1;

    iget-object v0, v0, Lrx/internal/operators/w$1$1;->cbe:Ljava/lang/Thread;

    invoke-static {}, Ljava/lang/Thread;->currentThread()Ljava/lang/Thread;

    move-result-object v1

    if-ne v0, v1, :cond_10

    .line 80
    iget-object v0, p0, Lrx/internal/operators/w$1$1$1;->cbg:Lrx/i;

    invoke-interface {v0, p1, p2}, Lrx/i;->request(J)V

    .line 89
    :goto_f
    return-void

    .line 82
    :cond_10
    iget-object v0, p0, Lrx/internal/operators/w$1$1$1;->cbh:Lrx/internal/operators/w$1$1;

    iget-object v0, v0, Lrx/internal/operators/w$1$1;->cbf:Lrx/internal/operators/w$1;

    iget-object v0, v0, Lrx/internal/operators/w$1;->cbc:Lrx/k;

    new-instance v1, Lrx/internal/operators/w$1$1$1$1;

    invoke-direct {v1, p0, p1, p2}, Lrx/internal/operators/w$1$1$1$1;-><init>(Lrx/internal/operators/w$1$1$1;J)V

    invoke-virtual {v0, v1}, Lrx/k;->b(Lrx/b/a;)Lrx/p;

    goto :goto_f
.end method