r.smali

.class final Lrx/internal/operators/r;
.super Lrx/o;
.source "OperatorMerge.java"


# annotations
.annotation system Ldalvik/annotation/Signature;
    value = {
        "<T:",
        "Ljava/lang/Object;",
        ">",
        "Lrx/o",
        "<TT;>;"
    }
.end annotation


# static fields
.field private static caQ:I


# instance fields
.field private caN:Lrx/internal/operators/s;
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "Lrx/internal/operators/s",
            "<TT;>;"
        }
    .end annotation
.end field

.field volatile caO:Lrx/internal/util/c;

.field private caP:I

.field volatile done:Z

.field final id:J


# direct methods
.method static constructor <clinit>()V
    .registers 1

    .prologue
    .line 833
    sget v0, Lrx/internal/util/c;->SIZE:I

    div-int/lit8 v0, v0, 0x4

    sput v0, Lrx/internal/operators/r;->caQ:I

    return-void
.end method

.method public constructor <init>(Lrx/internal/operators/s;J)V
    .registers 4
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Lrx/internal/operators/s",
            "<TT;>;J)V"
        }
    .end annotation

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

    .line 836
    iput-object p1, p0, Lrx/internal/operators/r;->caN:Lrx/internal/operators/s;

    .line 837
    iput-wide p2, p0, Lrx/internal/operators/r;->id:J

    .line 838
    return-void
.end method


# virtual methods
.method public final SG()V
    .registers 2

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

    iput-boolean v0, p0, Lrx/internal/operators/r;->done:Z

    .line 857
    iget-object v0, p0, Lrx/internal/operators/r;->caN:Lrx/internal/operators/s;

    invoke-virtual {v0}, Lrx/internal/operators/s;->emit()V

    .line 858
    return-void
.end method

.method public final af(J)V
    .registers 6

    .prologue
    .line 860
    iget v0, p0, Lrx/internal/operators/r;->caP:I

    long-to-int v1, p1

    sub-int/2addr v0, v1

    .line 861
    sget v1, Lrx/internal/operators/r;->caQ:I

    if-le v0, v1, :cond_b

    .line 862
    iput v0, p0, Lrx/internal/operators/r;->caP:I

    .line 870
    :cond_a
    :goto_a
    return-void

    .line 865
    :cond_b
    sget v1, Lrx/internal/util/c;->SIZE:I

    iput v1, p0, Lrx/internal/operators/r;->caP:I

    .line 866
    sget v1, Lrx/internal/util/c;->SIZE:I

    sub-int v0, v1, v0

    .line 867
    if-lez v0, :cond_a

    .line 868
    int-to-long v0, v0

    invoke-virtual {p0, v0, v1}, Lrx/internal/operators/r;->request(J)V

    goto :goto_a
