FlowableTakeLast$TakeLastSubscriber.smali
.class final Lio/reactivex/internal/operators/flowable/FlowableTakeLast$TakeLastSubscriber;
.super Ljava/util/ArrayDeque;
.source "FlowableTakeLast.java"
# interfaces
.implements Lio/reactivex/FlowableSubscriber;
.implements Lorg/reactivestreams/Subscription;
# annotations
.annotation system Ldalvik/annotation/EnclosingClass;
value = Lio/reactivex/internal/operators/flowable/FlowableTakeLast;
.end annotation
.annotation system Ldalvik/annotation/InnerClass;
accessFlags = 0x18
name = "TakeLastSubscriber"
.end annotation
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">",
"Ljava/util/ArrayDeque<",
"TT;>;",
"Lio/reactivex/FlowableSubscriber<",
"TT;>;",
"Lorg/reactivestreams/Subscription;"
}
.end annotation
# static fields
.field private static final serialVersionUID:J = 0x6479cc5265c56d72L
# instance fields
.field final actual:Lorg/reactivestreams/Subscriber;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lorg/reactivestreams/Subscriber<",
"-TT;>;"
}
.end annotation
.end field
.field volatile cancelled:Z
.field final count:I
.field volatile done:Z
.field final requested:Ljava/util/concurrent/atomic/AtomicLong;
.field s:Lorg/reactivestreams/Subscription;
.field final wip:Ljava/util/concurrent/atomic/AtomicInteger;
# direct methods
.method static constructor <clinit>()V
.registers 1
return-void
.end method
.method constructor <init>(Lorg/reactivestreams/Subscriber;I)V
.registers 4
.param p2, "count" # I
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lorg/reactivestreams/Subscriber<",
"-TT;>;I)V"
}
.end annotation
.line 52
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableTakeLast$TakeLastSubscriber;, "Lio/reactivex/internal/operators/flowable/FlowableTakeLast$TakeLastSubscriber<TT;>;"
.local p1, "actual":Lorg/reactivestreams/Subscriber;, "Lorg/reactivestreams/Subscriber<-TT;>;"
invoke-direct {p0}, Ljava/util/ArrayDeque;-><init>()V
.line 48
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/FlowableTakeLast$TakeLastSubscriber;->requested:Ljava/util/concurrent/atomic/AtomicLong;
.line 50
new-instance v0, Ljava/util/concurrent/atomic/AtomicInteger;
invoke-direct {v0}, Ljava/util/concurrent/atomic/AtomicInteger;-><init>()V
iput-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableTakeLast$TakeLastSubscriber;->wip:Ljava/util/concurrent/atomic/AtomicInteger;
.line 53
iput-object p1, p0, Lio/reactivex/internal/operators/flowable/FlowableTakeLast$TakeLastSubscriber;->actual:Lorg/reactivestreams/Subscriber;
.line 54
iput p2, p0, Lio/reactivex/internal/operators/flowable/FlowableTakeLast$TakeLastSubscriber;->count:I
.line 55
return-void
.end method
# virtual methods
.method public cancel()V
.registers 2
.line 95
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableTakeLast$TakeLastSubscriber;, "Lio/reactivex/internal/operators/flowable/FlowableTakeLast$TakeLastSubscriber<TT;>;"
const/4 v0, 0x1
iput-boolean v0, p0, Lio/reactivex/internal/operators/flowable/FlowableTakeLast$TakeLastSubscriber;->cancelled:Z
.line 96
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableTakeLast$TakeLastSubscriber;->s:Lorg/reactivestreams/Subscription;
invoke-interface {v0}, Lorg/reactivestreams/Subscription;->cancel()V
.line 97
return-void
.end method
.method drain()V
.registers 9
.line 100
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableTakeLast$TakeLastSubscriber;, "Lio/reactivex/internal/operators/flowable/FlowableTakeLast$TakeLastSubscriber<TT;>;"
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableTakeLast$TakeLastSubscriber;->wip:Ljava/util/concurrent/atomic/AtomicInteger;
invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicInteger;->getAndIncrement()I
move-result v0
if-nez v0, :cond_53
.line 101
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableTakeLast$TakeLastSubscriber;->actual:Lorg/reactivestreams/Subscriber;
.line 102
.local v0, "a":Lorg/reactivestreams/Subscriber;, "Lorg/reactivestreams/Subscriber<-TT;>;"
iget-object v1, p0, Lio/reactivex/internal/operators/flowable/FlowableTakeLast$TakeLastSubscriber;->requested:Ljava/util/concurrent/atomic/AtomicLong;
invoke-virtual {v1}, Ljava/util/concurrent/atomic/AtomicLong;->get()J
move-result-wide v1
.line 104
.local v1, "r":J
:cond_10
iget-boolean v3, p0, Lio/reactivex/internal/operators/flowable/FlowableTakeLast$TakeLastSubscriber;->cancelled:Z
if-eqz v3, :cond_15
.line 105
return-void
.line 107
:cond_15
iget-boolean v3, p0, Lio/reactivex/internal/operators/flowable/FlowableTakeLast$TakeLastSubscriber;->done:Z
if-eqz v3, :cond_4b
.line 108
const-wide/16 v3, 0x0
.line 110
.local v3, "e":J
:goto_1b
cmp-long v5, v3, v1
if-eqz v5, :cond_35
.line 111
iget-boolean v5, p0, Lio/reactivex/internal/operators/flowable/FlowableTakeLast$TakeLastSubscriber;->cancelled:Z
if-eqz v5, :cond_24
.line 112
return-void
.line 114
:cond_24
invoke-virtual {p0}, Lio/reactivex/internal/operators/flowable/FlowableTakeLast$TakeLastSubscriber;->poll()Ljava/lang/Object;
move-result-object v5
.line 115
.local v5, "v":Ljava/lang/Object;, "TT;"
if-nez v5, :cond_2e
.line 116
invoke-interface {v0}, Lorg/reactivestreams/Subscriber;->onComplete()V
.line 117
return-void
.line 119
:cond_2e
invoke-interface {v0, v5}, Lorg/reactivestreams/Subscriber;->onNext(Ljava/lang/Object;)V
.line 120
const-wide/16 v6, 0x1
add-long/2addr v3, v6
.line 121
.end local v5 # "v":Ljava/lang/Object;, "TT;"
goto :goto_1b
.line 122
:cond_35
const-wide/16 v5, 0x0
cmp-long v7, v3, v5
if-eqz v7, :cond_4b
const-wide v5, 0x7fffffffffffffffL
cmp-long v7, v1, v5
if-eqz v7, :cond_4b
.line 123
iget-object v5, p0, Lio/reactivex/internal/operators/flowable/FlowableTakeLast$TakeLastSubscriber;->requested:Ljava/util/concurrent/atomic/AtomicLong;
neg-long v6, v3
invoke-virtual {v5, v6, v7}, Ljava/util/concurrent/atomic/AtomicLong;->addAndGet(J)J
move-result-wide v1
.line 126
.end local v3 # "e":J
:cond_4b
iget-object v3, p0, Lio/reactivex/internal/operators/flowable/FlowableTakeLast$TakeLastSubscriber;->wip:Ljava/util/concurrent/atomic/AtomicInteger;
invoke-virtual {v3}, Ljava/util/concurrent/atomic/AtomicInteger;->decrementAndGet()I
move-result v3
if-nez v3, :cond_10
.line 128
.end local v0 # "a":Lorg/reactivestreams/Subscriber;, "Lorg/reactivestreams/Subscriber<-TT;>;"
.end local v1 # "r":J
:cond_53
return-void
.end method
.method public onComplete()V
.registers 2
.line 81
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableTakeLast$TakeLastSubscriber;, "Lio/reactivex/internal/operators/flowable/FlowableTakeLast$TakeLastSubscriber<TT;>;"
const/4 v0, 0x1
iput-boolean v0, p0, Lio/reactivex/internal/operators/flowable/FlowableTakeLast$TakeLastSubscriber;->done:Z
.line 82
invoke-virtual {p0}, Lio/reactivex/internal/operators/flowable/FlowableTakeLast$TakeLastSubscriber;->drain()V
.line 83
return-void
.end method
.method public onError(Ljava/lang/Throwable;)V
.registers 3
.param p1, "t" # Ljava/lang/Throwable;
.line 76
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableTakeLast$TakeLastSubscriber;, "Lio/reactivex/internal/operators/flowable/FlowableTakeLast$TakeLastSubscriber<TT;>;"
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableTakeLast$TakeLastSubscriber;->actual:Lorg/reactivestreams/Subscriber;
invoke-interface {v0, p1}, Lorg/reactivestreams/Subscriber;->onError(Ljava/lang/Throwable;)V
.line 77
return-void
.end method
.method public onNext(Ljava/lang/Object;)V
.registers 4
.annotation system Ldalvik/annotation/Signature;
value = {
"(TT;)V"
}
.end annotation
.line 68
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableTakeLast$TakeLastSubscriber;, "Lio/reactivex/internal/operators/flowable/FlowableTakeLast$TakeLastSubscriber<TT;>;"
.local p1, "t":Ljava/lang/Object;, "TT;"
iget v0, p0, Lio/reactivex/internal/operators/flowable/FlowableTakeLast$TakeLastSubscriber;->count:I
invoke-virtual {p0}, Lio/reactivex/internal/operators/flowable/FlowableTakeLast$TakeLastSubscriber;->size()I
move-result v1
if-ne v0, v1, :cond_b
.line 69
invoke-virtual {p0}, Lio/reactivex/internal/operators/flowable/FlowableTakeLast$TakeLastSubscriber;->poll()Ljava/lang/Object;
.line 71
:cond_b
invoke-virtual {p0, p1}, Lio/reactivex/internal/operators/flowable/FlowableTakeLast$TakeLastSubscriber;->offer(Ljava/lang/Object;)Z
.line 72
return-void
.end method
.method public onSubscribe(Lorg/reactivestreams/Subscription;)V
.registers 4
.param p1, "s" # Lorg/reactivestreams/Subscription;
.line 59
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableTakeLast$TakeLastSubscriber;, "Lio/reactivex/internal/operators/flowable/FlowableTakeLast$TakeLastSubscriber<TT;>;"
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableTakeLast$TakeLastSubscriber;->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_17
.line 60
iput-object p1, p0, Lio/reactivex/internal/operators/flowable/FlowableTakeLast$TakeLastSubscriber;->s:Lorg/reactivestreams/Subscription;
.line 61
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableTakeLast$TakeLastSubscriber;->actual:Lorg/reactivestreams/Subscriber;
invoke-interface {v0, p0}, Lorg/reactivestreams/Subscriber;->onSubscribe(Lorg/reactivestreams/Subscription;)V
.line 62
const-wide v0, 0x7fffffffffffffffL
invoke-interface {p1, v0, v1}, Lorg/reactivestreams/Subscription;->request(J)V
.line 64
:cond_17
return-void
.end method
.method public request(J)V
.registers 4
.param p1, "n" # J
.line 87
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableTakeLast$TakeLastSubscriber;, "Lio/reactivex/internal/operators/flowable/FlowableTakeLast$TakeLastSubscriber<TT;>;"
invoke-static {p1, p2}, Lio/reactivex/internal/subscriptions/SubscriptionHelper;->validate(J)Z
move-result v0
if-eqz v0, :cond_e
.line 88
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableTakeLast$TakeLastSubscriber;->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 89
invoke-virtual {p0}, Lio/reactivex/internal/operators/flowable/FlowableTakeLast$TakeLastSubscriber;->drain()V
.line 91
:cond_e
return-void
.end method