FlowableGroupBy$State.smali
.class final Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;
.super Lio/reactivex/internal/subscriptions/BasicIntQueueSubscription;
.source "FlowableGroupBy.java"
# interfaces
.implements Lorg/reactivestreams/Publisher;
# annotations
.annotation system Ldalvik/annotation/EnclosingClass;
value = Lio/reactivex/internal/operators/flowable/FlowableGroupBy;
.end annotation
.annotation system Ldalvik/annotation/InnerClass;
accessFlags = 0x18
name = "State"
.end annotation
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
"K:",
"Ljava/lang/Object;",
">",
"Lio/reactivex/internal/subscriptions/BasicIntQueueSubscription<",
"TT;>;",
"Lorg/reactivestreams/Publisher<",
"TT;>;"
}
.end annotation
# static fields
.field private static final serialVersionUID:J = -0x35762a4bbab31538L
# instance fields
.field final actual:Ljava/util/concurrent/atomic/AtomicReference;
.annotation system Ldalvik/annotation/Signature;
value = {
"Ljava/util/concurrent/atomic/AtomicReference<",
"Lorg/reactivestreams/Subscriber<",
"-TT;>;>;"
}
.end annotation
.end field
.field final cancelled:Ljava/util/concurrent/atomic/AtomicBoolean;
.field final delayError:Z
.field volatile done:Z
.field error:Ljava/lang/Throwable;
.field final key:Ljava/lang/Object;
.annotation system Ldalvik/annotation/Signature;
value = {
"TK;"
}
.end annotation
.end field
.field final once:Ljava/util/concurrent/atomic/AtomicBoolean;
.field outputFused:Z
.field final parent:Lio/reactivex/internal/operators/flowable/FlowableGroupBy$GroupBySubscriber;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/internal/operators/flowable/FlowableGroupBy$GroupBySubscriber<",
"*TK;TT;>;"
}
.end annotation
.end field
.field produced:I
.field final queue:Lio/reactivex/internal/queue/SpscLinkedArrayQueue;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/internal/queue/SpscLinkedArrayQueue<",
"TT;>;"
}
.end annotation
.end field
.field final requested:Ljava/util/concurrent/atomic/AtomicLong;
# direct methods
.method static constructor <clinit>()V
.registers 1
return-void
.end method
.method constructor <init>(ILio/reactivex/internal/operators/flowable/FlowableGroupBy$GroupBySubscriber;Ljava/lang/Object;Z)V
.registers 6
.param p1, "bufferSize" # I
.param p4, "delayError" # Z
.annotation system Ldalvik/annotation/Signature;
value = {
"(I",
"Lio/reactivex/internal/operators/flowable/FlowableGroupBy$GroupBySubscriber<",
"*TK;TT;>;TK;Z)V"
}
.end annotation
.line 431
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;, "Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State<TT;TK;>;"
.local p2, "parent":Lio/reactivex/internal/operators/flowable/FlowableGroupBy$GroupBySubscriber;, "Lio/reactivex/internal/operators/flowable/FlowableGroupBy$GroupBySubscriber<*TK;TT;>;"
.local p3, "key":Ljava/lang/Object;, "TK;"
invoke-direct {p0}, Lio/reactivex/internal/subscriptions/BasicIntQueueSubscription;-><init>()V
.line 416
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/FlowableGroupBy$State;->requested:Ljava/util/concurrent/atomic/AtomicLong;
.line 421
new-instance v0, Ljava/util/concurrent/atomic/AtomicBoolean;
invoke-direct {v0}, Ljava/util/concurrent/atomic/AtomicBoolean;-><init>()V
iput-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->cancelled:Ljava/util/concurrent/atomic/AtomicBoolean;
.line 423
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/FlowableGroupBy$State;->actual:Ljava/util/concurrent/atomic/AtomicReference;
.line 425
new-instance v0, Ljava/util/concurrent/atomic/AtomicBoolean;
invoke-direct {v0}, Ljava/util/concurrent/atomic/AtomicBoolean;-><init>()V
iput-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->once:Ljava/util/concurrent/atomic/AtomicBoolean;
.line 432
new-instance v0, Lio/reactivex/internal/queue/SpscLinkedArrayQueue;
invoke-direct {v0, p1}, Lio/reactivex/internal/queue/SpscLinkedArrayQueue;-><init>(I)V
iput-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->queue:Lio/reactivex/internal/queue/SpscLinkedArrayQueue;
.line 433
iput-object p2, p0, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->parent:Lio/reactivex/internal/operators/flowable/FlowableGroupBy$GroupBySubscriber;
.line 434
iput-object p3, p0, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->key:Ljava/lang/Object;
.line 435
iput-boolean p4, p0, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->delayError:Z
.line 436
return-void
.end method
# virtual methods
.method public cancel()V
.registers 4
.line 448
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;, "Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State<TT;TK;>;"
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->cancelled:Ljava/util/concurrent/atomic/AtomicBoolean;
const/4 v1, 0x0
const/4 v2, 0x1
invoke-virtual {v0, v1, v2}, Ljava/util/concurrent/atomic/AtomicBoolean;->compareAndSet(ZZ)Z
move-result v0
if-eqz v0, :cond_11
.line 449
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->parent:Lio/reactivex/internal/operators/flowable/FlowableGroupBy$GroupBySubscriber;
iget-object v1, p0, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->key:Ljava/lang/Object;
invoke-virtual {v0, v1}, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$GroupBySubscriber;->cancel(Ljava/lang/Object;)V
.line 451
:cond_11
return-void
.end method
.method checkTerminated(ZZLorg/reactivestreams/Subscriber;Z)Z
.registers 8
.param p1, "d" # Z
.param p2, "empty" # Z
.param p4, "delayError" # Z
.annotation system Ldalvik/annotation/Signature;
value = {
"(ZZ",
"Lorg/reactivestreams/Subscriber<",
"-TT;>;Z)Z"
}
.end annotation
.line 591
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;, "Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State<TT;TK;>;"
.local p3, "a":Lorg/reactivestreams/Subscriber;, "Lorg/reactivestreams/Subscriber<-TT;>;"
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->cancelled:Ljava/util/concurrent/atomic/AtomicBoolean;
invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicBoolean;->get()Z
move-result v0
const/4 v1, 0x1
if-eqz v0, :cond_f
.line 592
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->queue:Lio/reactivex/internal/queue/SpscLinkedArrayQueue;
invoke-virtual {v0}, Lio/reactivex/internal/queue/SpscLinkedArrayQueue;->clear()V
.line 593
return v1
.line 596
:cond_f
if-eqz p1, :cond_34
.line 597
if-eqz p4, :cond_21
.line 598
if-eqz p2, :cond_34
.line 599
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->error:Ljava/lang/Throwable;
.line 600
.local v0, "e":Ljava/lang/Throwable;
if-eqz v0, :cond_1d
.line 601
invoke-interface {p3, v0}, Lorg/reactivestreams/Subscriber;->onError(Ljava/lang/Throwable;)V
goto :goto_20
.line 603
:cond_1d
invoke-interface {p3}, Lorg/reactivestreams/Subscriber;->onComplete()V
.line 605
:goto_20
return v1
.line 608
.end local v0 # "e":Ljava/lang/Throwable;
:cond_21
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->error:Ljava/lang/Throwable;
.line 609
.restart local v0 # "e":Ljava/lang/Throwable;
if-eqz v0, :cond_2e
.line 610
iget-object v2, p0, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->queue:Lio/reactivex/internal/queue/SpscLinkedArrayQueue;
invoke-virtual {v2}, Lio/reactivex/internal/queue/SpscLinkedArrayQueue;->clear()V
.line 611
invoke-interface {p3, v0}, Lorg/reactivestreams/Subscriber;->onError(Ljava/lang/Throwable;)V
.line 612
return v1
.line 614
:cond_2e
if-eqz p2, :cond_34
.line 615
invoke-interface {p3}, Lorg/reactivestreams/Subscriber;->onComplete()V
.line 616
return v1
.line 621
.end local v0 # "e":Ljava/lang/Throwable;
:cond_34
const/4 v0, 0x0
return v0
.end method
.method public clear()V
.registers 2
.line 656
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;, "Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State<TT;TK;>;"
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->queue:Lio/reactivex/internal/queue/SpscLinkedArrayQueue;
invoke-virtual {v0}, Lio/reactivex/internal/queue/SpscLinkedArrayQueue;->clear()V
.line 657
return-void
.end method
.method drain()V
.registers 2
.line 481
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;, "Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State<TT;TK;>;"
invoke-virtual {p0}, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->getAndIncrement()I
move-result v0
if-eqz v0, :cond_7
.line 482
return-void
.line 484
:cond_7
iget-boolean v0, p0, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->outputFused:Z
if-eqz v0, :cond_f
.line 485
invoke-virtual {p0}, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->drainFused()V
goto :goto_12
.line 487
:cond_f
invoke-virtual {p0}, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->drainNormal()V
.line 489
:goto_12
return-void
.end method
.method drainFused()V
.registers 6
.line 492
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;, "Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State<TT;TK;>;"
const/4 v0, 0x1
.line 494
.local v0, "missed":I
iget-object v1, p0, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->queue:Lio/reactivex/internal/queue/SpscLinkedArrayQueue;
.line 495
.local v1, "q":Lio/reactivex/internal/queue/SpscLinkedArrayQueue;, "Lio/reactivex/internal/queue/SpscLinkedArrayQueue<TT;>;"
iget-object v2, p0, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->actual:Ljava/util/concurrent/atomic/AtomicReference;
invoke-virtual {v2}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object;
move-result-object v2
check-cast v2, Lorg/reactivestreams/Subscriber;
.line 498
.local v2, "a":Lorg/reactivestreams/Subscriber;, "Lorg/reactivestreams/Subscriber<-TT;>;"
:goto_b
if-eqz v2, :cond_3e
.line 499
iget-object v3, p0, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->cancelled:Ljava/util/concurrent/atomic/AtomicBoolean;
invoke-virtual {v3}, Ljava/util/concurrent/atomic/AtomicBoolean;->get()Z
move-result v3
if-eqz v3, :cond_19
.line 500
invoke-virtual {v1}, Lio/reactivex/internal/queue/SpscLinkedArrayQueue;->clear()V
.line 501
return-void
.line 504
:cond_19
iget-boolean v3, p0, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->done:Z
.line 506
.local v3, "d":Z
if-eqz v3, :cond_2c
iget-boolean v4, p0, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->delayError:Z
if-nez v4, :cond_2c
.line 507
iget-object v4, p0, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->error:Ljava/lang/Throwable;
.line 508
.local v4, "ex":Ljava/lang/Throwable;
if-eqz v4, :cond_2c
.line 509
invoke-virtual {v1}, Lio/reactivex/internal/queue/SpscLinkedArrayQueue;->clear()V
.line 510
invoke-interface {v2, v4}, Lorg/reactivestreams/Subscriber;->onError(Ljava/lang/Throwable;)V
.line 511
return-void
.line 515
.end local v4 # "ex":Ljava/lang/Throwable;
:cond_2c
const/4 v4, 0x0
invoke-interface {v2, v4}, Lorg/reactivestreams/Subscriber;->onNext(Ljava/lang/Object;)V
.line 517
if-eqz v3, :cond_3e
.line 518
iget-object v4, p0, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->error:Ljava/lang/Throwable;
.line 519
.restart local v4 # "ex":Ljava/lang/Throwable;
if-eqz v4, :cond_3a
.line 520
invoke-interface {v2, v4}, Lorg/reactivestreams/Subscriber;->onError(Ljava/lang/Throwable;)V
goto :goto_3d
.line 522
:cond_3a
invoke-interface {v2}, Lorg/reactivestreams/Subscriber;->onComplete()V
.line 524
:goto_3d
return-void
.line 528
.end local v3 # "d":Z
.end local v4 # "ex":Ljava/lang/Throwable;
:cond_3e
neg-int v3, v0
invoke-virtual {p0, v3}, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->addAndGet(I)I
move-result v0
.line 529
if-nez v0, :cond_46
.line 530
return-void
.line 533
:cond_46
if-nez v2, :cond_52
.line 534
iget-object v3, p0, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->actual:Ljava/util/concurrent/atomic/AtomicReference;
invoke-virtual {v3}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object;
move-result-object v3
move-object v2, v3
check-cast v2, Lorg/reactivestreams/Subscriber;
goto :goto_b
.line 533
:cond_52
goto :goto_b
.end method
.method drainNormal()V
.registers 14
.line 540
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;, "Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State<TT;TK;>;"
const/4 v0, 0x1
.line 542
.local v0, "missed":I
iget-object v1, p0, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->queue:Lio/reactivex/internal/queue/SpscLinkedArrayQueue;
.line 543
.local v1, "q":Lio/reactivex/internal/queue/SpscLinkedArrayQueue;, "Lio/reactivex/internal/queue/SpscLinkedArrayQueue<TT;>;"
iget-boolean v2, p0, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->delayError:Z
.line 544
.local v2, "delayError":Z
iget-object v3, p0, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->actual:Ljava/util/concurrent/atomic/AtomicReference;
invoke-virtual {v3}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object;
move-result-object v3
check-cast v3, Lorg/reactivestreams/Subscriber;
.line 546
.local v3, "a":Lorg/reactivestreams/Subscriber;, "Lorg/reactivestreams/Subscriber<-TT;>;"
:goto_d
if-eqz v3, :cond_64
.line 547
iget-object v4, p0, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->requested:Ljava/util/concurrent/atomic/AtomicLong;
invoke-virtual {v4}, Ljava/util/concurrent/atomic/AtomicLong;->get()J
move-result-wide v4
.line 548
.local v4, "r":J
const-wide/16 v6, 0x0
.line 550
.local v6, "e":J
:goto_17
cmp-long v8, v6, v4
if-eqz v8, :cond_37
.line 551
iget-boolean v8, p0, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->done:Z
.line 552
.local v8, "d":Z
invoke-virtual {v1}, Lio/reactivex/internal/queue/SpscLinkedArrayQueue;->poll()Ljava/lang/Object;
move-result-object v9
.line 553
.local v9, "v":Ljava/lang/Object;, "TT;"
if-nez v9, :cond_25
const/4 v10, 0x1
goto :goto_26
:cond_25
const/4 v10, 0x0
.line 555
.local v10, "empty":Z
:goto_26
invoke-virtual {p0, v8, v10, v3, v2}, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->checkTerminated(ZZLorg/reactivestreams/Subscriber;Z)Z
move-result v11
if-eqz v11, :cond_2d
.line 556
return-void
.line 559
:cond_2d
if-eqz v10, :cond_30
.line 560
goto :goto_37
.line 563
:cond_30
invoke-interface {v3, v9}, Lorg/reactivestreams/Subscriber;->onNext(Ljava/lang/Object;)V
.line 565
const-wide/16 v11, 0x1
add-long/2addr v6, v11
.line 566
.end local v8 # "d":Z
.end local v9 # "v":Ljava/lang/Object;, "TT;"
.end local v10 # "empty":Z
goto :goto_17
.line 568
:cond_37
:goto_37
cmp-long v8, v6, v4
if-nez v8, :cond_48
iget-boolean v8, p0, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->done:Z
invoke-virtual {v1}, Lio/reactivex/internal/queue/SpscLinkedArrayQueue;->isEmpty()Z
move-result v9
invoke-virtual {p0, v8, v9, v3, v2}, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->checkTerminated(ZZLorg/reactivestreams/Subscriber;Z)Z
move-result v8
if-eqz v8, :cond_48
.line 569
return-void
.line 572
:cond_48
const-wide/16 v8, 0x0
cmp-long v10, v6, v8
if-eqz v10, :cond_64
.line 573
const-wide v8, 0x7fffffffffffffffL
cmp-long v10, v4, v8
if-eqz v10, :cond_5d
.line 574
iget-object v8, p0, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->requested:Ljava/util/concurrent/atomic/AtomicLong;
neg-long v9, v6
invoke-virtual {v8, v9, v10}, Ljava/util/concurrent/atomic/AtomicLong;->addAndGet(J)J
.line 576
:cond_5d
iget-object v8, p0, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->parent:Lio/reactivex/internal/operators/flowable/FlowableGroupBy$GroupBySubscriber;
iget-object v8, v8, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$GroupBySubscriber;->s:Lorg/reactivestreams/Subscription;
invoke-interface {v8, v6, v7}, Lorg/reactivestreams/Subscription;->request(J)V
.line 580
.end local v4 # "r":J
.end local v6 # "e":J
:cond_64
neg-int v4, v0
invoke-virtual {p0, v4}, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->addAndGet(I)I
move-result v0
.line 581
if-nez v0, :cond_6d
.line 582
nop
.line 588
return-void
.line 584
:cond_6d
if-nez v3, :cond_79
.line 585
iget-object v4, p0, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->actual:Ljava/util/concurrent/atomic/AtomicReference;
invoke-virtual {v4}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object;
move-result-object v4
move-object v3, v4
check-cast v3, Lorg/reactivestreams/Subscriber;
goto :goto_d
.line 584
:cond_79
goto :goto_d
.end method
.method public isEmpty()Z
.registers 2
.line 651
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;, "Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State<TT;TK;>;"
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->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 onComplete()V
.registers 2
.line 476
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;, "Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State<TT;TK;>;"
const/4 v0, 0x1
iput-boolean v0, p0, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->done:Z
.line 477
invoke-virtual {p0}, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->drain()V
.line 478
return-void
.end method
.method public onError(Ljava/lang/Throwable;)V
.registers 3
.param p1, "e" # Ljava/lang/Throwable;
.line 470
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;, "Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State<TT;TK;>;"
iput-object p1, p0, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->error:Ljava/lang/Throwable;
.line 471
const/4 v0, 0x1
iput-boolean v0, p0, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->done:Z
.line 472
invoke-virtual {p0}, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->drain()V
.line 473
return-void
.end method
.method public onNext(Ljava/lang/Object;)V
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"(TT;)V"
}
.end annotation
.line 465
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;, "Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State<TT;TK;>;"
.local p1, "t":Ljava/lang/Object;, "TT;"
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->queue:Lio/reactivex/internal/queue/SpscLinkedArrayQueue;
invoke-virtual {v0, p1}, Lio/reactivex/internal/queue/SpscLinkedArrayQueue;->offer(Ljava/lang/Object;)Z
.line 466
invoke-virtual {p0}, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->drain()V
.line 467
return-void
.end method
.method public poll()Ljava/lang/Object;
.registers 6
.annotation system Ldalvik/annotation/Signature;
value = {
"()TT;"
}
.end annotation
.line 636
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;, "Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State<TT;TK;>;"
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->queue:Lio/reactivex/internal/queue/SpscLinkedArrayQueue;
invoke-virtual {v0}, Lio/reactivex/internal/queue/SpscLinkedArrayQueue;->poll()Ljava/lang/Object;
move-result-object v0
.line 637
.local v0, "v":Ljava/lang/Object;, "TT;"
if-eqz v0, :cond_f
.line 638
iget v1, p0, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->produced:I
add-int/lit8 v1, v1, 0x1
iput v1, p0, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->produced:I
.line 639
return-object v0
.line 641
:cond_f
iget v1, p0, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->produced:I
.line 642
.local v1, "p":I
if-eqz v1, :cond_1e
.line 643
const/4 v2, 0x0
iput v2, p0, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->produced:I
.line 644
iget-object v2, p0, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->parent:Lio/reactivex/internal/operators/flowable/FlowableGroupBy$GroupBySubscriber;
iget-object v2, v2, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$GroupBySubscriber;->s:Lorg/reactivestreams/Subscription;
int-to-long v3, v1
invoke-interface {v2, v3, v4}, Lorg/reactivestreams/Subscription;->request(J)V
.line 646
:cond_1e
const/4 v2, 0x0
return-object v2
.end method
.method public request(J)V
.registers 4
.param p1, "n" # J
.line 440
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;, "Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State<TT;TK;>;"
invoke-static {p1, p2}, Lio/reactivex/internal/subscriptions/SubscriptionHelper;->validate(J)Z
move-result v0
if-eqz v0, :cond_e
.line 441
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->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 442
invoke-virtual {p0}, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->drain()V
.line 444
:cond_e
return-void
.end method
.method public requestFusion(I)I
.registers 3
.param p1, "mode" # I
.line 626
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;, "Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State<TT;TK;>;"
and-int/lit8 v0, p1, 0x2
if-eqz v0, :cond_9
.line 627
const/4 v0, 0x1
iput-boolean v0, p0, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->outputFused:Z
.line 628
const/4 v0, 0x2
return v0
.line 630
:cond_9
const/4 v0, 0x0
return v0
.end method
.method public subscribe(Lorg/reactivestreams/Subscriber;)V
.registers 5
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lorg/reactivestreams/Subscriber<",
"-TT;>;)V"
}
.end annotation
.line 455
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;, "Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State<TT;TK;>;"
.local p1, "s":Lorg/reactivestreams/Subscriber;, "Lorg/reactivestreams/Subscriber<-TT;>;"
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->once:Ljava/util/concurrent/atomic/AtomicBoolean;
const/4 v1, 0x0
const/4 v2, 0x1
invoke-virtual {v0, v1, v2}, Ljava/util/concurrent/atomic/AtomicBoolean;->compareAndSet(ZZ)Z
move-result v0
if-eqz v0, :cond_16
.line 456
invoke-interface {p1, p0}, Lorg/reactivestreams/Subscriber;->onSubscribe(Lorg/reactivestreams/Subscription;)V
.line 457
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->actual:Ljava/util/concurrent/atomic/AtomicReference;
invoke-virtual {v0, p1}, Ljava/util/concurrent/atomic/AtomicReference;->lazySet(Ljava/lang/Object;)V
.line 458
invoke-virtual {p0}, Lio/reactivex/internal/operators/flowable/FlowableGroupBy$State;->drain()V
goto :goto_20
.line 460
:cond_16
new-instance v0, Ljava/lang/IllegalStateException;
const-string v1, "Only one Subscriber allowed!"
invoke-direct {v0, v1}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
invoke-static {v0, p1}, Lio/reactivex/internal/subscriptions/EmptySubscription;->error(Ljava/lang/Throwable;Lorg/reactivestreams/Subscriber;)V
.line 462
:goto_20
return-void
.end method