FlowableSampleTimed$SampleTimedEmitLast.smali
.class final Lio/reactivex/internal/operators/flowable/FlowableSampleTimed$SampleTimedEmitLast;
.super Lio/reactivex/internal/operators/flowable/FlowableSampleTimed$SampleTimedSubscriber;
.source "FlowableSampleTimed.java"
# annotations
.annotation system Ldalvik/annotation/EnclosingClass;
value = Lio/reactivex/internal/operators/flowable/FlowableSampleTimed;
.end annotation
.annotation system Ldalvik/annotation/InnerClass;
accessFlags = 0x18
name = "SampleTimedEmitLast"
.end annotation
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">",
"Lio/reactivex/internal/operators/flowable/FlowableSampleTimed$SampleTimedSubscriber<",
"TT;>;"
}
.end annotation
# static fields
.field private static final serialVersionUID:J = -0x63165c33f8fff493L
# instance fields
.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;JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)V
.registers 8
.param p2, "period" # J
.param p4, "unit" # Ljava/util/concurrent/TimeUnit;
.param p5, "scheduler" # Lio/reactivex/Scheduler;
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lorg/reactivestreams/Subscriber<",
"-TT;>;J",
"Ljava/util/concurrent/TimeUnit;",
"Lio/reactivex/Scheduler;",
")V"
}
.end annotation
.line 162
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableSampleTimed$SampleTimedEmitLast;, "Lio/reactivex/internal/operators/flowable/FlowableSampleTimed$SampleTimedEmitLast<TT;>;"
.local p1, "actual":Lorg/reactivestreams/Subscriber;, "Lorg/reactivestreams/Subscriber<-TT;>;"
invoke-direct/range {p0 .. p5}, Lio/reactivex/internal/operators/flowable/FlowableSampleTimed$SampleTimedSubscriber;-><init>(Lorg/reactivestreams/Subscriber;JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)V
.line 163
new-instance v0, Ljava/util/concurrent/atomic/AtomicInteger;
const/4 v1, 0x1
invoke-direct {v0, v1}, Ljava/util/concurrent/atomic/AtomicInteger;-><init>(I)V
iput-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableSampleTimed$SampleTimedEmitLast;->wip:Ljava/util/concurrent/atomic/AtomicInteger;
.line 164
return-void
.end method
# virtual methods
.method complete()V
.registers 2
.line 168
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableSampleTimed$SampleTimedEmitLast;, "Lio/reactivex/internal/operators/flowable/FlowableSampleTimed$SampleTimedEmitLast<TT;>;"
invoke-virtual {p0}, Lio/reactivex/internal/operators/flowable/FlowableSampleTimed$SampleTimedEmitLast;->emit()V
.line 169
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableSampleTimed$SampleTimedEmitLast;->wip:Ljava/util/concurrent/atomic/AtomicInteger;
invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicInteger;->decrementAndGet()I
move-result v0
if-nez v0, :cond_10
.line 170
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableSampleTimed$SampleTimedEmitLast;->actual:Lorg/reactivestreams/Subscriber;
invoke-interface {v0}, Lorg/reactivestreams/Subscriber;->onComplete()V
.line 172
:cond_10
return-void
.end method
.method public run()V
.registers 3
.line 176
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableSampleTimed$SampleTimedEmitLast;, "Lio/reactivex/internal/operators/flowable/FlowableSampleTimed$SampleTimedEmitLast<TT;>;"
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableSampleTimed$SampleTimedEmitLast;->wip:Ljava/util/concurrent/atomic/AtomicInteger;
invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicInteger;->incrementAndGet()I
move-result v0
const/4 v1, 0x2
if-ne v0, v1, :cond_19
.line 177
invoke-virtual {p0}, Lio/reactivex/internal/operators/flowable/FlowableSampleTimed$SampleTimedEmitLast;->emit()V
.line 178
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableSampleTimed$SampleTimedEmitLast;->wip:Ljava/util/concurrent/atomic/AtomicInteger;
invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicInteger;->decrementAndGet()I
move-result v0
if-nez v0, :cond_19
.line 179
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableSampleTimed$SampleTimedEmitLast;->actual:Lorg/reactivestreams/Subscriber;
invoke-interface {v0}, Lorg/reactivestreams/Subscriber;->onComplete()V
.line 182
:cond_19
return-void
.end method