FlowableFlatMap$MergeSubscriber.smali
.class final Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;
.super Ljava/util/concurrent/atomic/AtomicInteger;
.source "FlowableFlatMap.java"
# interfaces
.implements Lio/reactivex/FlowableSubscriber;
.implements Lorg/reactivestreams/Subscription;
# annotations
.annotation system Ldalvik/annotation/EnclosingClass;
value = Lio/reactivex/internal/operators/flowable/FlowableFlatMap;
.end annotation
.annotation system Ldalvik/annotation/InnerClass;
accessFlags = 0x18
name = "MergeSubscriber"
.end annotation
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
"U:",
"Ljava/lang/Object;",
">",
"Ljava/util/concurrent/atomic/AtomicInteger;",
"Lio/reactivex/FlowableSubscriber<",
"TT;>;",
"Lorg/reactivestreams/Subscription;"
}
.end annotation
# static fields
.field static final CANCELLED:[Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;
.annotation system Ldalvik/annotation/Signature;
value = {
"[",
"Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber<",
"**>;"
}
.end annotation
.end field
.field static final EMPTY:[Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;
.annotation system Ldalvik/annotation/Signature;
value = {
"[",
"Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber<",
"**>;"
}
.end annotation
.end field
.field private static final serialVersionUID:J = -0x1d634c9cafb5cc5aL
# instance fields
.field final actual:Lorg/reactivestreams/Subscriber;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lorg/reactivestreams/Subscriber<",
"-TU;>;"
}
.end annotation
.end field
.field final bufferSize:I
.field volatile cancelled:Z
.field final delayErrors:Z
.field volatile done:Z
.field final errs:Lio/reactivex/internal/util/AtomicThrowable;
.field lastId:J
.field lastIndex:I
.field final mapper:Lio/reactivex/functions/Function;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/functions/Function<",
"-TT;+",
"Lorg/reactivestreams/Publisher<",
"+TU;>;>;"
}
.end annotation
.end field
.field final maxConcurrency:I
.field volatile queue:Lio/reactivex/internal/fuseable/SimplePlainQueue;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/internal/fuseable/SimplePlainQueue<",
"TU;>;"
}
.end annotation
.end field
.field final requested:Ljava/util/concurrent/atomic/AtomicLong;
.field s:Lorg/reactivestreams/Subscription;
.field scalarEmitted:I
.field final scalarLimit:I
.field final subscribers:Ljava/util/concurrent/atomic/AtomicReference;
.annotation system Ldalvik/annotation/Signature;
value = {
"Ljava/util/concurrent/atomic/AtomicReference<",
"[",
"Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber<",
"**>;>;"
}
.end annotation
.end field
.field uniqueId:J
# direct methods
.method static constructor <clinit>()V
.registers 2
.line 82
const/4 v0, 0x0
new-array v1, v0, [Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;
sput-object v1, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->EMPTY:[Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;
.line 84
new-array v0, v0, [Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;
sput-object v0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->CANCELLED:[Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;
return-void
.end method
.method constructor <init>(Lorg/reactivestreams/Subscriber;Lio/reactivex/functions/Function;ZII)V
.registers 8
.param p3, "delayErrors" # Z
.param p4, "maxConcurrency" # I
.param p5, "bufferSize" # I
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lorg/reactivestreams/Subscriber<",
"-TU;>;",
"Lio/reactivex/functions/Function<",
"-TT;+",
"Lorg/reactivestreams/Publisher<",
"+TU;>;>;ZII)V"
}
.end annotation
.line 98
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;, "Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber<TT;TU;>;"
.local p1, "actual":Lorg/reactivestreams/Subscriber;, "Lorg/reactivestreams/Subscriber<-TU;>;"
.local p2, "mapper":Lio/reactivex/functions/Function;, "Lio/reactivex/functions/Function<-TT;+Lorg/reactivestreams/Publisher<+TU;>;>;"
invoke-direct {p0}, Ljava/util/concurrent/atomic/AtomicInteger;-><init>()V
.line 76
new-instance v0, Lio/reactivex/internal/util/AtomicThrowable;
invoke-direct {v0}, Lio/reactivex/internal/util/AtomicThrowable;-><init>()V
iput-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->errs:Lio/reactivex/internal/util/AtomicThrowable;
.line 80
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/flowable/FlowableFlatMap$MergeSubscriber;->subscribers:Ljava/util/concurrent/atomic/AtomicReference;
.line 86
new-instance v0, Ljava/util/concurrent/atomic/AtomicLong;
invoke-direct {v0}, Ljava/util/concurrent/atomic/AtomicLong;-><init>()V
iput-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->requested:Ljava/util/concurrent/atomic/AtomicLong;
.line 99
iput-object p1, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->actual:Lorg/reactivestreams/Subscriber;
.line 100
iput-object p2, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->mapper:Lio/reactivex/functions/Function;
.line 101
iput-boolean p3, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->delayErrors:Z
.line 102
iput p4, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->maxConcurrency:I
.line 103
iput p5, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->bufferSize:I
.line 104
shr-int/lit8 v0, p4, 0x1
const/4 v1, 0x1
invoke-static {v1, v0}, Ljava/lang/Math;->max(II)I
move-result v0
iput v0, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->scalarLimit:I
.line 105
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->subscribers:Ljava/util/concurrent/atomic/AtomicReference;
sget-object v1, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->EMPTY:[Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;
invoke-virtual {v0, v1}, Ljava/util/concurrent/atomic/AtomicReference;->lazySet(Ljava/lang/Object;)V
.line 106
return-void
.end method
# virtual methods
.method addInner(Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;)Z
.registers 6
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber<",
"TT;TU;>;)Z"
}
.end annotation
.line 170
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;, "Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber<TT;TU;>;"
.local p1, "inner":Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;, "Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber<TT;TU;>;"
:goto_0
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->subscribers: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/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;
.line 171
.local v0, "a":[Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;, "[Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber<**>;"
sget-object v1, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->CANCELLED:[Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;
const/4 v2, 0x0
if-ne v0, v1, :cond_11
.line 172
invoke-virtual {p1}, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;->dispose()V
.line 173
return v2
.line 175
:cond_11
array-length v1, v0
.line 176
.local v1, "n":I
add-int/lit8 v3, v1, 0x1
new-array v3, v3, [Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;
.line 177
.local v3, "b":[Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;, "[Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber<**>;"
invoke-static {v0, v2, v3, v2, v1}, Ljava/lang/System;->arraycopy(Ljava/lang/Object;ILjava/lang/Object;II)V
.line 178
aput-object p1, v3, v1
.line 179
iget-object v2, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->subscribers:Ljava/util/concurrent/atomic/AtomicReference;
invoke-virtual {v2, v0, v3}, Ljava/util/concurrent/atomic/AtomicReference;->compareAndSet(Ljava/lang/Object;Ljava/lang/Object;)Z
move-result v2
if-eqz v2, :cond_25
.line 180
const/4 v2, 0x1
return v2
.line 182
.end local v0 # "a":[Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;, "[Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber<**>;"
.end local v1 # "n":I
.end local v3 # "b":[Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;, "[Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber<**>;"
:cond_25
goto :goto_0
.end method
.method public cancel()V
.registers 2
.line 351
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;, "Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber<TT;TU;>;"
iget-boolean v0, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->cancelled:Z
if-nez v0, :cond_1c
.line 352
const/4 v0, 0x1
iput-boolean v0, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->cancelled:Z
.line 353
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->s:Lorg/reactivestreams/Subscription;
invoke-interface {v0}, Lorg/reactivestreams/Subscription;->cancel()V
.line 354
invoke-virtual {p0}, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->disposeAll()V
.line 355
invoke-virtual {p0}, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->getAndIncrement()I
move-result v0
if-nez v0, :cond_1c
.line 356
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->queue:Lio/reactivex/internal/fuseable/SimplePlainQueue;
.line 357
.local v0, "q":Lio/reactivex/internal/fuseable/SimpleQueue;, "Lio/reactivex/internal/fuseable/SimpleQueue<TU;>;"
if-eqz v0, :cond_1c
.line 358
invoke-interface {v0}, Lio/reactivex/internal/fuseable/SimpleQueue;->clear()V
.line 362
.end local v0 # "q":Lio/reactivex/internal/fuseable/SimpleQueue;, "Lio/reactivex/internal/fuseable/SimpleQueue<TU;>;"
:cond_1c
return-void
.end method
.method checkTerminate()Z
.registers 4
.line 555
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;, "Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber<TT;TU;>;"
iget-boolean v0, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->cancelled:Z
const/4 v1, 0x1
if-eqz v0, :cond_9
.line 556
invoke-virtual {p0}, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->clearScalarQueue()V
.line 557
return v1
.line 559
:cond_9
iget-boolean v0, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->delayErrors:Z
if-nez v0, :cond_28
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->errs:Lio/reactivex/internal/util/AtomicThrowable;
invoke-virtual {v0}, Lio/reactivex/internal/util/AtomicThrowable;->get()Ljava/lang/Object;
move-result-object v0
if-eqz v0, :cond_28
.line 560
invoke-virtual {p0}, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->clearScalarQueue()V
.line 561
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->errs:Lio/reactivex/internal/util/AtomicThrowable;
invoke-virtual {v0}, Lio/reactivex/internal/util/AtomicThrowable;->terminate()Ljava/lang/Throwable;
move-result-object v0
.line 562
.local v0, "ex":Ljava/lang/Throwable;
sget-object v2, Lio/reactivex/internal/util/ExceptionHelper;->TERMINATED:Ljava/lang/Throwable;
if-eq v0, v2, :cond_27
.line 563
iget-object v2, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->actual:Lorg/reactivestreams/Subscriber;
invoke-interface {v2, v0}, Lorg/reactivestreams/Subscriber;->onError(Ljava/lang/Throwable;)V
.line 565
:cond_27
return v1
.line 567
.end local v0 # "ex":Ljava/lang/Throwable;
:cond_28
const/4 v0, 0x0
return v0
.end method
.method clearScalarQueue()V
.registers 2
.line 571
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;, "Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber<TT;TU;>;"
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->queue:Lio/reactivex/internal/fuseable/SimplePlainQueue;
.line 572
.local v0, "q":Lio/reactivex/internal/fuseable/SimpleQueue;, "Lio/reactivex/internal/fuseable/SimpleQueue<TU;>;"
if-eqz v0, :cond_7
.line 573
invoke-interface {v0}, Lio/reactivex/internal/fuseable/SimpleQueue;->clear()V
.line 575
:cond_7
return-void
.end method
.method disposeAll()V
.registers 5
.line 578
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;, "Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber<TT;TU;>;"
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->subscribers: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/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;
.line 579
.local v0, "a":[Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;, "[Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber<**>;"
sget-object v1, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->CANCELLED:[Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;
if-eq v0, v1, :cond_34
.line 580
iget-object v2, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->subscribers:Ljava/util/concurrent/atomic/AtomicReference;
invoke-virtual {v2, v1}, Ljava/util/concurrent/atomic/AtomicReference;->getAndSet(Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v1
move-object v0, v1
check-cast v0, [Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;
.line 581
sget-object v1, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->CANCELLED:[Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;
if-eq v0, v1, :cond_34
.line 582
array-length v1, v0
const/4 v2, 0x0
:goto_1b
if-ge v2, v1, :cond_25
aget-object v3, v0, v2
.line 583
.local v3, "inner":Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;, "Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber<**>;"
invoke-virtual {v3}, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;->dispose()V
.line 582
.end local v3 # "inner":Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;, "Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber<**>;"
add-int/lit8 v2, v2, 0x1
goto :goto_1b
.line 585
:cond_25
iget-object v1, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->errs:Lio/reactivex/internal/util/AtomicThrowable;
invoke-virtual {v1}, Lio/reactivex/internal/util/AtomicThrowable;->terminate()Ljava/lang/Throwable;
move-result-object v1
.line 586
.local v1, "ex":Ljava/lang/Throwable;
if-eqz v1, :cond_34
sget-object v2, Lio/reactivex/internal/util/ExceptionHelper;->TERMINATED:Ljava/lang/Throwable;
if-eq v1, v2, :cond_34
.line 587
invoke-static {v1}, Lio/reactivex/plugins/RxJavaPlugins;->onError(Ljava/lang/Throwable;)V
.line 591
.end local v1 # "ex":Ljava/lang/Throwable;
:cond_34
return-void
.end method
.method drain()V
.registers 2
.line 365
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;, "Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber<TT;TU;>;"
invoke-virtual {p0}, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->getAndIncrement()I
move-result v0
if-nez v0, :cond_9
.line 366
invoke-virtual {p0}, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->drainLoop()V
.line 368
:cond_9
return-void
.end method
.method drainLoop()V
.registers 34
.line 371
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;, "Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber<TT;TU;>;"
move-object/from16 v1, p0
iget-object v2, v1, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->actual:Lorg/reactivestreams/Subscriber;
.line 372
.local v2, "child":Lorg/reactivestreams/Subscriber;, "Lorg/reactivestreams/Subscriber<-TU;>;"
const/4 v0, 0x1
move v3, v0
.line 374
.local v3, "missed":I
:goto_6
invoke-virtual/range {p0 .. p0}, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->checkTerminate()Z
move-result v0
if-eqz v0, :cond_d
.line 375
return-void
.line 377
:cond_d
iget-object v0, v1, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->queue:Lio/reactivex/internal/fuseable/SimplePlainQueue;
.line 379
.local v0, "svq":Lio/reactivex/internal/fuseable/SimplePlainQueue;, "Lio/reactivex/internal/fuseable/SimplePlainQueue<TU;>;"
iget-object v4, v1, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->requested:Ljava/util/concurrent/atomic/AtomicLong;
invoke-virtual {v4}, Ljava/util/concurrent/atomic/AtomicLong;->get()J
move-result-wide v4
.line 380
.local v4, "r":J
const-wide v6, 0x7fffffffffffffffL
cmp-long v9, v4, v6
if-nez v9, :cond_20
const/4 v6, 0x1
goto :goto_21
:cond_20
const/4 v6, 0x0
.line 382
.local v6, "unbounded":Z
:goto_21
const-wide/16 v9, 0x0
.line 384
.local v9, "replenishMain":J
const-wide/16 v11, 0x1
const-wide/16 v13, 0x0
if-eqz v0, :cond_77
.line 386
:goto_29
const-wide/16 v15, 0x0
.line 387
.local v15, "scalarEmission":J
const/4 v7, 0x0
move-wide/from16 v17, v15
.line 388
.end local v15 # "scalarEmission":J
.local v7, "o":Ljava/lang/Object;, "TU;"
.local v17, "scalarEmission":J
:goto_2e
cmp-long v15, v4, v13
if-eqz v15, :cond_52
.line 389
invoke-interface {v0}, Lio/reactivex/internal/fuseable/SimplePlainQueue;->poll()Ljava/lang/Object;
move-result-object v7
.line 391
invoke-virtual/range {p0 .. p0}, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->checkTerminate()Z
move-result v15
if-eqz v15, :cond_3d
.line 392
return-void
.line 394
:cond_3d
if-nez v7, :cond_44
.line 395
move-wide/from16 v19, v9
move-wide/from16 v8, v17
goto :goto_56
.line 398
:cond_44
invoke-interface {v2, v7}, Lorg/reactivestreams/Subscriber;->onNext(Ljava/lang/Object;)V
.line 400
add-long/2addr v9, v11
.line 401
move-wide/from16 v19, v9
move-wide/from16 v8, v17
.end local v9 # "replenishMain":J
.end local v17 # "scalarEmission":J
.local v8, "scalarEmission":J
.local v19, "replenishMain":J
add-long v17, v8, v11
.line 402
.end local v8 # "scalarEmission":J
.restart local v17 # "scalarEmission":J
sub-long/2addr v4, v11
move-wide/from16 v9, v19
goto :goto_2e
.line 388
.end local v19 # "replenishMain":J
.restart local v9 # "replenishMain":J
:cond_52
move-wide/from16 v19, v9
move-wide/from16 v8, v17
.line 404
.end local v9 # "replenishMain":J
.end local v17 # "scalarEmission":J
.restart local v8 # "scalarEmission":J
.restart local v19 # "replenishMain":J
:goto_56
cmp-long v10, v8, v13
if-eqz v10, :cond_69
.line 405
if-eqz v6, :cond_62
.line 406
const-wide v4, 0x7fffffffffffffffL
goto :goto_69
.line 408
:cond_62
iget-object v10, v1, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->requested:Ljava/util/concurrent/atomic/AtomicLong;
neg-long v11, v8
invoke-virtual {v10, v11, v12}, Ljava/util/concurrent/atomic/AtomicLong;->addAndGet(J)J
move-result-wide v4
.line 411
:cond_69
:goto_69
cmp-long v10, v4, v13
if-eqz v10, :cond_75
if-nez v7, :cond_70
.line 412
goto :goto_75
.line 414
.end local v7 # "o":Ljava/lang/Object;, "TU;"
.end local v8 # "scalarEmission":J
:cond_70
move-wide/from16 v9, v19
const-wide/16 v11, 0x1
goto :goto_29
.line 417
:cond_75
:goto_75
move-wide/from16 v9, v19
.end local v19 # "replenishMain":J
.restart local v9 # "replenishMain":J
:cond_77
iget-boolean v7, v1, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->done:Z
.line 418
.local v7, "d":Z
iget-object v8, v1, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->queue:Lio/reactivex/internal/fuseable/SimplePlainQueue;
.line 419
.end local v0 # "svq":Lio/reactivex/internal/fuseable/SimplePlainQueue;, "Lio/reactivex/internal/fuseable/SimplePlainQueue<TU;>;"
.local v8, "svq":Lio/reactivex/internal/fuseable/SimplePlainQueue;, "Lio/reactivex/internal/fuseable/SimplePlainQueue<TU;>;"
iget-object v0, v1, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->subscribers:Ljava/util/concurrent/atomic/AtomicReference;
invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object;
move-result-object v0
move-object v11, v0
check-cast v11, [Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;
.line 420
.local v11, "inner":[Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;, "[Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber<**>;"
array-length v12, v11
.line 422
.local v12, "n":I
if-eqz v7, :cond_a5
if-eqz v8, :cond_8f
invoke-interface {v8}, Lio/reactivex/internal/fuseable/SimplePlainQueue;->isEmpty()Z
move-result v0
if-eqz v0, :cond_a5
:cond_8f
if-nez v12, :cond_a5
.line 423
iget-object v0, v1, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->errs:Lio/reactivex/internal/util/AtomicThrowable;
invoke-virtual {v0}, Lio/reactivex/internal/util/AtomicThrowable;->terminate()Ljava/lang/Throwable;
move-result-object v0
.line 424
.local v0, "ex":Ljava/lang/Throwable;
sget-object v13, Lio/reactivex/internal/util/ExceptionHelper;->TERMINATED:Ljava/lang/Throwable;
if-eq v0, v13, :cond_a4
.line 425
if-nez v0, :cond_a1
.line 426
invoke-interface {v2}, Lorg/reactivestreams/Subscriber;->onComplete()V
goto :goto_a4
.line 428
:cond_a1
invoke-interface {v2, v0}, Lorg/reactivestreams/Subscriber;->onError(Ljava/lang/Throwable;)V
.line 431
:cond_a4
:goto_a4
return-void
.line 434
.end local v0 # "ex":Ljava/lang/Throwable;
:cond_a5
const/4 v0, 0x0
.line 435
.local v0, "innerCompleted":Z
if-eqz v12, :cond_202
.line 436
iget-wide v13, v1, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->lastId:J
.line 437
.local v13, "startId":J
iget v15, v1, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->lastIndex:I
.line 439
.local v15, "index":I
if-le v12, v15, :cond_c0
move/from16 v21, v0
.end local v0 # "innerCompleted":Z
.local v21, "innerCompleted":Z
aget-object v0, v11, v15
move-wide/from16 v22, v4
.end local v4 # "r":J
.local v22, "r":J
iget-wide v4, v0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;->id:J
cmp-long v0, v4, v13
if-eqz v0, :cond_bb
goto :goto_c4
:cond_bb
move/from16 v24, v7
move-object/from16 v25, v8
goto :goto_f1
.end local v21 # "innerCompleted":Z
.end local v22 # "r":J
.restart local v0 # "innerCompleted":Z
.restart local v4 # "r":J
:cond_c0
move/from16 v21, v0
move-wide/from16 v22, v4
.line 440
.end local v0 # "innerCompleted":Z
.end local v4 # "r":J
.restart local v21 # "innerCompleted":Z
.restart local v22 # "r":J
:goto_c4
if-gt v12, v15, :cond_c7
.line 441
const/4 v15, 0x0
.line 443
:cond_c7
move v0, v15
.line 444
.local v0, "j":I
const/4 v4, 0x0
.local v4, "i":I
:goto_c9
if-ge v4, v12, :cond_e4
.line 445
aget-object v5, v11, v0
move/from16 v24, v7
move-object/from16 v25, v8
.end local v7 # "d":Z
.end local v8 # "svq":Lio/reactivex/internal/fuseable/SimplePlainQueue;, "Lio/reactivex/internal/fuseable/SimplePlainQueue<TU;>;"
.local v24, "d":Z
.local v25, "svq":Lio/reactivex/internal/fuseable/SimplePlainQueue;, "Lio/reactivex/internal/fuseable/SimplePlainQueue<TU;>;"
iget-wide v7, v5, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;->id:J
cmp-long v5, v7, v13
if-nez v5, :cond_d8
.line 446
goto :goto_e8
.line 448
:cond_d8
add-int/lit8 v0, v0, 0x1
.line 449
if-ne v0, v12, :cond_dd
.line 450
const/4 v0, 0x0
.line 444
:cond_dd
add-int/lit8 v4, v4, 0x1
move/from16 v7, v24
move-object/from16 v8, v25
goto :goto_c9
.end local v24 # "d":Z
.end local v25 # "svq":Lio/reactivex/internal/fuseable/SimplePlainQueue;, "Lio/reactivex/internal/fuseable/SimplePlainQueue<TU;>;"
.restart local v7 # "d":Z
.restart local v8 # "svq":Lio/reactivex/internal/fuseable/SimplePlainQueue;, "Lio/reactivex/internal/fuseable/SimplePlainQueue<TU;>;"
:cond_e4
move/from16 v24, v7
move-object/from16 v25, v8
.line 453
.end local v4 # "i":I
.end local v7 # "d":Z
.end local v8 # "svq":Lio/reactivex/internal/fuseable/SimplePlainQueue;, "Lio/reactivex/internal/fuseable/SimplePlainQueue<TU;>;"
.restart local v24 # "d":Z
.restart local v25 # "svq":Lio/reactivex/internal/fuseable/SimplePlainQueue;, "Lio/reactivex/internal/fuseable/SimplePlainQueue<TU;>;"
:goto_e8
move v15, v0
.line 454
iput v0, v1, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->lastIndex:I
.line 455
aget-object v4, v11, v0
iget-wide v4, v4, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;->id:J
iput-wide v4, v1, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->lastId:J
.line 458
.end local v0 # "j":I
:goto_f1
move v0, v15
.line 460
.restart local v0 # "j":I
const/4 v4, 0x0
move v5, v4
move v4, v0
.end local v0 # "j":I
.local v4, "j":I
.local v5, "i":I
:goto_f5
if-ge v5, v12, :cond_1ed
.line 461
invoke-virtual/range {p0 .. p0}, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->checkTerminate()Z
move-result v0
if-eqz v0, :cond_fe
.line 462
return-void
.line 465
:cond_fe
aget-object v7, v11, v4
.line 467
.local v7, "is":Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;, "Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber<TT;TU;>;"
const/4 v0, 0x0
.line 469
.local v0, "o":Ljava/lang/Object;, "TU;"
:goto_101
invoke-virtual/range {p0 .. p0}, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->checkTerminate()Z
move-result v8
if-eqz v8, :cond_108
.line 470
return-void
.line 472
:cond_108
iget-object v8, v7, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;->queue:Lio/reactivex/internal/fuseable/SimpleQueue;
.line 473
.local v8, "q":Lio/reactivex/internal/fuseable/SimpleQueue;, "Lio/reactivex/internal/fuseable/SimpleQueue<TU;>;"
if-nez v8, :cond_116
.line 474
move-object/from16 v30, v2
move/from16 v32, v5
move/from16 v31, v6
move-wide/from16 v28, v13
goto/16 :goto_1ac
.line 476
:cond_116
const-wide/16 v26, 0x0
move-wide/from16 v28, v13
move-wide/from16 v13, v26
move-wide/from16 v26, v22
move-object/from16 v22, v0
.line 477
.end local v0 # "o":Ljava/lang/Object;, "TU;"
.local v13, "produced":J
.local v22, "o":Ljava/lang/Object;, "TU;"
.local v26, "r":J
.local v28, "startId":J
:goto_120
const-wide/16 v18, 0x0
cmp-long v0, v26, v18
if-eqz v0, :cond_16c
.line 480
:try_start_126
invoke-interface {v8}, Lio/reactivex/internal/fuseable/SimpleQueue;->poll()Ljava/lang/Object;
move-result-object v0
:try_end_12a
.catchall {:try_start_126 .. :try_end_12a} :catchall_143
.line 492
.end local v22 # "o":Ljava/lang/Object;, "TU;"
.restart local v0 # "o":Ljava/lang/Object;, "TU;"
nop
.line 493
if-nez v0, :cond_130
.line 494
move-object/from16 v30, v2
goto :goto_170
.line 497
:cond_130
invoke-interface {v2, v0}, Lorg/reactivestreams/Subscriber;->onNext(Ljava/lang/Object;)V
.line 499
invoke-virtual/range {p0 .. p0}, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->checkTerminate()Z
move-result v22
if-eqz v22, :cond_13a
.line 500
return-void
.line 503
:cond_13a
const-wide/16 v16, 0x1
sub-long v26, v26, v16
.line 504
add-long v13, v13, v16
move-object/from16 v22, v0
goto :goto_120
.line 481
.end local v0 # "o":Ljava/lang/Object;, "TU;"
.restart local v22 # "o":Ljava/lang/Object;, "TU;"
:catchall_143
move-exception v0
move-object/from16 v23, v0
move-object/from16 v0, v23
.line 482
.local v0, "ex":Ljava/lang/Throwable;
invoke-static {v0}, Lio/reactivex/exceptions/Exceptions;->throwIfFatal(Ljava/lang/Throwable;)V
.line 483
invoke-virtual {v7}, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;->dispose()V
.line 484
move-object/from16 v30, v2
.end local v2 # "child":Lorg/reactivestreams/Subscriber;, "Lorg/reactivestreams/Subscriber<-TU;>;"
.local v30, "child":Lorg/reactivestreams/Subscriber;, "Lorg/reactivestreams/Subscriber<-TU;>;"
iget-object v2, v1, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->errs:Lio/reactivex/internal/util/AtomicThrowable;
invoke-virtual {v2, v0}, Lio/reactivex/internal/util/AtomicThrowable;->addThrowable(Ljava/lang/Throwable;)Z
.line 485
invoke-virtual/range {p0 .. p0}, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->checkTerminate()Z
move-result v2
if-eqz v2, :cond_15c
.line 486
return-void
.line 488
:cond_15c
invoke-virtual {v1, v7}, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->removeInner(Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;)V
.line 489
const/4 v2, 0x1
.line 490
.end local v21 # "innerCompleted":Z
.local v2, "innerCompleted":Z
add-int/lit8 v5, v5, 0x1
.line 491
move/from16 v21, v2
move/from16 v31, v6
move-wide/from16 v22, v26
const-wide/16 v13, 0x1
goto/16 :goto_1e3
.line 477
.end local v0 # "ex":Ljava/lang/Throwable;
.end local v30 # "child":Lorg/reactivestreams/Subscriber;, "Lorg/reactivestreams/Subscriber<-TU;>;"
.local v2, "child":Lorg/reactivestreams/Subscriber;, "Lorg/reactivestreams/Subscriber<-TU;>;"
.restart local v21 # "innerCompleted":Z
:cond_16c
move-object/from16 v30, v2
.end local v2 # "child":Lorg/reactivestreams/Subscriber;, "Lorg/reactivestreams/Subscriber<-TU;>;"
.restart local v30 # "child":Lorg/reactivestreams/Subscriber;, "Lorg/reactivestreams/Subscriber<-TU;>;"
move-object/from16 v0, v22
.line 506
.end local v22 # "o":Ljava/lang/Object;, "TU;"
.local v0, "o":Ljava/lang/Object;, "TU;"
:goto_170
const-wide/16 v18, 0x0
cmp-long v2, v13, v18
if-eqz v2, :cond_193
.line 507
if-nez v6, :cond_184
.line 508
iget-object v2, v1, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->requested:Ljava/util/concurrent/atomic/AtomicLong;
move/from16 v32, v5
move/from16 v31, v6
.end local v5 # "i":I
.end local v6 # "unbounded":Z
.local v31, "unbounded":Z
.local v32, "i":I
neg-long v5, v13
invoke-virtual {v2, v5, v6}, Ljava/util/concurrent/atomic/AtomicLong;->addAndGet(J)J
move-result-wide v5
.end local v26 # "r":J
.local v5, "r":J
goto :goto_18d
.line 510
.end local v31 # "unbounded":Z
.end local v32 # "i":I
.local v5, "i":I
.restart local v6 # "unbounded":Z
.restart local v26 # "r":J
:cond_184
move/from16 v32, v5
move/from16 v31, v6
.end local v5 # "i":I
.end local v6 # "unbounded":Z
.restart local v31 # "unbounded":Z
.restart local v32 # "i":I
const-wide v5, 0x7fffffffffffffffL
.line 512
.end local v26 # "r":J
.local v5, "r":J
:goto_18d
invoke-virtual {v7, v13, v14}, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;->requestMore(J)V
move-wide/from16 v22, v5
goto :goto_199
.line 506
.end local v31 # "unbounded":Z
.end local v32 # "i":I
.local v5, "i":I
.restart local v6 # "unbounded":Z
.restart local v26 # "r":J
:cond_193
move/from16 v32, v5
move/from16 v31, v6
.end local v5 # "i":I
.end local v6 # "unbounded":Z
.restart local v31 # "unbounded":Z
.restart local v32 # "i":I
move-wide/from16 v22, v26
.line 514
.end local v26 # "r":J
.local v22, "r":J
:goto_199
const-wide/16 v5, 0x0
cmp-long v2, v22, v5
if-eqz v2, :cond_1ac
if-nez v0, :cond_1a2
.line 515
goto :goto_1ac
.line 517
.end local v8 # "q":Lio/reactivex/internal/fuseable/SimpleQueue;, "Lio/reactivex/internal/fuseable/SimpleQueue<TU;>;"
.end local v13 # "produced":J
:cond_1a2
move-wide/from16 v13, v28
move-object/from16 v2, v30
move/from16 v6, v31
move/from16 v5, v32
goto/16 :goto_101
.line 518
:cond_1ac
:goto_1ac
iget-boolean v2, v7, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;->done:Z
.line 519
.local v2, "innerDone":Z
iget-object v5, v7, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;->queue:Lio/reactivex/internal/fuseable/SimpleQueue;
.line 520
.local v5, "innerQueue":Lio/reactivex/internal/fuseable/SimpleQueue;, "Lio/reactivex/internal/fuseable/SimpleQueue<TU;>;"
if-eqz v2, :cond_1ce
if-eqz v5, :cond_1be
invoke-interface {v5}, Lio/reactivex/internal/fuseable/SimpleQueue;->isEmpty()Z
move-result v6
if-eqz v6, :cond_1bb
goto :goto_1be
:cond_1bb
const-wide/16 v13, 0x1
goto :goto_1d0
.line 521
:cond_1be
:goto_1be
invoke-virtual {v1, v7}, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->removeInner(Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;)V
.line 522
invoke-virtual/range {p0 .. p0}, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->checkTerminate()Z
move-result v6
if-eqz v6, :cond_1c8
.line 523
return-void
.line 525
:cond_1c8
const-wide/16 v13, 0x1
add-long/2addr v9, v13
.line 526
const/16 v21, 0x1
goto :goto_1d0
.line 520
:cond_1ce
const-wide/16 v13, 0x1
.line 528
:goto_1d0
const-wide/16 v16, 0x0
cmp-long v6, v22, v16
if-nez v6, :cond_1d9
.line 529
move/from16 v0, v21
goto :goto_1f7
.line 532
:cond_1d9
add-int/lit8 v4, v4, 0x1
.line 533
if-ne v4, v12, :cond_1e1
.line 534
const/4 v4, 0x0
move/from16 v5, v32
goto :goto_1e3
.line 533
:cond_1e1
move/from16 v5, v32
.line 460
.end local v0 # "o":Ljava/lang/Object;, "TU;"
.end local v2 # "innerDone":Z
.end local v7 # "is":Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;, "Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber<TT;TU;>;"
.end local v32 # "i":I
.local v5, "i":I
:goto_1e3
const/4 v2, 0x1
add-int/2addr v5, v2
move-wide/from16 v13, v28
move-object/from16 v2, v30
move/from16 v6, v31
goto/16 :goto_f5
.end local v28 # "startId":J
.end local v30 # "child":Lorg/reactivestreams/Subscriber;, "Lorg/reactivestreams/Subscriber<-TU;>;"
.end local v31 # "unbounded":Z
.local v2, "child":Lorg/reactivestreams/Subscriber;, "Lorg/reactivestreams/Subscriber<-TU;>;"
.restart local v6 # "unbounded":Z
.local v13, "startId":J
:cond_1ed
move-object/from16 v30, v2
move/from16 v32, v5
move/from16 v31, v6
move-wide/from16 v28, v13
.end local v2 # "child":Lorg/reactivestreams/Subscriber;, "Lorg/reactivestreams/Subscriber<-TU;>;"
.end local v5 # "i":I
.end local v6 # "unbounded":Z
.end local v13 # "startId":J
.restart local v28 # "startId":J
.restart local v30 # "child":Lorg/reactivestreams/Subscriber;, "Lorg/reactivestreams/Subscriber<-TU;>;"
.restart local v31 # "unbounded":Z
.restart local v32 # "i":I
move/from16 v0, v21
.line 537
.end local v21 # "innerCompleted":Z
.end local v32 # "i":I
.local v0, "innerCompleted":Z
:goto_1f7
iput v4, v1, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->lastIndex:I
.line 538
aget-object v2, v11, v4
iget-wide v5, v2, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;->id:J
iput-wide v5, v1, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->lastId:J
move-wide/from16 v4, v22
goto :goto_20e
.line 435
.end local v15 # "index":I
.end local v22 # "r":J
.end local v24 # "d":Z
.end local v25 # "svq":Lio/reactivex/internal/fuseable/SimplePlainQueue;, "Lio/reactivex/internal/fuseable/SimplePlainQueue<TU;>;"
.end local v28 # "startId":J
.end local v30 # "child":Lorg/reactivestreams/Subscriber;, "Lorg/reactivestreams/Subscriber<-TU;>;"
.end local v31 # "unbounded":Z
.restart local v2 # "child":Lorg/reactivestreams/Subscriber;, "Lorg/reactivestreams/Subscriber<-TU;>;"
.local v4, "r":J
.restart local v6 # "unbounded":Z
.local v7, "d":Z
.local v8, "svq":Lio/reactivex/internal/fuseable/SimplePlainQueue;, "Lio/reactivex/internal/fuseable/SimplePlainQueue<TU;>;"
:cond_202
move/from16 v21, v0
move-object/from16 v30, v2
move-wide/from16 v22, v4
move/from16 v31, v6
move/from16 v24, v7
move-object/from16 v25, v8
.line 541
.end local v2 # "child":Lorg/reactivestreams/Subscriber;, "Lorg/reactivestreams/Subscriber<-TU;>;"
.end local v6 # "unbounded":Z
.end local v7 # "d":Z
.end local v8 # "svq":Lio/reactivex/internal/fuseable/SimplePlainQueue;, "Lio/reactivex/internal/fuseable/SimplePlainQueue<TU;>;"
.restart local v24 # "d":Z
.restart local v25 # "svq":Lio/reactivex/internal/fuseable/SimplePlainQueue;, "Lio/reactivex/internal/fuseable/SimplePlainQueue<TU;>;"
.restart local v30 # "child":Lorg/reactivestreams/Subscriber;, "Lorg/reactivestreams/Subscriber<-TU;>;"
.restart local v31 # "unbounded":Z
:goto_20e
const-wide/16 v6, 0x0
cmp-long v2, v9, v6
if-eqz v2, :cond_21d
iget-boolean v2, v1, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->cancelled:Z
if-nez v2, :cond_21d
.line 542
iget-object v2, v1, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->s:Lorg/reactivestreams/Subscription;
invoke-interface {v2, v9, v10}, Lorg/reactivestreams/Subscription;->request(J)V
.line 544
:cond_21d
if-eqz v0, :cond_223
.line 545
move-object/from16 v2, v30
goto/16 :goto_6
.line 547
:cond_223
neg-int v2, v3
invoke-virtual {v1, v2}, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->addAndGet(I)I
move-result v3
.line 548
if-nez v3, :cond_22c
.line 549
nop
.line 552
.end local v0 # "innerCompleted":Z
.end local v4 # "r":J
.end local v9 # "replenishMain":J
.end local v11 # "inner":[Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;, "[Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber<**>;"
.end local v12 # "n":I
.end local v24 # "d":Z
.end local v25 # "svq":Lio/reactivex/internal/fuseable/SimplePlainQueue;, "Lio/reactivex/internal/fuseable/SimplePlainQueue<TU;>;"
.end local v31 # "unbounded":Z
return-void
.line 551
:cond_22c
move-object/from16 v2, v30
goto/16 :goto_6
.end method
.method getInnerQueue(Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;)Lio/reactivex/internal/fuseable/SimpleQueue;
.registers 5
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber<",
"TT;TU;>;)",
"Lio/reactivex/internal/fuseable/SimpleQueue<",
"TU;>;"
}
.end annotation
.line 269
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;, "Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber<TT;TU;>;"
.local p1, "inner":Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;, "Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber<TT;TU;>;"
iget-object v0, p1, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;->queue:Lio/reactivex/internal/fuseable/SimpleQueue;
.line 270
.local v0, "q":Lio/reactivex/internal/fuseable/SimpleQueue;, "Lio/reactivex/internal/fuseable/SimpleQueue<TU;>;"
if-nez v0, :cond_e
.line 271
new-instance v1, Lio/reactivex/internal/queue/SpscArrayQueue;
iget v2, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->bufferSize:I
invoke-direct {v1, v2}, Lio/reactivex/internal/queue/SpscArrayQueue;-><init>(I)V
move-object v0, v1
.line 272
iput-object v0, p1, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;->queue:Lio/reactivex/internal/fuseable/SimpleQueue;
.line 274
:cond_e
return-object v0
.end method
.method getMainQueue()Lio/reactivex/internal/fuseable/SimpleQueue;
.registers 4
.annotation system Ldalvik/annotation/Signature;
value = {
"()",
"Lio/reactivex/internal/fuseable/SimpleQueue<",
"TU;>;"
}
.end annotation
.line 217
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;, "Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber<TT;TU;>;"
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->queue:Lio/reactivex/internal/fuseable/SimplePlainQueue;
.line 218
.local v0, "q":Lio/reactivex/internal/fuseable/SimplePlainQueue;, "Lio/reactivex/internal/fuseable/SimplePlainQueue<TU;>;"
if-nez v0, :cond_1e
.line 219
iget v1, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->maxConcurrency:I
const v2, 0x7fffffff
if-ne v1, v2, :cond_14
.line 220
new-instance v1, Lio/reactivex/internal/queue/SpscLinkedArrayQueue;
iget v2, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->bufferSize:I
invoke-direct {v1, v2}, Lio/reactivex/internal/queue/SpscLinkedArrayQueue;-><init>(I)V
move-object v0, v1
goto :goto_1c
.line 222
:cond_14
new-instance v1, Lio/reactivex/internal/queue/SpscArrayQueue;
iget v2, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->maxConcurrency:I
invoke-direct {v1, v2}, Lio/reactivex/internal/queue/SpscArrayQueue;-><init>(I)V
move-object v0, v1
.line 224
:goto_1c
iput-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->queue:Lio/reactivex/internal/fuseable/SimplePlainQueue;
.line 226
:cond_1e
return-object v0
.end method
.method innerError(Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;Ljava/lang/Throwable;)V
.registers 7
.param p2, "t" # Ljava/lang/Throwable;
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber<",
"TT;TU;>;",
"Ljava/lang/Throwable;",
")V"
}
.end annotation
.line 594
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;, "Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber<TT;TU;>;"
.local p1, "inner":Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;, "Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber<TT;TU;>;"
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->errs:Lio/reactivex/internal/util/AtomicThrowable;
invoke-virtual {v0, p2}, Lio/reactivex/internal/util/AtomicThrowable;->addThrowable(Ljava/lang/Throwable;)Z
move-result v0
if-eqz v0, :cond_2e
.line 595
const/4 v0, 0x1
iput-boolean v0, p1, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;->done:Z
.line 596
iget-boolean v0, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->delayErrors:Z
if-nez v0, :cond_2a
.line 597
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->s:Lorg/reactivestreams/Subscription;
invoke-interface {v0}, Lorg/reactivestreams/Subscription;->cancel()V
.line 598
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->subscribers:Ljava/util/concurrent/atomic/AtomicReference;
sget-object v1, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->CANCELLED:[Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;
invoke-virtual {v0, v1}, Ljava/util/concurrent/atomic/AtomicReference;->getAndSet(Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v0
check-cast v0, [Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;
array-length v1, v0
const/4 v2, 0x0
:goto_20
if-ge v2, v1, :cond_2a
aget-object v3, v0, v2
.line 599
.local v3, "a":Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;, "Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber<**>;"
invoke-virtual {v3}, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;->dispose()V
.line 598
.end local v3 # "a":Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;, "Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber<**>;"
add-int/lit8 v2, v2, 0x1
goto :goto_20
.line 602
:cond_2a
invoke-virtual {p0}, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->drain()V
goto :goto_31
.line 604
:cond_2e
invoke-static {p2}, Lio/reactivex/plugins/RxJavaPlugins;->onError(Ljava/lang/Throwable;)V
.line 606
:goto_31
return-void
.end method
.method public onComplete()V
.registers 2
.line 334
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;, "Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber<TT;TU;>;"
iget-boolean v0, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->done:Z
if-eqz v0, :cond_5
.line 335
return-void
.line 337
:cond_5
const/4 v0, 0x1
iput-boolean v0, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->done:Z
.line 338
invoke-virtual {p0}, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->drain()V
.line 339
return-void
.end method
.method public onError(Ljava/lang/Throwable;)V
.registers 3
.param p1, "t" # Ljava/lang/Throwable;
.line 319
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;, "Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber<TT;TU;>;"
iget-boolean v0, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->done:Z
if-eqz v0, :cond_8
.line 320
invoke-static {p1}, Lio/reactivex/plugins/RxJavaPlugins;->onError(Ljava/lang/Throwable;)V
.line 321
return-void
.line 323
:cond_8
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->errs:Lio/reactivex/internal/util/AtomicThrowable;
invoke-virtual {v0, p1}, Lio/reactivex/internal/util/AtomicThrowable;->addThrowable(Ljava/lang/Throwable;)Z
move-result v0
if-eqz v0, :cond_17
.line 324
const/4 v0, 0x1
iput-boolean v0, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->done:Z
.line 325
invoke-virtual {p0}, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->drain()V
goto :goto_1a
.line 327
:cond_17
invoke-static {p1}, Lio/reactivex/plugins/RxJavaPlugins;->onError(Ljava/lang/Throwable;)V
.line 329
:goto_1a
return-void
.end method
.method public onNext(Ljava/lang/Object;)V
.registers 8
.annotation system Ldalvik/annotation/Signature;
value = {
"(TT;)V"
}
.end annotation
.line 127
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;, "Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber<TT;TU;>;"
.local p1, "t":Ljava/lang/Object;, "TT;"
iget-boolean v0, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->done:Z
if-eqz v0, :cond_5
.line 128
return-void
.line 132
:cond_5
:try_start_5
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->mapper:Lio/reactivex/functions/Function;
invoke-interface {v0, p1}, Lio/reactivex/functions/Function;->apply(Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v0
const-string v1, "The mapper returned a null Publisher"
invoke-static {v0, v1}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
move-result-object v0
check-cast v0, Lorg/reactivestreams/Publisher;
:try_end_13
.catchall {:try_start_5 .. :try_end_13} :catchall_68
.line 138
.local v0, "p":Lorg/reactivestreams/Publisher;, "Lorg/reactivestreams/Publisher<+TU;>;"
nop
.line 139
instance-of v1, v0, Ljava/util/concurrent/Callable;
if-eqz v1, :cond_52
.line 143
:try_start_18
move-object v1, v0
check-cast v1, Ljava/util/concurrent/Callable;
invoke-interface {v1}, Ljava/util/concurrent/Callable;->call()Ljava/lang/Object;
move-result-object v1
:try_end_1f
.catchall {:try_start_18 .. :try_end_1f} :catchall_45
.line 149
.local v1, "u":Ljava/lang/Object;, "TU;"
nop
.line 151
if-eqz v1, :cond_26
.line 152
invoke-virtual {p0, v1}, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->tryEmitScalar(Ljava/lang/Object;)V
goto :goto_44
.line 154
:cond_26
iget v2, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->maxConcurrency:I
const v3, 0x7fffffff
if-eq v2, v3, :cond_44
iget-boolean v2, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->cancelled:Z
if-nez v2, :cond_44
iget v2, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->scalarEmitted:I
add-int/lit8 v2, v2, 0x1
iput v2, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->scalarEmitted:I
iget v3, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->scalarLimit:I
if-ne v2, v3, :cond_44
.line 156
const/4 v2, 0x0
iput v2, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->scalarEmitted:I
.line 157
iget-object v2, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->s:Lorg/reactivestreams/Subscription;
int-to-long v3, v3
invoke-interface {v2, v3, v4}, Lorg/reactivestreams/Subscription;->request(J)V
.line 160
.end local v1 # "u":Ljava/lang/Object;, "TU;"
:cond_44
:goto_44
goto :goto_67
.line 144
:catchall_45
move-exception v1
.line 145
.local v1, "ex":Ljava/lang/Throwable;
invoke-static {v1}, Lio/reactivex/exceptions/Exceptions;->throwIfFatal(Ljava/lang/Throwable;)V
.line 146
iget-object v2, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->errs:Lio/reactivex/internal/util/AtomicThrowable;
invoke-virtual {v2, v1}, Lio/reactivex/internal/util/AtomicThrowable;->addThrowable(Ljava/lang/Throwable;)Z
.line 147
invoke-virtual {p0}, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->drain()V
.line 148
return-void
.line 161
.end local v1 # "ex":Ljava/lang/Throwable;
:cond_52
new-instance v1, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;
iget-wide v2, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->uniqueId:J
const-wide/16 v4, 0x1
add-long/2addr v4, v2
iput-wide v4, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->uniqueId:J
invoke-direct {v1, p0, v2, v3}, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;-><init>(Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;J)V
.line 162
.local v1, "inner":Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;, "Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber<TT;TU;>;"
invoke-virtual {p0, v1}, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->addInner(Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;)Z
move-result v2
if-eqz v2, :cond_67
.line 163
invoke-interface {v0, v1}, Lorg/reactivestreams/Publisher;->subscribe(Lorg/reactivestreams/Subscriber;)V
.line 166
.end local v1 # "inner":Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;, "Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber<TT;TU;>;"
:cond_67
:goto_67
return-void
.line 133
.end local v0 # "p":Lorg/reactivestreams/Publisher;, "Lorg/reactivestreams/Publisher<+TU;>;"
:catchall_68
move-exception v0
.line 134
.local v0, "e":Ljava/lang/Throwable;
invoke-static {v0}, Lio/reactivex/exceptions/Exceptions;->throwIfFatal(Ljava/lang/Throwable;)V
.line 135
iget-object v1, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->s:Lorg/reactivestreams/Subscription;
invoke-interface {v1}, Lorg/reactivestreams/Subscription;->cancel()V
.line 136
invoke-virtual {p0, v0}, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->onError(Ljava/lang/Throwable;)V
.line 137
return-void
.end method
.method public onSubscribe(Lorg/reactivestreams/Subscription;)V
.registers 4
.param p1, "s" # Lorg/reactivestreams/Subscription;
.line 110
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;, "Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber<TT;TU;>;"
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->s:Lorg/reactivestreams/Subscription;
invoke-static {v0, p1}, Lio/reactivex/internal/subscriptions/SubscriptionHelper;->validate(Lorg/reactivestreams/Subscription;Lorg/reactivestreams/Subscription;)Z
move-result v0
if-eqz v0, :cond_27
.line 111
iput-object p1, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->s:Lorg/reactivestreams/Subscription;
.line 112
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->actual:Lorg/reactivestreams/Subscriber;
invoke-interface {v0, p0}, Lorg/reactivestreams/Subscriber;->onSubscribe(Lorg/reactivestreams/Subscription;)V
.line 113
iget-boolean v0, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->cancelled:Z
if-nez v0, :cond_27
.line 114
iget v0, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->maxConcurrency:I
const v1, 0x7fffffff
if-ne v0, v1, :cond_23
.line 115
const-wide v0, 0x7fffffffffffffffL
invoke-interface {p1, v0, v1}, Lorg/reactivestreams/Subscription;->request(J)V
goto :goto_27
.line 117
:cond_23
int-to-long v0, v0
invoke-interface {p1, v0, v1}, Lorg/reactivestreams/Subscription;->request(J)V
.line 121
:cond_27
:goto_27
return-void
.end method
.method removeInner(Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;)V
.registers 9
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber<",
"TT;TU;>;)V"
}
.end annotation
.line 187
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;, "Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber<TT;TU;>;"
.local p1, "inner":Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;, "Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber<TT;TU;>;"
:goto_0
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->subscribers: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/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;
.line 188
.local v0, "a":[Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;, "[Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber<**>;"
sget-object v1, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->CANCELLED:[Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;
if-eq v0, v1, :cond_43
sget-object v1, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->EMPTY:[Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;
if-ne v0, v1, :cond_11
goto :goto_43
.line 191
:cond_11
array-length v1, v0
.line 192
.local v1, "n":I
const/4 v2, -0x1
.line 193
.local v2, "j":I
const/4 v3, 0x0
.local v3, "i":I
:goto_14
if-ge v3, v1, :cond_1f
.line 194
aget-object v4, v0, v3
if-ne v4, p1, :cond_1c
.line 195
move v2, v3
.line 196
goto :goto_1f
.line 193
:cond_1c
add-int/lit8 v3, v3, 0x1
goto :goto_14
.line 199
.end local v3 # "i":I
:cond_1f
:goto_1f
if-gez v2, :cond_22
.line 200
return-void
.line 203
:cond_22
const/4 v3, 0x1
if-ne v1, v3, :cond_28
.line 204
sget-object v3, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->EMPTY:[Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;
.local v3, "b":[Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;, "[Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber<**>;"
goto :goto_39
.line 206
.end local v3 # "b":[Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;, "[Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber<**>;"
:cond_28
add-int/lit8 v4, v1, -0x1
new-array v4, v4, [Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;
.line 207
.local v4, "b":[Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;, "[Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber<**>;"
const/4 v5, 0x0
invoke-static {v0, v5, v4, v5, v2}, Ljava/lang/System;->arraycopy(Ljava/lang/Object;ILjava/lang/Object;II)V
.line 208
add-int/lit8 v5, v2, 0x1
sub-int v6, v1, v2
sub-int/2addr v6, v3
invoke-static {v0, v5, v4, v2, v6}, Ljava/lang/System;->arraycopy(Ljava/lang/Object;ILjava/lang/Object;II)V
move-object v3, v4
.line 210
.end local v4 # "b":[Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;, "[Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber<**>;"
.restart local v3 # "b":[Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;, "[Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber<**>;"
:goto_39
iget-object v4, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->subscribers:Ljava/util/concurrent/atomic/AtomicReference;
invoke-virtual {v4, v0, v3}, Ljava/util/concurrent/atomic/AtomicReference;->compareAndSet(Ljava/lang/Object;Ljava/lang/Object;)Z
move-result v4
if-eqz v4, :cond_42
.line 211
return-void
.line 213
.end local v0 # "a":[Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;, "[Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber<**>;"
.end local v1 # "n":I
.end local v2 # "j":I
.end local v3 # "b":[Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;, "[Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber<**>;"
:cond_42
goto :goto_0
.line 189
.restart local v0 # "a":[Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;, "[Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber<**>;"
:cond_43
:goto_43
return-void
.end method
.method public request(J)V
.registers 4
.param p1, "n" # J
.line 343
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;, "Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber<TT;TU;>;"
invoke-static {p1, p2}, Lio/reactivex/internal/subscriptions/SubscriptionHelper;->validate(J)Z
move-result v0
if-eqz v0, :cond_e
.line 344
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->requested:Ljava/util/concurrent/atomic/AtomicLong;
invoke-static {v0, p1, p2}, Lio/reactivex/internal/util/BackpressureHelper;->add(Ljava/util/concurrent/atomic/AtomicLong;J)J
.line 345
invoke-virtual {p0}, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->drain()V
.line 347
:cond_e
return-void
.end method
.method tryEmit(Ljava/lang/Object;Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;)V
.registers 10
.annotation system Ldalvik/annotation/Signature;
value = {
"(TU;",
"Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber<",
"TT;TU;>;)V"
}
.end annotation
.line 278
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;, "Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber<TT;TU;>;"
.local p1, "value":Ljava/lang/Object;, "TU;"
.local p2, "inner":Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;, "Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber<TT;TU;>;"
invoke-virtual {p0}, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->get()I
move-result v0
const-string v1, "Inner queue full?!"
if-nez v0, :cond_5c
const/4 v0, 0x0
const/4 v2, 0x1
invoke-virtual {p0, v0, v2}, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->compareAndSet(II)Z
move-result v0
if-eqz v0, :cond_5c
.line 279
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->requested:Ljava/util/concurrent/atomic/AtomicLong;
invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicLong;->get()J
move-result-wide v2
.line 280
.local v2, "r":J
iget-object v0, p2, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;->queue:Lio/reactivex/internal/fuseable/SimpleQueue;
.line 281
.local v0, "q":Lio/reactivex/internal/fuseable/SimpleQueue;, "Lio/reactivex/internal/fuseable/SimpleQueue<TU;>;"
const-wide/16 v4, 0x0
cmp-long v6, v2, v4
if-eqz v6, :cond_3f
if-eqz v0, :cond_26
invoke-interface {v0}, Lio/reactivex/internal/fuseable/SimpleQueue;->isEmpty()Z
move-result v4
if-eqz v4, :cond_3f
.line 282
:cond_26
iget-object v1, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->actual:Lorg/reactivestreams/Subscriber;
invoke-interface {v1, p1}, Lorg/reactivestreams/Subscriber;->onNext(Ljava/lang/Object;)V
.line 283
const-wide v4, 0x7fffffffffffffffL
cmp-long v1, v2, v4
if-eqz v1, :cond_39
.line 284
iget-object v1, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->requested:Ljava/util/concurrent/atomic/AtomicLong;
invoke-virtual {v1}, Ljava/util/concurrent/atomic/AtomicLong;->decrementAndGet()J
.line 286
:cond_39
const-wide/16 v4, 0x1
invoke-virtual {p2, v4, v5}, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;->requestMore(J)V
goto :goto_54
.line 288
:cond_3f
if-nez v0, :cond_45
.line 289
invoke-virtual {p0, p2}, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->getInnerQueue(Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;)Lio/reactivex/internal/fuseable/SimpleQueue;
move-result-object v0
.line 291
:cond_45
invoke-interface {v0, p1}, Lio/reactivex/internal/fuseable/SimpleQueue;->offer(Ljava/lang/Object;)Z
move-result v4
if-nez v4, :cond_54
.line 292
new-instance v4, Lio/reactivex/exceptions/MissingBackpressureException;
invoke-direct {v4, v1}, Lio/reactivex/exceptions/MissingBackpressureException;-><init>(Ljava/lang/String;)V
invoke-virtual {p0, v4}, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->onError(Ljava/lang/Throwable;)V
.line 293
return-void
.line 296
:cond_54
:goto_54
invoke-virtual {p0}, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->decrementAndGet()I
move-result v1
if-nez v1, :cond_5b
.line 297
return-void
.line 299
.end local v0 # "q":Lio/reactivex/internal/fuseable/SimpleQueue;, "Lio/reactivex/internal/fuseable/SimpleQueue<TU;>;"
.end local v2 # "r":J
:cond_5b
goto :goto_80
.line 300
:cond_5c
iget-object v0, p2, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;->queue:Lio/reactivex/internal/fuseable/SimpleQueue;
.line 301
.restart local v0 # "q":Lio/reactivex/internal/fuseable/SimpleQueue;, "Lio/reactivex/internal/fuseable/SimpleQueue<TU;>;"
if-nez v0, :cond_6a
.line 302
new-instance v2, Lio/reactivex/internal/queue/SpscArrayQueue;
iget v3, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->bufferSize:I
invoke-direct {v2, v3}, Lio/reactivex/internal/queue/SpscArrayQueue;-><init>(I)V
move-object v0, v2
.line 303
iput-object v0, p2, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$InnerSubscriber;->queue:Lio/reactivex/internal/fuseable/SimpleQueue;
.line 305
:cond_6a
invoke-interface {v0, p1}, Lio/reactivex/internal/fuseable/SimpleQueue;->offer(Ljava/lang/Object;)Z
move-result v2
if-nez v2, :cond_79
.line 306
new-instance v2, Lio/reactivex/exceptions/MissingBackpressureException;
invoke-direct {v2, v1}, Lio/reactivex/exceptions/MissingBackpressureException;-><init>(Ljava/lang/String;)V
invoke-virtual {p0, v2}, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->onError(Ljava/lang/Throwable;)V
.line 307
return-void
.line 309
:cond_79
invoke-virtual {p0}, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->getAndIncrement()I
move-result v1
if-eqz v1, :cond_80
.line 310
return-void
.line 313
.end local v0 # "q":Lio/reactivex/internal/fuseable/SimpleQueue;, "Lio/reactivex/internal/fuseable/SimpleQueue<TU;>;"
:cond_80
:goto_80
invoke-virtual {p0}, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->drainLoop()V
.line 314
return-void
.end method
.method tryEmitScalar(Ljava/lang/Object;)V
.registers 11
.annotation system Ldalvik/annotation/Signature;
value = {
"(TU;)V"
}
.end annotation
.line 230
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;, "Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber<TT;TU;>;"
.local p1, "value":Ljava/lang/Object;, "TU;"
invoke-virtual {p0}, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->get()I
move-result v0
const-string v1, "Scalar queue full?!"
if-nez v0, :cond_73
const/4 v0, 0x1
const/4 v2, 0x0
invoke-virtual {p0, v2, v0}, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->compareAndSet(II)Z
move-result v3
if-eqz v3, :cond_73
.line 231
iget-object v3, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->requested:Ljava/util/concurrent/atomic/AtomicLong;
invoke-virtual {v3}, Ljava/util/concurrent/atomic/AtomicLong;->get()J
move-result-wide v3
.line 232
.local v3, "r":J
iget-object v5, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->queue:Lio/reactivex/internal/fuseable/SimplePlainQueue;
.line 233
.local v5, "q":Lio/reactivex/internal/fuseable/SimpleQueue;, "Lio/reactivex/internal/fuseable/SimpleQueue<TU;>;"
const-wide/16 v6, 0x0
cmp-long v8, v3, v6
if-eqz v8, :cond_56
if-eqz v5, :cond_26
invoke-interface {v5}, Lio/reactivex/internal/fuseable/SimpleQueue;->isEmpty()Z
move-result v6
if-eqz v6, :cond_56
.line 234
:cond_26
iget-object v1, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->actual:Lorg/reactivestreams/Subscriber;
invoke-interface {v1, p1}, Lorg/reactivestreams/Subscriber;->onNext(Ljava/lang/Object;)V
.line 235
const-wide v6, 0x7fffffffffffffffL
cmp-long v1, v3, v6
if-eqz v1, :cond_39
.line 236
iget-object v1, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->requested:Ljava/util/concurrent/atomic/AtomicLong;
invoke-virtual {v1}, Ljava/util/concurrent/atomic/AtomicLong;->decrementAndGet()J
.line 238
:cond_39
iget v1, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->maxConcurrency:I
const v6, 0x7fffffff
if-eq v1, v6, :cond_6b
iget-boolean v1, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->cancelled:Z
if-nez v1, :cond_6b
iget v1, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->scalarEmitted:I
add-int/2addr v1, v0
iput v1, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->scalarEmitted:I
iget v0, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->scalarLimit:I
if-ne v1, v0, :cond_6b
.line 240
iput v2, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->scalarEmitted:I
.line 241
iget-object v1, p0, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->s:Lorg/reactivestreams/Subscription;
int-to-long v6, v0
invoke-interface {v1, v6, v7}, Lorg/reactivestreams/Subscription;->request(J)V
goto :goto_6b
.line 244
:cond_56
if-nez v5, :cond_5c
.line 245
invoke-virtual {p0}, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->getMainQueue()Lio/reactivex/internal/fuseable/SimpleQueue;
move-result-object v5
.line 247
:cond_5c
invoke-interface {v5, p1}, Lio/reactivex/internal/fuseable/SimpleQueue;->offer(Ljava/lang/Object;)Z
move-result v0
if-nez v0, :cond_6b
.line 248
new-instance v0, Ljava/lang/IllegalStateException;
invoke-direct {v0, v1}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
invoke-virtual {p0, v0}, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->onError(Ljava/lang/Throwable;)V
.line 249
return-void
.line 252
:cond_6b
:goto_6b
invoke-virtual {p0}, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->decrementAndGet()I
move-result v0
if-nez v0, :cond_72
.line 253
return-void
.line 255
.end local v3 # "r":J
.end local v5 # "q":Lio/reactivex/internal/fuseable/SimpleQueue;, "Lio/reactivex/internal/fuseable/SimpleQueue<TU;>;"
:cond_72
goto :goto_8d
.line 256
:cond_73
invoke-virtual {p0}, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->getMainQueue()Lio/reactivex/internal/fuseable/SimpleQueue;
move-result-object v0
.line 257
.local v0, "q":Lio/reactivex/internal/fuseable/SimpleQueue;, "Lio/reactivex/internal/fuseable/SimpleQueue<TU;>;"
invoke-interface {v0, p1}, Lio/reactivex/internal/fuseable/SimpleQueue;->offer(Ljava/lang/Object;)Z
move-result v2
if-nez v2, :cond_86
.line 258
new-instance v2, Ljava/lang/IllegalStateException;
invoke-direct {v2, v1}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
invoke-virtual {p0, v2}, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->onError(Ljava/lang/Throwable;)V
.line 259
return-void
.line 261
:cond_86
invoke-virtual {p0}, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->getAndIncrement()I
move-result v1
if-eqz v1, :cond_8d
.line 262
return-void
.line 265
.end local v0 # "q":Lio/reactivex/internal/fuseable/SimpleQueue;, "Lio/reactivex/internal/fuseable/SimpleQueue<TU;>;"
:cond_8d
:goto_8d
invoke-virtual {p0}, Lio/reactivex/internal/operators/flowable/FlowableFlatMap$MergeSubscriber;->drainLoop()V
.line 266
return-void
.end method