ObservableZip$ZipCoordinator.smali
.class final Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;
.super Ljava/util/concurrent/atomic/AtomicInteger;
.source "ObservableZip.java"
# interfaces
.implements Lio/reactivex/disposables/b;
# annotations
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
"R:",
"Ljava/lang/Object;",
">",
"Ljava/util/concurrent/atomic/AtomicInteger;",
"Lio/reactivex/disposables/b;"
}
.end annotation
# static fields
.field private static final serialVersionUID:J = 0x296842a962149c03L
# instance fields
.field final actual:Lio/reactivex/r;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/r",
"<-TR;>;"
}
.end annotation
.end field
.field volatile cancelled:Z
.field final delayError:Z
.field final observers:[Lio/reactivex/internal/operators/observable/hh;
.annotation system Ldalvik/annotation/Signature;
value = {
"[",
"Lio/reactivex/internal/operators/observable/hh",
"<TT;TR;>;"
}
.end annotation
.end field
.field final row:[Ljava/lang/Object;
.annotation system Ldalvik/annotation/Signature;
value = {
"[TT;"
}
.end annotation
.end field
.field final zipper:Lio/reactivex/b/h;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/b/h",
"<-[",
"Ljava/lang/Object;",
"+TR;>;"
}
.end annotation
.end field
# direct methods
.method constructor <init>(Lio/reactivex/r;Lio/reactivex/b/h;IZ)V
.registers 6
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/r",
"<-TR;>;",
"Lio/reactivex/b/h",
"<-[",
"Ljava/lang/Object;",
"+TR;>;IZ)V"
}
.end annotation
.prologue
.line 89
invoke-direct {p0}, Ljava/util/concurrent/atomic/AtomicInteger;-><init>()V
.line 90
iput-object p1, p0, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->actual:Lio/reactivex/r;
.line 91
iput-object p2, p0, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->zipper:Lio/reactivex/b/h;
.line 92
new-array v0, p3, [Lio/reactivex/internal/operators/observable/hh;
iput-object v0, p0, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->observers:[Lio/reactivex/internal/operators/observable/hh;
.line 93
new-array v0, p3, [Ljava/lang/Object;
check-cast v0, [Ljava/lang/Object;
iput-object v0, p0, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->row:[Ljava/lang/Object;
.line 94
iput-boolean p4, p0, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->delayError:Z
.line 95
return-void
.end method
# virtual methods
.method final cancel()V
.registers 1
.prologue
.line 131
invoke-virtual {p0}, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->clear()V
.line 132
invoke-virtual {p0}, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->cancelSources()V
.line 133
return-void
.end method
.method final cancelSources()V
.registers 5
.prologue
.line 136
iget-object v1, p0, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->observers:[Lio/reactivex/internal/operators/observable/hh;
array-length v2, v1
const/4 v0, 0x0
:goto_4
if-ge v0, v2, :cond_10
aget-object v3, v1, v0
.line 1293
iget-object v3, v3, Lio/reactivex/internal/operators/observable/hh;->s:Ljava/util/concurrent/atomic/AtomicReference;
invoke-static {v3}, Lio/reactivex/internal/disposables/DisposableHelper;->dispose(Ljava/util/concurrent/atomic/AtomicReference;)Z
.line 136
add-int/lit8 v0, v0, 0x1
goto :goto_4
.line 139
:cond_10
return-void
.end method
.method final checkTerminated(ZZLio/reactivex/r;ZLio/reactivex/internal/operators/observable/hh;)Z
.registers 8
.annotation system Ldalvik/annotation/Signature;
value = {
"(ZZ",
"Lio/reactivex/r",
"<-TR;>;Z",
"Lio/reactivex/internal/operators/observable/hh",
"<**>;)Z"
}
.end annotation
.prologue
const/4 v0, 0x1
.line 218
iget-boolean v1, p0, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->cancelled:Z
if-eqz v1, :cond_9
.line 219
invoke-virtual {p0}, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->cancel()V
.line 250
:goto_8
return v0
.line 223
:cond_9
if-eqz p1, :cond_32
.line 224
if-eqz p4, :cond_1e
.line 225
if-eqz p2, :cond_32
.line 226
iget-object v1, p5, Lio/reactivex/internal/operators/observable/hh;->error:Ljava/lang/Throwable;
.line 227
invoke-virtual {p0}, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->cancel()V
.line 228
if-eqz v1, :cond_1a
.line 229
invoke-interface {p3, v1}, Lio/reactivex/r;->onError(Ljava/lang/Throwable;)V
goto :goto_8
.line 231
:cond_1a
invoke-interface {p3}, Lio/reactivex/r;->onComplete()V
goto :goto_8
.line 236
:cond_1e
iget-object v1, p5, Lio/reactivex/internal/operators/observable/hh;->error:Ljava/lang/Throwable;
.line 237
if-eqz v1, :cond_29
.line 238
invoke-virtual {p0}, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->cancel()V
.line 239
invoke-interface {p3, v1}, Lio/reactivex/r;->onError(Ljava/lang/Throwable;)V
goto :goto_8
.line 242
:cond_29
if-eqz p2, :cond_32
.line 243
invoke-virtual {p0}, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->cancel()V
.line 244
invoke-interface {p3}, Lio/reactivex/r;->onComplete()V
goto :goto_8
.line 250
:cond_32
const/4 v0, 0x0
goto :goto_8
.end method
.method final clear()V
.registers 5
.prologue
.line 142
iget-object v1, p0, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->observers:[Lio/reactivex/internal/operators/observable/hh;
array-length v2, v1
const/4 v0, 0x0
:goto_4
if-ge v0, v2, :cond_10
aget-object v3, v1, v0
.line 143
iget-object v3, v3, Lio/reactivex/internal/operators/observable/hh;->queue:Lio/reactivex/internal/queue/a;
invoke-virtual {v3}, Lio/reactivex/internal/queue/a;->clear()V
.line 142
add-int/lit8 v0, v0, 0x1
goto :goto_4
.line 145
:cond_10
return-void
.end method
.method public final dispose()V
.registers 2
.prologue
.line 116
iget-boolean v0, p0, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->cancelled:Z
if-nez v0, :cond_13
.line 117
const/4 v0, 0x1
iput-boolean v0, p0, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->cancelled:Z
.line 118
invoke-virtual {p0}, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->cancelSources()V
.line 119
invoke-virtual {p0}, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->getAndIncrement()I
move-result v0
if-nez v0, :cond_13
.line 120
invoke-virtual {p0}, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->clear()V
.line 123
:cond_13
return-void
.end method
.method public final drain()V
.registers 15
.prologue
.line 148
invoke-virtual {p0}, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->getAndIncrement()I
move-result v0
if-eqz v0, :cond_7
.line 212
:cond_6
:goto_6
return-void
.line 152
:cond_7
const/4 v0, 0x1
.line 154
iget-object v10, p0, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->observers:[Lio/reactivex/internal/operators/observable/hh;
.line 155
iget-object v3, p0, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->actual:Lio/reactivex/r;
.line 156
iget-object v11, p0, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->row:[Ljava/lang/Object;
.line 157
iget-boolean v4, p0, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->delayError:Z
move v6, v0
.line 162
:goto_11
const/4 v1, 0x0
.line 163
const/4 v7, 0x0
.line 164
array-length v12, v10
const/4 v0, 0x0
move v8, v0
move v9, v1
:goto_17
if-ge v8, v12, :cond_54
aget-object v5, v10, v8
.line 165
aget-object v0, v11, v9
if-nez v0, :cond_43
.line 166
iget-boolean v1, v5, Lio/reactivex/internal/operators/observable/hh;->done:Z
.line 167
iget-object v0, v5, Lio/reactivex/internal/operators/observable/hh;->queue:Lio/reactivex/internal/queue/a;
invoke-virtual {v0}, Lio/reactivex/internal/queue/a;->poll()Ljava/lang/Object;
move-result-object v13
.line 168
if-nez v13, :cond_3e
const/4 v2, 0x1
:goto_2a
move-object v0, p0
.line 170
invoke-virtual/range {v0 .. v5}, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->checkTerminated(ZZLio/reactivex/r;ZLio/reactivex/internal/operators/observable/hh;)Z
move-result v0
if-nez v0, :cond_6
.line 173
if-nez v2, :cond_40
.line 174
aput-object v13, v11, v9
move v0, v7
.line 188
:goto_36
add-int/lit8 v2, v9, 0x1
.line 164
add-int/lit8 v1, v8, 0x1
move v8, v1
move v7, v0
move v9, v2
goto :goto_17
.line 168
:cond_3e
const/4 v2, 0x0
goto :goto_2a
.line 176
:cond_40
add-int/lit8 v0, v7, 0x1
.line 178
goto :goto_36
.line 179
:cond_43
iget-boolean v0, v5, Lio/reactivex/internal/operators/observable/hh;->done:Z
if-eqz v0, :cond_82
if-nez v4, :cond_82
.line 180
iget-object v0, v5, Lio/reactivex/internal/operators/observable/hh;->error:Ljava/lang/Throwable;
.line 181
if-eqz v0, :cond_82
.line 182
invoke-virtual {p0}, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->cancel()V
.line 183
invoke-interface {v3, v0}, Lio/reactivex/r;->onError(Ljava/lang/Throwable;)V
goto :goto_6
.line 191
:cond_54
if-nez v7, :cond_79
.line 197
:try_start_56
iget-object v0, p0, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->zipper:Lio/reactivex/b/h;
invoke-virtual {v11}, [Ljava/lang/Object;->clone()Ljava/lang/Object;
move-result-object v1
invoke-interface {v0, v1}, Lio/reactivex/b/h;->apply(Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v0
const-string v1, "The zipper returned a null value"
invoke-static {v0, v1}, Lio/reactivex/internal/functions/aj;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
:try_end_65
.catch Ljava/lang/Throwable; {:try_start_56 .. :try_end_65} :catch_6e
move-result-object v0
.line 205
invoke-interface {v3, v0}, Lio/reactivex/r;->onNext(Ljava/lang/Object;)V
.line 207
const/4 v0, 0x0
invoke-static {v11, v0}, Ljava/util/Arrays;->fill([Ljava/lang/Object;Ljava/lang/Object;)V
goto :goto_11
.line 198
:catch_6e
move-exception v0
.line 199
invoke-static {v0}, Lio/reactivex/exceptions/d;->throwIfFatal(Ljava/lang/Throwable;)V
.line 200
invoke-virtual {p0}, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->cancel()V
.line 201
invoke-interface {v3, v0}, Lio/reactivex/r;->onError(Ljava/lang/Throwable;)V
goto :goto_6
.line 210
:cond_79
neg-int v0, v6
invoke-virtual {p0, v0}, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->addAndGet(I)I
move-result v0
.line 211
if-eqz v0, :cond_6
move v6, v0
goto :goto_11
:cond_82
move v0, v7
goto :goto_36
.end method
.method public final isDisposed()Z
.registers 2
.prologue
.line 127
iget-boolean v0, p0, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->cancelled:Z
return v0
.end method
.method public final subscribe([Lio/reactivex/p;I)V
.registers 8
.annotation system Ldalvik/annotation/Signature;
value = {
"([",
"Lio/reactivex/p",
"<+TT;>;I)V"
}
.end annotation
.prologue
const/4 v0, 0x0
.line 98
iget-object v2, p0, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->observers:[Lio/reactivex/internal/operators/observable/hh;
.line 99
array-length v3, v2
move v1, v0
.line 100
:goto_5
if-ge v1, v3, :cond_11
.line 101
new-instance v4, Lio/reactivex/internal/operators/observable/hh;
invoke-direct {v4, p0, p2}, Lio/reactivex/internal/operators/observable/hh;-><init>(Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;I)V
aput-object v4, v2, v1
.line 100
add-int/lit8 v1, v1, 0x1
goto :goto_5
.line 104
:cond_11
invoke-virtual {p0, v0}, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->lazySet(I)V
.line 105
iget-object v1, p0, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->actual:Lio/reactivex/r;
invoke-interface {v1, p0}, Lio/reactivex/r;->onSubscribe(Lio/reactivex/disposables/b;)V
.line 106
:goto_19
if-ge v0, v3, :cond_1f
.line 107
iget-boolean v1, p0, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->cancelled:Z
if-eqz v1, :cond_20
.line 112
:cond_1f
return-void
.line 110
:cond_20
aget-object v1, p1, v0
aget-object v4, v2, v0
invoke-interface {v1, v4}, Lio/reactivex/p;->subscribe(Lio/reactivex/r;)V
.line 106
add-int/lit8 v0, v0, 0x1
goto :goto_19
.end method