.end method

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

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

    iput-boolean v0, p0, Lrx/internal/operators/r;->done:Z

    .line 851
    iget-object v0, p0, Lrx/internal/operators/r;->caN:Lrx/internal/operators/s;

    invoke-virtual {v0}, Lrx/internal/operators/s;->SR()Ljava/util/Queue;

    move-result-object v0

    invoke-interface {v0, p1}, Ljava/util/Queue;->offer(Ljava/lang/Object;)Z

    .line 852
    iget-object v0, p0, Lrx/internal/operators/r;->caN:Lrx/internal/operators/s;

    invoke-virtual {v0}, Lrx/internal/operators/s;->emit()V

    .line 853
    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, 0x0

    const/4 v2, 0x1

    const/4 v1, 0x0

    .line 846
    iget-object v3, p0, Lrx/internal/operators/r;->caN:Lrx/internal/operators/s;

    .line 1341
    iget-object v0, v3, Lrx/internal/operators/s;->caR:Lrx/internal/operators/OperatorMerge$MergeProducer;

    invoke-virtual {v0}, Lrx/internal/operators/OperatorMerge$MergeProducer;->get()J

    move-result-wide v4

    .line 1342
    cmp-long v0, v4, v6

    if-eqz v0, :cond_8b

    .line 1343
    monitor-enter v3

    .line 1345
    :try_start_11
    iget-object v0, v3, Lrx/internal/operators/s;->caR:Lrx/internal/operators/OperatorMerge$MergeProducer;

    invoke-virtual {v0}, Lrx/internal/operators/OperatorMerge$MergeProducer;->get()J

    move-result-wide v4

    .line 1346
    iget-boolean v0, v3, Lrx/internal/operators/s;->bTk:Z

    if-nez v0, :cond_89

    cmp-long v0, v4, v6

    if-eqz v0, :cond_89

    .line 1347
    const/4 v0, 0x1

    iput-boolean v0, v3, Lrx/internal/operators/s;->bTk:Z

    move v0, v2

    .line 1350
    :goto_23
    monitor-exit v3
    :try_end_24
    .catchall {:try_start_11 .. :try_end_24} :catchall_53

    .line 1352
    :goto_24
    if-eqz v0, :cond_80

    .line 1353
    iget-object v0, p0, Lrx/internal/operators/r;->caO:Lrx/internal/util/c;

    .line 1354
    if-eqz v0, :cond_30

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

    move-result v0

    if-eqz v0, :cond_79

    .line 1395
    :cond_30
    :try_start_30
    iget-object v0, v3, Lrx/internal/operators/s;->child:Lrx/o;

    invoke-virtual {v0, p1}, Lrx/o;->onNext(Ljava/lang/Object;)V
    :try_end_35
    .catch Ljava/lang/Throwable; {:try_start_30 .. :try_end_35} :catch_56
    .catchall {:try_start_30 .. :try_end_35} :catchall_87

    .line 1406
    const-wide v6, 0x7fffffffffffffffL

    cmp-long v0, v4, v6

    if-eqz v0, :cond_44

    .line 1407
    :try_start_3e
    iget-object v0, v3, Lrx/internal/operators/s;->caR:Lrx/internal/operators/OperatorMerge$MergeProducer;

    const/4 v4, 0x1

    invoke-virtual {v0, v4}, Lrx/internal/operators/OperatorMerge$MergeProducer;->produced(I)J

    .line 1409
    :cond_44
    const-wide/16 v4, 0x1

    invoke-virtual {p0, v4, v5}, Lrx/internal/operators/r;->af(J)V

    .line 1411
    monitor-enter v3
    :try_end_4a
    .catchall {:try_start_3e .. :try_end_4a} :catchall_87

    .line 1413
    :try_start_4a
    iget-boolean v0, v3, Lrx/internal/operators/s;->caT:Z

    if-nez v0, :cond_6b

    .line 1414
    const/4 v0, 0x0

    iput-boolean v0, v3, Lrx/internal/operators/s;->bTk:Z

    .line 1415
    monitor-exit v3
    :try_end_52
    .catchall {:try_start_4a .. :try_end_52} :catchall_73

    .line 1423
    :goto_52
    return-void

    .line 1350
    :catchall_53
    move-exception v0

    :try_start_54
    monitor-exit v3
    :try_end_55
    .catchall {:try_start_54 .. :try_end_55} :catchall_53

    throw v0

    .line 1396
    :catch_56
    move-exception v0

    .line 1398
    :try_start_57
    invoke-static {v0}, Lrx/exceptions/d;->throwIfFatal(Ljava/lang/Throwable;)V
    :try_end_5a
    .catchall {:try_start_57 .. :try_end_5a} :catchall_87

    .line 1400
    :try_start_5a
    invoke-virtual {p0}, Lrx/internal/operators/r;->unsubscribe()V

    .line 1401
    invoke-virtual {p0, v0}, Lrx/internal/operators/r;->onError(Ljava/lang/Throwable;)V
    :try_end_60
    .catchall {:try_start_5a .. :try_end_60} :catchall_61

    goto :goto_52

    .line 1420
    :catchall_61
    move-exception v0

    move v1, v2

    :goto_63
    if-nez v1, :cond_6a

    .line 1421
    monitor-enter v3

    .line 1422
    const/4 v1, 0x0

    :try_start_67
    iput-boolean v1, v3, Lrx/internal/operators/s;->bTk:Z

    .line 1423
    monitor-exit v3
    :try_end_6a
    .catchall {:try_start_67 .. :try_end_6a} :catchall_76

    :cond_6a
    throw v0

    .line 1417
    :cond_6b
    const/4 v0, 0x0

    :try_start_6c
    iput-boolean v0, v3, Lrx/internal/operators/s;->caT:Z

    .line 1418
    monitor-exit v3
    :try_end_6f
    .catchall {:try_start_6c .. :try_end_6f} :catchall_73

    .line 1433
    invoke-virtual {v3}, Lrx/internal/operators/s;->Qd()V

    goto :goto_52

    .line 1418
    :catchall_73
    move-exception v0

    :try_start_74
    monitor-exit v3
    :try_end_75
    .catchall {:try_start_74 .. :try_end_75} :catchall_73

    :try_start_75
    throw v0
    :try_end_76
    .catchall {:try_start_75 .. :try_end_76} :catchall_61

    .line 1423
    :catchall_76
    move-exception v0

    :try_start_77
    monitor-exit v3
    :try_end_78
    .catchall {:try_start_77 .. :try_end_78} :catchall_76

    throw v0

    .line 1357
    :cond_79
    invoke-static {p0, p1}, Lrx/internal/operators/s;->a(Lrx/internal/operators/r;Ljava/lang/Object;)V

    .line 1358
    invoke-virtual {v3}, Lrx/internal/operators/s;->Qd()V

    goto :goto_52

    .line 1361
    :cond_80
    invoke-static {p0, p1}, Lrx/internal/operators/s;->a(Lrx/internal/operators/r;Ljava/lang/Object;)V

    .line 1362
    invoke-virtual {v3}, Lrx/internal/operators/s;->emit()V

    goto :goto_52

    .line 1420
    :catchall_87
    move-exception v0

    goto :goto_63

    :cond_89
    move v0, v1

    goto :goto_23

    :cond_8b
    move-wide v4, v6

    move v0, v1

    goto :goto_24
.end method

.method public final onStart()V
    .registers 3

    .prologue
    .line 841
    sget v0, Lrx/internal/util/c;->SIZE:I

    iput v0, p0, Lrx/internal/operators/r;->caP:I

    .line 842
    sget v0, Lrx/internal/util/c;->SIZE:I

    int-to-long v0, v0

    invoke-virtual {p0, v0, v1}, Lrx/internal/operators/r;->request(J)V

    .line 843
    return-void
.end method