FlowableCombineLatest$CombineLatestCoordinator.smali
.class final Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;
.super Lio/reactivex/internal/subscriptions/BasicIntQueueSubscription;
.source "FlowableCombineLatest.java"
# annotations
.annotation system Ldalvik/annotation/EnclosingClass;
value = Lio/reactivex/internal/operators/flowable/FlowableCombineLatest;
.end annotation
.annotation system Ldalvik/annotation/InnerClass;
accessFlags = 0x18
name = "CombineLatestCoordinator"
.end annotation
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
"R:",
"Ljava/lang/Object;",
">",
"Lio/reactivex/internal/subscriptions/BasicIntQueueSubscription<",
"TR;>;"
}
.end annotation
# static fields
.field private static final serialVersionUID:J = -0x4687de9589e4abbdL
# instance fields
.field final actual:Lorg/reactivestreams/Subscriber;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lorg/reactivestreams/Subscriber<",
"-TR;>;"
}
.end annotation
.end field
.field volatile cancelled:Z
.field final combiner:Lio/reactivex/functions/Function;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/functions/Function<",
"-[",
"Ljava/lang/Object;",
"+TR;>;"
}
.end annotation
.end field
.field completedSources:I
.field final delayErrors:Z
.field volatile done:Z
.field final error:Ljava/util/concurrent/atomic/AtomicReference;
.annotation system Ldalvik/annotation/Signature;
value = {
"Ljava/util/concurrent/atomic/AtomicReference<",
"Ljava/lang/Throwable;",
">;"
}
.end annotation
.end field
.field final latest:[Ljava/lang/Object;
.field nonEmptySources:I
.field outputFused:Z
.field final queue:Lio/reactivex/internal/queue/SpscLinkedArrayQueue;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/internal/queue/SpscLinkedArrayQueue<",
"Ljava/lang/Object;",
">;"
}
.end annotation
.end field
.field final requested:Ljava/util/concurrent/atomic/AtomicLong;
.field final subscribers:[Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestInnerSubscriber;
.annotation system Ldalvik/annotation/Signature;
value = {
"[",
"Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestInnerSubscriber<",
"TT;>;"
}
.end annotation
.end field
# direct methods
.method static constructor <clinit>()V
.registers 1
return-void
.end method
.method constructor <init>(Lorg/reactivestreams/Subscriber;Lio/reactivex/functions/Function;IIZ)V
.registers 9
.param p3, "n" # I
.param p4, "bufferSize" # I
.param p5, "delayErrors" # Z
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lorg/reactivestreams/Subscriber<",
"-TR;>;",
"Lio/reactivex/functions/Function<",
"-[",
"Ljava/lang/Object;",
"+TR;>;IIZ)V"
}
.end annotation
.line 182
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;, "Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator<TT;TR;>;"
.local p1, "actual":Lorg/reactivestreams/Subscriber;, "Lorg/reactivestreams/Subscriber<-TR;>;"
.local p2, "combiner":Lio/reactivex/functions/Function;, "Lio/reactivex/functions/Function<-[Ljava/lang/Object;+TR;>;"
invoke-direct {p0}, Lio/reactivex/internal/subscriptions/BasicIntQueueSubscription;-><init>()V
.line 183
iput-object p1, p0, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->actual:Lorg/reactivestreams/Subscriber;
.line 184
iput-object p2, p0, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->combiner:Lio/reactivex/functions/Function;
.line 186
new-array v0, p3, [Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestInnerSubscriber;
.line 187
.local v0, "a":[Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestInnerSubscriber;, "[Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestInnerSubscriber<TT;>;"
const/4 v1, 0x0
.local v1, "i":I
:goto_a
if-ge v1, p3, :cond_16
.line 188
new-instance v2, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestInnerSubscriber;
invoke-direct {v2, p0, v1, p4}, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestInnerSubscriber;-><init>(Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;II)V
aput-object v2, v0, v1
.line 187
add-int/lit8 v1, v1, 0x1
goto :goto_a
.line 190
.end local v1 # "i":I
:cond_16
iput-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->subscribers:[Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestInnerSubscriber;
.line 191
new-array v1, p3, [Ljava/lang/Object;
iput-object v1, p0, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->latest:[Ljava/lang/Object;
.line 192
new-instance v1, Lio/reactivex/internal/queue/SpscLinkedArrayQueue;
invoke-direct {v1, p4}, Lio/reactivex/internal/queue/SpscLinkedArrayQueue;-><init>(I)V
iput-object v1, p0, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->queue:Lio/reactivex/internal/queue/SpscLinkedArrayQueue;
.line 193
new-instance v1, Ljava/util/concurrent/atomic/AtomicLong;
invoke-direct {v1}, Ljava/util/concurrent/atomic/AtomicLong;-><init>()V
iput-object v1, p0, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->requested:Ljava/util/concurrent/atomic/AtomicLong;
.line 194
new-instance v1, Ljava/util/concurrent/atomic/AtomicReference;
invoke-direct {v1}, Ljava/util/concurrent/atomic/AtomicReference;-><init>()V
iput-object v1, p0, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->error:Ljava/util/concurrent/atomic/AtomicReference;
.line 195
iput-boolean p5, p0, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->delayErrors:Z
.line 196
return-void
.end method
# virtual methods
.method public cancel()V
.registers 2
.line 208
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;, "Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator<TT;TR;>;"
const/4 v0, 0x1
iput-boolean v0, p0, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->cancelled:Z
.line 209
invoke-virtual {p0}, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->cancelAll()V
.line 210
return-void
.end method
.method cancelAll()V
.registers 5
.line 453
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;, "Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator<TT;TR;>;"
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->subscribers:[Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestInnerSubscriber;
array-length v1, v0
const/4 v2, 0x0
:goto_4
if-ge v2, v1, :cond_e
aget-object v3, v0, v2
.line 454
.local v3, "inner":Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestInnerSubscriber;, "Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestInnerSubscriber<TT;>;"
invoke-virtual {v3}, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestInnerSubscriber;->cancel()V
.line 453
.end local v3 # "inner":Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestInnerSubscriber;, "Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestInnerSubscriber<TT;>;"
add-int/lit8 v2, v2, 0x1
goto :goto_4
.line 456
:cond_e
return-void
.end method
.method checkTerminated(ZZLorg/reactivestreams/Subscriber;Lio/reactivex/internal/queue/SpscLinkedArrayQueue;)Z
.registers 8
.param p1, "d" # Z
.param p2, "empty" # Z
.annotation system Ldalvik/annotation/Signature;
value = {
"(ZZ",
"Lorg/reactivestreams/Subscriber<",
"*>;",
"Lio/reactivex/internal/queue/SpscLinkedArrayQueue<",
"*>;)Z"
}
.end annotation
.line 413
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;, "Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator<TT;TR;>;"
.local p3, "a":Lorg/reactivestreams/Subscriber;, "Lorg/reactivestreams/Subscriber<*>;"
.local p4, "q":Lio/reactivex/internal/queue/SpscLinkedArrayQueue;, "Lio/reactivex/internal/queue/SpscLinkedArrayQueue<*>;"
iget-boolean v0, p0, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->cancelled:Z
const/4 v1, 0x1
if-eqz v0, :cond_c
.line 414
invoke-virtual {p0}, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->cancelAll()V
.line 415
invoke-virtual {p4}, Lio/reactivex/internal/queue/SpscLinkedArrayQueue;->clear()V
.line 416
return v1
.line 419
:cond_c
if-eqz p1, :cond_4a
.line 420
iget-boolean v0, p0, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->delayErrors:Z
if-eqz v0, :cond_2b
.line 421
if-eqz p2, :cond_4a
.line 422
invoke-virtual {p0}, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->cancelAll()V
.line 423
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->error:Ljava/util/concurrent/atomic/AtomicReference;
invoke-static {v0}, Lio/reactivex/internal/util/ExceptionHelper;->terminate(Ljava/util/concurrent/atomic/AtomicReference;)Ljava/lang/Throwable;
move-result-object v0
.line 425
.local v0, "e":Ljava/lang/Throwable;
if-eqz v0, :cond_27
sget-object v2, Lio/reactivex/internal/util/ExceptionHelper;->TERMINATED:Ljava/lang/Throwable;
if-eq v0, v2, :cond_27
.line 426
invoke-interface {p3, v0}, Lorg/reactivestreams/Subscriber;->onError(Ljava/lang/Throwable;)V
goto :goto_2a
.line 428
:cond_27
invoke-interface {p3}, Lorg/reactivestreams/Subscriber;->onComplete()V
.line 430
:goto_2a
return v1
.line 433
.end local v0 # "e":Ljava/lang/Throwable;
:cond_2b
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->error:Ljava/util/concurrent/atomic/AtomicReference;
invoke-static {v0}, Lio/reactivex/internal/util/ExceptionHelper;->terminate(Ljava/util/concurrent/atomic/AtomicReference;)Ljava/lang/Throwable;
move-result-object v0
.line 435
.restart local v0 # "e":Ljava/lang/Throwable;
if-eqz v0, :cond_41
sget-object v2, Lio/reactivex/internal/util/ExceptionHelper;->TERMINATED:Ljava/lang/Throwable;
if-eq v0, v2, :cond_41
.line 436
invoke-virtual {p0}, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->cancelAll()V
.line 437
invoke-virtual {p4}, Lio/reactivex/internal/queue/SpscLinkedArrayQueue;->clear()V
.line 438
invoke-interface {p3, v0}, Lorg/reactivestreams/Subscriber;->onError(Ljava/lang/Throwable;)V
.line 439
return v1
.line 441
:cond_41
if-eqz p2, :cond_4a
.line 442
invoke-virtual {p0}, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->cancelAll()V
.line 444
invoke-interface {p3}, Lorg/reactivestreams/Subscriber;->onComplete()V
.line 445
return v1
.line 449
.end local v0 # "e":Ljava/lang/Throwable;
:cond_4a
const/4 v0, 0x0
return v0
.end method
.method public clear()V
.registers 2
.line 484
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;, "Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator<TT;TR;>;"
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->queue:Lio/reactivex/internal/queue/SpscLinkedArrayQueue;
invoke-virtual {v0}, Lio/reactivex/internal/queue/SpscLinkedArrayQueue;->clear()V
.line 485
return-void
.end method
.method drain()V
.registers 2
.line 401
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;, "Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator<TT;TR;>;"
invoke-virtual {p0}, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->getAndIncrement()I
move-result v0
if-eqz v0, :cond_7
.line 402
return-void
.line 405
:cond_7
iget-boolean v0, p0, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->outputFused:Z
if-eqz v0, :cond_f
.line 406
invoke-virtual {p0}, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->drainOutput()V
goto :goto_12
.line 408
:cond_f
invoke-virtual {p0}, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->drainAsync()V
.line 410
:goto_12
return-void
.end method
.method drainAsync()V
.registers 15
.line 334
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;, "Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator<TT;TR;>;"
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->actual:Lorg/reactivestreams/Subscriber;
.line 335
.local v0, "a":Lorg/reactivestreams/Subscriber;, "Lorg/reactivestreams/Subscriber<-TR;>;"
iget-object v1, p0, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->queue:Lio/reactivex/internal/queue/SpscLinkedArrayQueue;
.line 337
.local v1, "q":Lio/reactivex/internal/queue/SpscLinkedArrayQueue;, "Lio/reactivex/internal/queue/SpscLinkedArrayQueue<Ljava/lang/Object;>;"
const/4 v2, 0x1
.line 341
.local v2, "missed":I
:goto_5
iget-object v3, p0, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->requested:Ljava/util/concurrent/atomic/AtomicLong;
invoke-virtual {v3}, Ljava/util/concurrent/atomic/AtomicLong;->get()J
move-result-wide v3
.line 342
.local v3, "r":J
const-wide/16 v5, 0x0
.line 344
.local v5, "e":J
:goto_d
cmp-long v7, v5, v3
if-eqz v7, :cond_5e
.line 345
iget-boolean v7, p0, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->done:Z
.line 347
.local v7, "d":Z
invoke-virtual {v1}, Lio/reactivex/internal/queue/SpscLinkedArrayQueue;->poll()Ljava/lang/Object;
move-result-object v8
.line 349
.local v8, "v":Ljava/lang/Object;
if-nez v8, :cond_1b
const/4 v9, 0x1
goto :goto_1c
:cond_1b
const/4 v9, 0x0
.line 351
.local v9, "empty":Z
:goto_1c
invoke-virtual {p0, v7, v9, v0, v1}, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->checkTerminated(ZZLorg/reactivestreams/Subscriber;Lio/reactivex/internal/queue/SpscLinkedArrayQueue;)Z
move-result v10
if-eqz v10, :cond_23
.line 352
return-void
.line 355
:cond_23
if-eqz v9, :cond_26
.line 356
goto :goto_5e
.line 359
:cond_26
invoke-virtual {v1}, Lio/reactivex/internal/queue/SpscLinkedArrayQueue;->poll()Ljava/lang/Object;
move-result-object v10
check-cast v10, [Ljava/lang/Object;
check-cast v10, [Ljava/lang/Object;
.line 364
.local v10, "va":[Ljava/lang/Object;, "[TT;"
:try_start_2e
iget-object v11, p0, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->combiner:Lio/reactivex/functions/Function;
invoke-interface {v11, v10}, Lio/reactivex/functions/Function;->apply(Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v11
const-string v12, "The combiner returned a null value"
invoke-static {v11, v12}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
move-result-object v11
:try_end_3a
.catchall {:try_start_2e .. :try_end_3a} :catchall_48
.line 374
.local v11, "w":Ljava/lang/Object;, "TR;"
nop
.line 376
invoke-interface {v0, v11}, Lorg/reactivestreams/Subscriber;->onNext(Ljava/lang/Object;)V
.line 378
move-object v12, v8
check-cast v12, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestInnerSubscriber;
invoke-virtual {v12}, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestInnerSubscriber;->requestOne()V
.line 380
const-wide/16 v12, 0x1
add-long/2addr v5, v12
.line 381
.end local v7 # "d":Z
.end local v8 # "v":Ljava/lang/Object;
.end local v9 # "empty":Z
.end local v10 # "va":[Ljava/lang/Object;, "[TT;"
.end local v11 # "w":Ljava/lang/Object;, "TR;"
goto :goto_d
.line 365
.restart local v7 # "d":Z
.restart local v8 # "v":Ljava/lang/Object;
.restart local v9 # "empty":Z
.restart local v10 # "va":[Ljava/lang/Object;, "[TT;"
:catchall_48
move-exception v11
.line 366
.local v11, "ex":Ljava/lang/Throwable;
invoke-static {v11}, Lio/reactivex/exceptions/Exceptions;->throwIfFatal(Ljava/lang/Throwable;)V
.line 368
invoke-virtual {p0}, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->cancelAll()V
.line 369
iget-object v12, p0, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->error:Ljava/util/concurrent/atomic/AtomicReference;
invoke-static {v12, v11}, Lio/reactivex/internal/util/ExceptionHelper;->addThrowable(Ljava/util/concurrent/atomic/AtomicReference;Ljava/lang/Throwable;)Z
.line 370
iget-object v12, p0, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->error:Ljava/util/concurrent/atomic/AtomicReference;
invoke-static {v12}, Lio/reactivex/internal/util/ExceptionHelper;->terminate(Ljava/util/concurrent/atomic/AtomicReference;)Ljava/lang/Throwable;
move-result-object v11
.line 372
invoke-interface {v0, v11}, Lorg/reactivestreams/Subscriber;->onError(Ljava/lang/Throwable;)V
.line 373
return-void
.line 383
.end local v7 # "d":Z
.end local v8 # "v":Ljava/lang/Object;
.end local v9 # "empty":Z
.end local v10 # "va":[Ljava/lang/Object;, "[TT;"
.end local v11 # "ex":Ljava/lang/Throwable;
:cond_5e
:goto_5e
cmp-long v7, v5, v3
if-nez v7, :cond_6f
.line 384
iget-boolean v7, p0, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->done:Z
invoke-virtual {v1}, Lio/reactivex/internal/queue/SpscLinkedArrayQueue;->isEmpty()Z
move-result v8
invoke-virtual {p0, v7, v8, v0, v1}, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->checkTerminated(ZZLorg/reactivestreams/Subscriber;Lio/reactivex/internal/queue/SpscLinkedArrayQueue;)Z
move-result v7
if-eqz v7, :cond_6f
.line 385
return-void
.line 389
:cond_6f
const-wide/16 v7, 0x0
cmp-long v9, v5, v7
if-eqz v9, :cond_84
const-wide v7, 0x7fffffffffffffffL
cmp-long v9, v3, v7
if-eqz v9, :cond_84
.line 390
iget-object v7, p0, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->requested:Ljava/util/concurrent/atomic/AtomicLong;
neg-long v8, v5
invoke-virtual {v7, v8, v9}, Ljava/util/concurrent/atomic/AtomicLong;->addAndGet(J)J
.line 393
:cond_84
neg-int v7, v2
invoke-virtual {p0, v7}, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->addAndGet(I)I
move-result v2
.line 394
if-nez v2, :cond_8d
.line 395
nop
.line 398
.end local v3 # "r":J
.end local v5 # "e":J
return-void
.line 397
:cond_8d
goto/16 :goto_5
.end method
.method drainOutput()V
.registers 8
.line 292
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;, "Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator<TT;TR;>;"
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->actual:Lorg/reactivestreams/Subscriber;
.line 293
.local v0, "a":Lorg/reactivestreams/Subscriber;, "Lorg/reactivestreams/Subscriber<-TR;>;"
iget-object v1, p0, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->queue:Lio/reactivex/internal/queue/SpscLinkedArrayQueue;
.line 295
.local v1, "q":Lio/reactivex/internal/queue/SpscLinkedArrayQueue;, "Lio/reactivex/internal/queue/SpscLinkedArrayQueue<Ljava/lang/Object;>;"
const/4 v2, 0x1
.line 299
.local v2, "missed":I
:goto_5
iget-boolean v3, p0, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->cancelled:Z
if-eqz v3, :cond_d
.line 300
invoke-virtual {v1}, Lio/reactivex/internal/queue/SpscLinkedArrayQueue;->clear()V
.line 301
return-void
.line 304
:cond_d
iget-object v3, p0, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->error:Ljava/util/concurrent/atomic/AtomicReference;
invoke-virtual {v3}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object;
move-result-object v3
check-cast v3, Ljava/lang/Throwable;
.line 305
.local v3, "ex":Ljava/lang/Throwable;
if-eqz v3, :cond_1e
.line 306
invoke-virtual {v1}, Lio/reactivex/internal/queue/SpscLinkedArrayQueue;->clear()V
.line 308
invoke-interface {v0, v3}, Lorg/reactivestreams/Subscriber;->onError(Ljava/lang/Throwable;)V
.line 309
return-void
.line 312
:cond_1e
iget-boolean v4, p0, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->done:Z
.line 314
.local v4, "d":Z
invoke-virtual {v1}, Lio/reactivex/internal/queue/SpscLinkedArrayQueue;->isEmpty()Z
move-result v5
.line 316
.local v5, "empty":Z
if-nez v5, :cond_2a
.line 317
const/4 v6, 0x0
invoke-interface {v0, v6}, Lorg/reactivestreams/Subscriber;->onNext(Ljava/lang/Object;)V
.line 320
:cond_2a
if-eqz v4, :cond_32
if-eqz v5, :cond_32
.line 321
invoke-interface {v0}, Lorg/reactivestreams/Subscriber;->onComplete()V
.line 322
return-void
.line 325
:cond_32
neg-int v6, v2
invoke-virtual {p0, v6}, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->addAndGet(I)I
move-result v2
.line 326
if-nez v2, :cond_3b
.line 327
nop
.line 330
.end local v3 # "ex":Ljava/lang/Throwable;
.end local v4 # "d":Z
.end local v5 # "empty":Z
return-void
.line 329
:cond_3b
goto :goto_5
.end method
.method innerComplete(I)V
.registers 6
.param p1, "index" # I
.line 257
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;, "Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator<TT;TR;>;"
monitor-enter p0
.line 258
:try_start_1
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->latest:[Ljava/lang/Object;
.line 260
.local v0, "os":[Ljava/lang/Object;
aget-object v1, v0, p1
const/4 v2, 0x1
if-eqz v1, :cond_15
.line 261
iget v1, p0, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->completedSources:I
add-int/2addr v1, v2
.line 263
.local v1, "localCompletedSources":I
array-length v3, v0
if-ne v1, v3, :cond_11
.line 264
iput-boolean v2, p0, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->done:Z
.line 269
.end local v1 # "localCompletedSources":I
goto :goto_17
.line 266
.restart local v1 # "localCompletedSources":I
:cond_11
iput v1, p0, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->completedSources:I
.line 267
monitor-exit p0
return-void
.line 270
.end local v1 # "localCompletedSources":I
:cond_15
iput-boolean v2, p0, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->done:Z
.line 272
.end local v0 # "os":[Ljava/lang/Object;
:goto_17
monitor-exit p0
:try_end_18
.catchall {:try_start_1 .. :try_end_18} :catchall_1c
.line 273
invoke-virtual {p0}, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->drain()V
.line 274
return-void
.line 272
:catchall_1c
move-exception v0
:try_start_1d
monitor-exit p0
:try_end_1e
.catchall {:try_start_1d .. :try_end_1e} :catchall_1c
throw v0
.end method
.method innerError(ILjava/lang/Throwable;)V
.registers 4
.param p1, "index" # I
.param p2, "e" # Ljava/lang/Throwable;
.line 278
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;, "Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator<TT;TR;>;"
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->error:Ljava/util/concurrent/atomic/AtomicReference;
invoke-static {v0, p2}, Lio/reactivex/internal/util/ExceptionHelper;->addThrowable(Ljava/util/concurrent/atomic/AtomicReference;Ljava/lang/Throwable;)Z
move-result v0
if-eqz v0, :cond_1a
.line 279
iget-boolean v0, p0, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->delayErrors:Z
if-nez v0, :cond_16
.line 280
invoke-virtual {p0}, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->cancelAll()V
.line 281
const/4 v0, 0x1
iput-boolean v0, p0, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->done:Z
.line 282
invoke-virtual {p0}, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->drain()V
goto :goto_1d
.line 284
:cond_16
invoke-virtual {p0, p1}, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->innerComplete(I)V
goto :goto_1d
.line 287
:cond_1a
invoke-static {p2}, Lio/reactivex/plugins/RxJavaPlugins;->onError(Ljava/lang/Throwable;)V
.line 289
:goto_1d
return-void
.end method
.method innerValue(ILjava/lang/Object;)V
.registers 8
.param p1, "index" # I
.annotation system Ldalvik/annotation/Signature;
value = {
"(ITT;)V"
}
.end annotation
.line 227
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;, "Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator<TT;TR;>;"
.local p2, "value":Ljava/lang/Object;, "TT;"
monitor-enter p0
.line 228
:try_start_1
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->latest:[Ljava/lang/Object;
.line 230
.local v0, "os":[Ljava/lang/Object;
iget v1, p0, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->nonEmptySources:I
.line 232
.local v1, "localNonEmptySources":I
aget-object v2, v0, p1
if-nez v2, :cond_d
.line 233
add-int/lit8 v1, v1, 0x1
.line 234
iput v1, p0, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->nonEmptySources:I
.line 237
:cond_d
aput-object p2, v0, p1
.line 239
array-length v2, v0
if-ne v2, v1, :cond_21
.line 241
iget-object v2, p0, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->queue:Lio/reactivex/internal/queue/SpscLinkedArrayQueue;
iget-object v3, p0, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->subscribers:[Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestInnerSubscriber;
aget-object v3, v3, p1
invoke-virtual {v0}, [Ljava/lang/Object;->clone()Ljava/lang/Object;
move-result-object v4
invoke-virtual {v2, v3, v4}, Lio/reactivex/internal/queue/SpscLinkedArrayQueue;->offer(Ljava/lang/Object;Ljava/lang/Object;)Z
.line 243
const/4 v2, 0x0
.local v2, "replenishInsteadOfDrain":Z
goto :goto_22
.line 245
.end local v2 # "replenishInsteadOfDrain":Z
:cond_21
const/4 v2, 0x1
.line 247
.end local v0 # "os":[Ljava/lang/Object;
.end local v1 # "localNonEmptySources":I
.restart local v2 # "replenishInsteadOfDrain":Z
:goto_22
monitor-exit p0
:try_end_23
.catchall {:try_start_1 .. :try_end_23} :catchall_31
.line 249
if-eqz v2, :cond_2d
.line 250
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->subscribers:[Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestInnerSubscriber;
aget-object v0, v0, p1
invoke-virtual {v0}, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestInnerSubscriber;->requestOne()V
goto :goto_30
.line 252
:cond_2d
invoke-virtual {p0}, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->drain()V
.line 254
:goto_30
return-void
.line 247
.end local v2 # "replenishInsteadOfDrain":Z
:catchall_31
move-exception v0
:try_start_32
monitor-exit p0
:try_end_33
.catchall {:try_start_32 .. :try_end_33} :catchall_31
throw v0
.end method
.method public isEmpty()Z
.registers 2
.line 489
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;, "Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator<TT;TR;>;"
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->queue:Lio/reactivex/internal/queue/SpscLinkedArrayQueue;
invoke-virtual {v0}, Lio/reactivex/internal/queue/SpscLinkedArrayQueue;->isEmpty()Z
move-result v0
return v0
.end method
.method public poll()Ljava/lang/Object;
.registers 5
.annotation system Ldalvik/annotation/Signature;
value = {
"()TR;"
}
.end annotation
.annotation system Ldalvik/annotation/Throws;
value = {
Ljava/lang/Exception;
}
.end annotation
.line 472
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;, "Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator<TT;TR;>;"
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->queue:Lio/reactivex/internal/queue/SpscLinkedArrayQueue;
invoke-virtual {v0}, Lio/reactivex/internal/queue/SpscLinkedArrayQueue;->poll()Ljava/lang/Object;
move-result-object v0
.line 473
.local v0, "e":Ljava/lang/Object;
if-nez v0, :cond_a
.line 474
const/4 v1, 0x0
return-object v1
.line 476
:cond_a
iget-object v1, p0, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->queue:Lio/reactivex/internal/queue/SpscLinkedArrayQueue;
invoke-virtual {v1}, Lio/reactivex/internal/queue/SpscLinkedArrayQueue;->poll()Ljava/lang/Object;
move-result-object v1
check-cast v1, [Ljava/lang/Object;
check-cast v1, [Ljava/lang/Object;
.line 477
.local v1, "a":[Ljava/lang/Object;, "[TT;"
iget-object v2, p0, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->combiner:Lio/reactivex/functions/Function;
invoke-interface {v2, v1}, Lio/reactivex/functions/Function;->apply(Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v2
const-string v3, "The combiner returned a null value"
invoke-static {v2, v3}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
move-result-object v2
.line 478
.local v2, "r":Ljava/lang/Object;, "TR;"
move-object v3, v0
check-cast v3, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestInnerSubscriber;
invoke-virtual {v3}, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestInnerSubscriber;->requestOne()V
.line 479
return-object v2
.end method
.method public request(J)V
.registers 4
.param p1, "n" # J
.line 200
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;, "Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator<TT;TR;>;"
invoke-static {p1, p2}, Lio/reactivex/internal/subscriptions/SubscriptionHelper;->validate(J)Z
move-result v0
if-eqz v0, :cond_e
.line 201
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->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 202
invoke-virtual {p0}, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->drain()V
.line 204
:cond_e
return-void
.end method
.method public requestFusion(I)I
.registers 4
.param p1, "requestedMode" # I
.line 460
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;, "Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator<TT;TR;>;"
and-int/lit8 v0, p1, 0x4
const/4 v1, 0x0
if-eqz v0, :cond_6
.line 461
return v1
.line 463
:cond_6
and-int/lit8 v0, p1, 0x2
.line 464
.local v0, "m":I
if-eqz v0, :cond_b
const/4 v1, 0x1
:cond_b
iput-boolean v1, p0, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->outputFused:Z
.line 465
return v0
.end method
.method subscribe([Lorg/reactivestreams/Publisher;I)V
.registers 7
.param p2, "n" # I
.annotation system Ldalvik/annotation/Signature;
value = {
"([",
"Lorg/reactivestreams/Publisher<",
"+TT;>;I)V"
}
.end annotation
.line 213
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;, "Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator<TT;TR;>;"
.local p1, "sources":[Lorg/reactivestreams/Publisher;, "[Lorg/reactivestreams/Publisher<+TT;>;"
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->subscribers:[Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestInnerSubscriber;
.line 215
.local v0, "a":[Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestInnerSubscriber;, "[Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestInnerSubscriber<TT;>;"
const/4 v1, 0x0
.local v1, "i":I
:goto_3
if-ge v1, p2, :cond_19
.line 216
iget-boolean v2, p0, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->done:Z
if-nez v2, :cond_18
iget-boolean v2, p0, Lio/reactivex/internal/operators/flowable/FlowableCombineLatest$CombineLatestCoordinator;->cancelled:Z
if-eqz v2, :cond_e
goto :goto_18
.line 219
:cond_e
aget-object v2, p1, v1
aget-object v3, v0, v1
invoke-interface {v2, v3}, Lorg/reactivestreams/Publisher;->subscribe(Lorg/reactivestreams/Subscriber;)V
.line 215
add-int/lit8 v1, v1, 0x1
goto :goto_3
.line 217
:cond_18
:goto_18
return-void
.line 221
.end local v1 # "i":I
:cond_19
return-void
.end method