p3$a.smali
.class public final Lio/reactivex/internal/operators/observable/p3$a;
.super Ljava/util/concurrent/atomic/AtomicInteger;
.source "SourceFile"
# interfaces
.implements Lio/reactivex/s;
.implements Lio/reactivex/disposables/b;
# annotations
.annotation system Ldalvik/annotation/EnclosingClass;
value = Lio/reactivex/internal/operators/observable/p3;
.end annotation
.annotation system Ldalvik/annotation/InnerClass;
accessFlags = 0x19
name = "a"
.end annotation
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">",
"Ljava/util/concurrent/atomic/AtomicInteger;",
"Lio/reactivex/s<",
"TT;>;",
"Lio/reactivex/disposables/b;"
}
.end annotation
# static fields
.field private static final serialVersionUID:J = -0x4eca0434695949bbL
# instance fields
.field public final a:Lio/reactivex/s;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/s<",
"-TT;>;"
}
.end annotation
.end field
.field public final b:J
.field public final c:Ljava/util/concurrent/TimeUnit;
.field public final d:Lio/reactivex/t;
.field public final e:Lio/reactivex/internal/queue/c;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/internal/queue/c<",
"Ljava/lang/Object;",
">;"
}
.end annotation
.end field
.field public final f:Z
.field public g:Lio/reactivex/disposables/b;
.field public volatile h:Z
.field public volatile i:Z
.field public j:Ljava/lang/Throwable;
# direct methods
.method public constructor <init>(Lio/reactivex/s;JLjava/util/concurrent/TimeUnit;Lio/reactivex/t;IZ)V
.registers 8
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/s<",
"-TT;>;J",
"Ljava/util/concurrent/TimeUnit;",
"Lio/reactivex/t;",
"IZ)V"
}
.end annotation
.line 1
invoke-direct {p0}, Ljava/util/concurrent/atomic/AtomicInteger;-><init>()V
.line 2
iput-object p1, p0, Lio/reactivex/internal/operators/observable/p3$a;->a:Lio/reactivex/s;
.line 3
iput-wide p2, p0, Lio/reactivex/internal/operators/observable/p3$a;->b:J
.line 4
iput-object p4, p0, Lio/reactivex/internal/operators/observable/p3$a;->c:Ljava/util/concurrent/TimeUnit;
.line 5
iput-object p5, p0, Lio/reactivex/internal/operators/observable/p3$a;->d:Lio/reactivex/t;
.line 6
new-instance p1, Lio/reactivex/internal/queue/c;
invoke-direct {p1, p6}, Lio/reactivex/internal/queue/c;-><init>(I)V
iput-object p1, p0, Lio/reactivex/internal/operators/observable/p3$a;->e:Lio/reactivex/internal/queue/c;
.line 7
iput-boolean p7, p0, Lio/reactivex/internal/operators/observable/p3$a;->f:Z
return-void
.end method
# virtual methods
.method public final a()V
.registers 18
move-object/from16 v0, p0
.line 1
invoke-virtual/range {p0 .. p0}, Ljava/util/concurrent/atomic/AtomicInteger;->getAndIncrement()I
move-result v1
if-eqz v1, :cond_9
return-void
.line 2
:cond_9
iget-object v1, v0, Lio/reactivex/internal/operators/observable/p3$a;->a:Lio/reactivex/s;
.line 3
iget-object v2, v0, Lio/reactivex/internal/operators/observable/p3$a;->e:Lio/reactivex/internal/queue/c;
.line 4
iget-boolean v3, v0, Lio/reactivex/internal/operators/observable/p3$a;->f:Z
.line 5
iget-object v4, v0, Lio/reactivex/internal/operators/observable/p3$a;->c:Ljava/util/concurrent/TimeUnit;
.line 6
iget-object v5, v0, Lio/reactivex/internal/operators/observable/p3$a;->d:Lio/reactivex/t;
.line 7
iget-wide v6, v0, Lio/reactivex/internal/operators/observable/p3$a;->b:J
const/4 v8, 0x1
const/4 v9, 0x1
.line 8
:cond_17
:goto_17
iget-boolean v10, v0, Lio/reactivex/internal/operators/observable/p3$a;->h:Z
if-eqz v10, :cond_21
.line 9
iget-object v1, v0, Lio/reactivex/internal/operators/observable/p3$a;->e:Lio/reactivex/internal/queue/c;
invoke-virtual {v1}, Lio/reactivex/internal/queue/c;->clear()V
return-void
.line 10
:cond_21
iget-boolean v10, v0, Lio/reactivex/internal/operators/observable/p3$a;->i:Z
.line 11
invoke-virtual {v2}, Lio/reactivex/internal/queue/c;->d()Ljava/lang/Object;
move-result-object v11
check-cast v11, Ljava/lang/Long;
if-nez v11, :cond_2d
const/4 v12, 0x1
goto :goto_2e
:cond_2d
const/4 v12, 0x0
.line 12
:goto_2e
invoke-virtual {v5, v4}, Lio/reactivex/t;->b(Ljava/util/concurrent/TimeUnit;)J
move-result-wide v13
if-nez v12, :cond_3e
.line 13
invoke-virtual {v11}, Ljava/lang/Long;->longValue()J
move-result-wide v15
sub-long/2addr v13, v6
cmp-long v11, v15, v13
if-lez v11, :cond_3e
const/4 v12, 0x1
:cond_3e
if-eqz v10, :cond_63
if-eqz v3, :cond_50
if-eqz v12, :cond_63
.line 14
iget-object v2, v0, Lio/reactivex/internal/operators/observable/p3$a;->j:Ljava/lang/Throwable;
if-eqz v2, :cond_4c
.line 15
invoke-interface {v1, v2}, Lio/reactivex/s;->onError(Ljava/lang/Throwable;)V
goto :goto_4f
.line 16
:cond_4c
invoke-interface {v1}, Lio/reactivex/s;->onComplete()V
:goto_4f
return-void
.line 17
:cond_50
iget-object v10, v0, Lio/reactivex/internal/operators/observable/p3$a;->j:Ljava/lang/Throwable;
if-eqz v10, :cond_5d
.line 18
iget-object v2, v0, Lio/reactivex/internal/operators/observable/p3$a;->e:Lio/reactivex/internal/queue/c;
invoke-virtual {v2}, Lio/reactivex/internal/queue/c;->clear()V
.line 19
invoke-interface {v1, v10}, Lio/reactivex/s;->onError(Ljava/lang/Throwable;)V
return-void
:cond_5d
if-eqz v12, :cond_63
.line 20
invoke-interface {v1}, Lio/reactivex/s;->onComplete()V
return-void
:cond_63
if-eqz v12, :cond_6d
neg-int v9, v9
.line 21
invoke-virtual {v0, v9}, Ljava/util/concurrent/atomic/AtomicInteger;->addAndGet(I)I
move-result v9
if-nez v9, :cond_17
return-void
.line 22
:cond_6d
invoke-virtual {v2}, Lio/reactivex/internal/queue/c;->poll()Ljava/lang/Object;
.line 23
invoke-virtual {v2}, Lio/reactivex/internal/queue/c;->poll()Ljava/lang/Object;
move-result-object v10
.line 24
invoke-interface {v1, v10}, Lio/reactivex/s;->onNext(Ljava/lang/Object;)V
goto :goto_17
.end method
.method public final dispose()V
.registers 2
.line 1
iget-boolean v0, p0, Lio/reactivex/internal/operators/observable/p3$a;->h:Z
if-nez v0, :cond_17
const/4 v0, 0x1
.line 2
iput-boolean v0, p0, Lio/reactivex/internal/operators/observable/p3$a;->h:Z
.line 3
iget-object v0, p0, Lio/reactivex/internal/operators/observable/p3$a;->g:Lio/reactivex/disposables/b;
invoke-interface {v0}, Lio/reactivex/disposables/b;->dispose()V
.line 4
invoke-virtual {p0}, Ljava/util/concurrent/atomic/AtomicInteger;->getAndIncrement()I
move-result v0
if-nez v0, :cond_17
.line 5
iget-object v0, p0, Lio/reactivex/internal/operators/observable/p3$a;->e:Lio/reactivex/internal/queue/c;
invoke-virtual {v0}, Lio/reactivex/internal/queue/c;->clear()V
:cond_17
return-void
.end method
.method public final isDisposed()Z
.registers 2
iget-boolean v0, p0, Lio/reactivex/internal/operators/observable/p3$a;->h:Z
return v0
.end method
.method public final onComplete()V
.registers 2
const/4 v0, 0x1
.line 1
iput-boolean v0, p0, Lio/reactivex/internal/operators/observable/p3$a;->i:Z
.line 2
invoke-virtual {p0}, Lio/reactivex/internal/operators/observable/p3$a;->a()V
return-void
.end method
.method public final onError(Ljava/lang/Throwable;)V
.registers 2
.line 1
iput-object p1, p0, Lio/reactivex/internal/operators/observable/p3$a;->j:Ljava/lang/Throwable;
const/4 p1, 0x1
.line 2
iput-boolean p1, p0, Lio/reactivex/internal/operators/observable/p3$a;->i:Z
.line 3
invoke-virtual {p0}, Lio/reactivex/internal/operators/observable/p3$a;->a()V
return-void
.end method
.method public final onNext(Ljava/lang/Object;)V
.registers 5
.annotation system Ldalvik/annotation/Signature;
value = {
"(TT;)V"
}
.end annotation
.line 1
iget-object v0, p0, Lio/reactivex/internal/operators/observable/p3$a;->e:Lio/reactivex/internal/queue/c;
.line 2
iget-object v1, p0, Lio/reactivex/internal/operators/observable/p3$a;->d:Lio/reactivex/t;
iget-object v2, p0, Lio/reactivex/internal/operators/observable/p3$a;->c:Ljava/util/concurrent/TimeUnit;
invoke-virtual {v1, v2}, Lio/reactivex/t;->b(Ljava/util/concurrent/TimeUnit;)J
move-result-wide v1
.line 3
invoke-static {v1, v2}, Ljava/lang/Long;->valueOf(J)Ljava/lang/Long;
move-result-object v1
invoke-virtual {v0, v1, p1}, Lio/reactivex/internal/queue/c;->c(Ljava/lang/Object;Ljava/lang/Object;)Z
.line 4
invoke-virtual {p0}, Lio/reactivex/internal/operators/observable/p3$a;->a()V
return-void
.end method
.method public final onSubscribe(Lio/reactivex/disposables/b;)V
.registers 3
.line 1
iget-object v0, p0, Lio/reactivex/internal/operators/observable/p3$a;->g:Lio/reactivex/disposables/b;
invoke-static {v0, p1}, Lio/reactivex/internal/disposables/c;->validate(Lio/reactivex/disposables/b;Lio/reactivex/disposables/b;)Z
move-result v0
if-eqz v0, :cond_f
.line 2
iput-object p1, p0, Lio/reactivex/internal/operators/observable/p3$a;->g:Lio/reactivex/disposables/b;
.line 3
iget-object p1, p0, Lio/reactivex/internal/operators/observable/p3$a;->a:Lio/reactivex/s;
invoke-interface {p1, p0}, Lio/reactivex/s;->onSubscribe(Lio/reactivex/disposables/b;)V
:cond_f
return-void
.end method