k$a.smali
.class final Lrx/c/a/k$a;
.super Lrx/i;
.source "SourceFile"
# annotations
.annotation system Ldalvik/annotation/EnclosingClass;
value = Lrx/c/a/k;
.end annotation
.annotation system Ldalvik/annotation/InnerClass;
accessFlags = 0x18
name = "a"
.end annotation
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
"R:",
"Ljava/lang/Object;",
">",
"Lrx/i<",
"TT;>;"
}
.end annotation
# instance fields
.field final a:Lrx/i;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lrx/i<",
"-TR;>;"
}
.end annotation
.end field
.field final b:Lrx/b/f;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lrx/b/f<",
"-TT;+",
"Ljava/lang/Iterable<",
"+TR;>;>;"
}
.end annotation
.end field
.field final c:J
.field final d:Ljava/util/Queue;
.annotation system Ldalvik/annotation/Signature;
value = {
"Ljava/util/Queue<",
"Ljava/lang/Object;",
">;"
}
.end annotation
.end field
.field final e: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 f:Ljava/util/concurrent/atomic/AtomicLong;
.field final g:Ljava/util/concurrent/atomic/AtomicInteger;
.field final h:Lrx/c/a/f;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lrx/c/a/f<",
"TT;>;"
}
.end annotation
.end field
.field volatile i:Z
.field j:J
.field k:Ljava/util/Iterator;
.annotation system Ldalvik/annotation/Signature;
value = {
"Ljava/util/Iterator<",
"+TR;>;"
}
.end annotation
.end field
# direct methods
.method public constructor <init>(Lrx/i;Lrx/b/f;I)V
.registers 4
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lrx/i<",
"-TR;>;",
"Lrx/b/f<",
"-TT;+",
"Ljava/lang/Iterable<",
"+TR;>;>;I)V"
}
.end annotation
.line 102
invoke-direct {p0}, Lrx/i;-><init>()V
.line 103
iput-object p1, p0, Lrx/c/a/k$a;->a:Lrx/i;
.line 104
iput-object p2, p0, Lrx/c/a/k$a;->b:Lrx/b/f;
.line 105
new-instance p1, Ljava/util/concurrent/atomic/AtomicReference;
invoke-direct {p1}, Ljava/util/concurrent/atomic/AtomicReference;-><init>()V
iput-object p1, p0, Lrx/c/a/k$a;->e:Ljava/util/concurrent/atomic/AtomicReference;
.line 106
new-instance p1, Ljava/util/concurrent/atomic/AtomicInteger;
invoke-direct {p1}, Ljava/util/concurrent/atomic/AtomicInteger;-><init>()V
iput-object p1, p0, Lrx/c/a/k$a;->g:Ljava/util/concurrent/atomic/AtomicInteger;
.line 107
new-instance p1, Ljava/util/concurrent/atomic/AtomicLong;
invoke-direct {p1}, Ljava/util/concurrent/atomic/AtomicLong;-><init>()V
iput-object p1, p0, Lrx/c/a/k$a;->f:Ljava/util/concurrent/atomic/AtomicLong;
.line 108
invoke-static {}, Lrx/c/a/f;->a()Lrx/c/a/f;
move-result-object p1
iput-object p1, p0, Lrx/c/a/k$a;->h:Lrx/c/a/f;
const p1, 0x7fffffff
if-ne p3, p1, :cond_38
const-wide p1, 0x7fffffffffffffffL
.line 110
iput-wide p1, p0, Lrx/c/a/k$a;->c:J
.line 111
new-instance p1, Lrx/c/e/a/d;
sget p2, Lrx/c/e/i;->b:I
invoke-direct {p1, p2}, Lrx/c/e/a/d;-><init>(I)V
iput-object p1, p0, Lrx/c/a/k$a;->d:Ljava/util/Queue;
goto :goto_54
:cond_38
shr-int/lit8 p1, p3, 0x2
sub-int p1, p3, p1
int-to-long p1, p1
.line 114
iput-wide p1, p0, Lrx/c/a/k$a;->c:J
.line 115
invoke-static {}, Lrx/c/e/b/y;->a()Z
move-result p1
if-eqz p1, :cond_4d
.line 116
new-instance p1, Lrx/c/e/b/r;
invoke-direct {p1, p3}, Lrx/c/e/b/r;-><init>(I)V
iput-object p1, p0, Lrx/c/a/k$a;->d:Ljava/util/Queue;
goto :goto_54
.line 118
:cond_4d
new-instance p1, Lrx/c/e/a/b;
invoke-direct {p1, p3}, Lrx/c/e/a/b;-><init>(I)V
iput-object p1, p0, Lrx/c/a/k$a;->d:Ljava/util/Queue;
:goto_54
int-to-long p1, p3
.line 121
invoke-virtual {p0, p1, p2}, Lrx/c/a/k$a;->a(J)V
return-void
.end method
.method private a(ZZLrx/i;Ljava/util/Queue;)Z
.registers 8
.annotation system Ldalvik/annotation/Signature;
value = {
"(ZZ",
"Lrx/i<",
"*>;",
"Ljava/util/Queue<",
"*>;)Z"
}
.end annotation
.line 290
invoke-virtual {p3}, Lrx/i;->isUnsubscribed()Z
move-result v0
const/4 v1, 0x0
const/4 v2, 0x1
if-eqz v0, :cond_e
.line 291
invoke-interface {p4}, Ljava/util/Queue;->clear()V
.line 292
iput-object v1, p0, Lrx/c/a/k$a;->k:Ljava/util/Iterator;
return v2
:cond_e
if-eqz p1, :cond_32
.line 297
iget-object p1, p0, Lrx/c/a/k$a;->e:Ljava/util/concurrent/atomic/AtomicReference;
invoke-virtual {p1}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object;
move-result-object p1
check-cast p1, Ljava/lang/Throwable;
if-eqz p1, :cond_2c
.line 299
iget-object p1, p0, Lrx/c/a/k$a;->e:Ljava/util/concurrent/atomic/AtomicReference;
invoke-static {p1}, Lrx/c/e/c;->terminate(Ljava/util/concurrent/atomic/AtomicReference;)Ljava/lang/Throwable;
move-result-object p1
.line 300
invoke-virtual {p0}, Lrx/c/a/k$a;->unsubscribe()V
.line 301
invoke-interface {p4}, Ljava/util/Queue;->clear()V
.line 302
iput-object v1, p0, Lrx/c/a/k$a;->k:Ljava/util/Iterator;
.line 304
invoke-virtual {p3, p1}, Lrx/i;->a(Ljava/lang/Throwable;)V
return v2
:cond_2c
if-eqz p2, :cond_32
.line 309
invoke-virtual {p3}, Lrx/i;->a()V
return v2
:cond_32
const/4 p1, 0x0
return p1
.end method
# virtual methods
.method public final a()V
.registers 2
const/4 v0, 0x1
.line 146
iput-boolean v0, p0, Lrx/c/a/k$a;->i:Z
.line 147
invoke-virtual {p0}, Lrx/c/a/k$a;->c()V
return-void
.end method
.method public final a(Ljava/lang/Object;)V
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"(TT;)V"
}
.end annotation
.line 126
iget-object v0, p0, Lrx/c/a/k$a;->d:Ljava/util/Queue;
invoke-static {p1}, Lrx/c/a/f;->a(Ljava/lang/Object;)Ljava/lang/Object;
move-result-object p1
invoke-interface {v0, p1}, Ljava/util/Queue;->offer(Ljava/lang/Object;)Z
move-result p1
if-nez p1, :cond_18
.line 127
invoke-virtual {p0}, Lrx/c/a/k$a;->unsubscribe()V
.line 128
new-instance p1, Lrx/exceptions/MissingBackpressureException;
invoke-direct {p1}, Lrx/exceptions/MissingBackpressureException;-><init>()V
invoke-virtual {p0, p1}, Lrx/c/a/k$a;->a(Ljava/lang/Throwable;)V
return-void
.line 131
:cond_18
invoke-virtual {p0}, Lrx/c/a/k$a;->c()V
return-void
.end method
.method public final a(Ljava/lang/Throwable;)V
.registers 3
.line 136
iget-object v0, p0, Lrx/c/a/k$a;->e:Ljava/util/concurrent/atomic/AtomicReference;
invoke-static {v0, p1}, Lrx/c/e/c;->addThrowable(Ljava/util/concurrent/atomic/AtomicReference;Ljava/lang/Throwable;)Z
move-result v0
if-eqz v0, :cond_f
const/4 p1, 0x1
.line 137
iput-boolean p1, p0, Lrx/c/a/k$a;->i:Z
.line 138
invoke-virtual {p0}, Lrx/c/a/k$a;->c()V
return-void
.line 140
:cond_f
invoke-static {p1}, Lrx/f/c;->a(Ljava/lang/Throwable;)V
return-void
.end method
.method final c()V
.registers 18
move-object/from16 v1, p0
.line 160
iget-object v0, v1, Lrx/c/a/k$a;->g:Ljava/util/concurrent/atomic/AtomicInteger;
invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicInteger;->getAndIncrement()I
move-result v0
if-eqz v0, :cond_b
return-void
.line 164
:cond_b
iget-object v2, v1, Lrx/c/a/k$a;->a:Lrx/i;
.line 165
iget-object v3, v1, Lrx/c/a/k$a;->d:Ljava/util/Queue;
const/4 v5, 0x1
.line 171
:cond_10
:goto_10
iget-object v0, v1, Lrx/c/a/k$a;->k:Ljava/util/Iterator;
const-wide/16 v6, 0x1
const-wide/16 v8, 0x0
const/4 v10, 0x0
if-nez v0, :cond_61
.line 174
iget-boolean v11, v1, Lrx/c/a/k$a;->i:Z
.line 176
invoke-interface {v3}, Ljava/util/Queue;->poll()Ljava/lang/Object;
move-result-object v12
if-nez v12, :cond_23
const/4 v13, 0x1
goto :goto_24
:cond_23
const/4 v13, 0x0
.line 180
:goto_24
invoke-direct {v1, v11, v13, v2, v3}, Lrx/c/a/k$a;->a(ZZLrx/i;Ljava/util/Queue;)Z
move-result v11
if-eqz v11, :cond_2b
return-void
:cond_2b
if-nez v13, :cond_61
.line 186
iget-wide v13, v1, Lrx/c/a/k$a;->j:J
add-long/2addr v13, v6
move v15, v5
.line 187
iget-wide v4, v1, Lrx/c/a/k$a;->c:J
cmp-long v0, v13, v4
if-nez v0, :cond_3d
.line 188
iput-wide v8, v1, Lrx/c/a/k$a;->j:J
.line 189
invoke-virtual {v1, v13, v14}, Lrx/c/a/k$a;->a(J)V
goto :goto_3f
.line 191
:cond_3d
iput-wide v13, v1, Lrx/c/a/k$a;->j:J
.line 197
:goto_3f
:try_start_3f
iget-object v0, v1, Lrx/c/a/k$a;->b:Lrx/b/f;
invoke-static {v12}, Lrx/c/a/f;->d(Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v4
invoke-interface {v0, v4}, Lrx/b/f;->call(Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v0
check-cast v0, Ljava/lang/Iterable;
.line 199
invoke-interface {v0}, Ljava/lang/Iterable;->iterator()Ljava/util/Iterator;
move-result-object v0
.line 201
invoke-interface {v0}, Ljava/util/Iterator;->hasNext()Z
move-result v4
:try_end_53
.catchall {:try_start_3f .. :try_end_53} :catchall_58
if-eqz v4, :cond_cb
.line 215
iput-object v0, v1, Lrx/c/a/k$a;->k:Ljava/util/Iterator;
goto :goto_62
:catchall_58
move-exception v0
.line 203
invoke-static {v0}, Lrx/exceptions/a;->b(Ljava/lang/Throwable;)V
.line 206
invoke-virtual {v1, v0}, Lrx/c/a/k$a;->a(Ljava/lang/Throwable;)V
goto/16 :goto_cb
:cond_61
move v15, v5
:goto_62
if-eqz v0, :cond_ce
.line 220
iget-object v4, v1, Lrx/c/a/k$a;->f:Ljava/util/concurrent/atomic/AtomicLong;
invoke-virtual {v4}, Ljava/util/concurrent/atomic/AtomicLong;->get()J
move-result-wide v4
move-wide v12, v8
:cond_6b
const/4 v14, 0x0
cmp-long v16, v12, v4
if-eqz v16, :cond_a9
.line 224
iget-boolean v11, v1, Lrx/c/a/k$a;->i:Z
invoke-direct {v1, v11, v10, v2, v3}, Lrx/c/a/k$a;->a(ZZLrx/i;Ljava/util/Queue;)Z
move-result v11
if-eqz v11, :cond_79
return-void
.line 231
:cond_79
:try_start_79
invoke-interface {v0}, Ljava/util/Iterator;->next()Ljava/lang/Object;
move-result-object v11
:try_end_7d
.catchall {:try_start_79 .. :try_end_7d} :catchall_9e
.line 240
invoke-virtual {v2, v11}, Lrx/i;->a(Ljava/lang/Object;)V
.line 242
iget-boolean v11, v1, Lrx/c/a/k$a;->i:Z
invoke-direct {v1, v11, v10, v2, v3}, Lrx/c/a/k$a;->a(ZZLrx/i;Ljava/util/Queue;)Z
move-result v11
if-eqz v11, :cond_89
return-void
:cond_89
add-long/2addr v12, v6
.line 251
:try_start_8a
invoke-interface {v0}, Ljava/util/Iterator;->hasNext()Z
move-result v11
:try_end_8e
.catchall {:try_start_8a .. :try_end_8e} :catchall_93
if-nez v11, :cond_6b
.line 262
iput-object v14, v1, Lrx/c/a/k$a;->k:Ljava/util/Iterator;
goto :goto_a8
:catchall_93
move-exception v0
move-object v6, v0
.line 253
invoke-static {v6}, Lrx/exceptions/a;->b(Ljava/lang/Throwable;)V
.line 255
iput-object v14, v1, Lrx/c/a/k$a;->k:Ljava/util/Iterator;
.line 256
invoke-virtual {v1, v6}, Lrx/c/a/k$a;->a(Ljava/lang/Throwable;)V
goto :goto_a8
:catchall_9e
move-exception v0
move-object v6, v0
.line 233
invoke-static {v6}, Lrx/exceptions/a;->b(Ljava/lang/Throwable;)V
.line 235
iput-object v14, v1, Lrx/c/a/k$a;->k:Ljava/util/Iterator;
.line 236
invoke-virtual {v1, v6}, Lrx/c/a/k$a;->a(Ljava/lang/Throwable;)V
:goto_a8
move-object v0, v14
:cond_a9
cmp-long v6, v12, v4
if-nez v6, :cond_bf
.line 268
iget-boolean v4, v1, Lrx/c/a/k$a;->i:Z
invoke-interface {v3}, Ljava/util/Queue;->isEmpty()Z
move-result v5
if-eqz v5, :cond_b8
if-nez v0, :cond_b8
const/4 v10, 0x1
:cond_b8
invoke-direct {v1, v4, v10, v2, v3}, Lrx/c/a/k$a;->a(ZZLrx/i;Ljava/util/Queue;)Z
move-result v4
if-eqz v4, :cond_bf
return-void
:cond_bf
cmp-long v4, v12, v8
if-eqz v4, :cond_c8
.line 274
iget-object v4, v1, Lrx/c/a/k$a;->f:Ljava/util/concurrent/atomic/AtomicLong;
invoke-static {v4, v12, v13}, Lrx/c/a/a;->b(Ljava/util/concurrent/atomic/AtomicLong;J)J
:cond_c8
if-eqz v0, :cond_cb
goto :goto_ce
:cond_cb
:goto_cb
move v5, v15
goto/16 :goto_10
.line 282
:cond_ce
:goto_ce
iget-object v0, v1, Lrx/c/a/k$a;->g:Ljava/util/concurrent/atomic/AtomicInteger;
neg-int v4, v15
invoke-virtual {v0, v4}, Ljava/util/concurrent/atomic/AtomicInteger;->addAndGet(I)I
move-result v5
if-nez v5, :cond_10
return-void
.end method