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/EnclosingClass;
value = Lio/reactivex/internal/operators/observable/ObservableZip;
.end annotation
.annotation system Ldalvik/annotation/InnerClass;
accessFlags = 0x18
name = "ZipCoordinator"
.end annotation
.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 volatile cancelled:Z
.field final delayError:Z
.field final downstream:Lio/reactivex/w;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/w<",
"-TR;>;"
}
.end annotation
.end field
.field final observers:[Lio/reactivex/internal/operators/observable/ObservableZip$a;
.annotation system Ldalvik/annotation/Signature;
value = {
"[",
"Lio/reactivex/internal/operators/observable/ObservableZip$a<",
"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/o;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/b/o<",
"-[",
"Ljava/lang/Object;",
"+TR;>;"
}
.end annotation
.end field
# direct methods
.method constructor <init>(Lio/reactivex/w;Lio/reactivex/b/o;IZ)V
.registers 5
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/w<",
"-TR;>;",
"Lio/reactivex/b/o<",
"-[",
"Ljava/lang/Object;",
"+TR;>;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/ObservableZip$ZipCoordinator;->downstream:Lio/reactivex/w;
.line 3
iput-object p2, p0, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->zipper:Lio/reactivex/b/o;
.line 4
new-array p1, p3, [Lio/reactivex/internal/operators/observable/ObservableZip$a;
iput-object p1, p0, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->observers:[Lio/reactivex/internal/operators/observable/ObservableZip$a;
.line 5
new-array p1, p3, [Ljava/lang/Object;
iput-object p1, p0, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->row:[Ljava/lang/Object;
.line 6
iput-boolean p4, p0, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->delayError:Z
return-void
.end method
# virtual methods
.method cancel()V
.registers 1
.line 1
invoke-virtual {p0}, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->clear()V
.line 2
invoke-virtual {p0}, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->cancelSources()V
return-void
.end method
.method cancelSources()V
.registers 5
.line 1
iget-object v0, p0, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->observers:[Lio/reactivex/internal/operators/observable/ObservableZip$a;
array-length v1, v0
const/4 v2, 0x0
:goto_4
if-ge v2, v1, :cond_e
aget-object v3, v0, v2
.line 2
invoke-virtual {v3}, Lio/reactivex/internal/operators/observable/ObservableZip$a;->a()V
add-int/lit8 v2, v2, 0x1
goto :goto_4
:cond_e
return-void
.end method
.method checkTerminated(ZZLio/reactivex/w;ZLio/reactivex/internal/operators/observable/ObservableZip$a;)Z
.registers 8
.annotation system Ldalvik/annotation/Signature;
value = {
"(ZZ",
"Lio/reactivex/w<",
"-TR;>;Z",
"Lio/reactivex/internal/operators/observable/ObservableZip$a<",
"**>;)Z"
}
.end annotation
.line 1
iget-boolean v0, p0, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->cancelled:Z
const/4 v1, 0x1
if-eqz v0, :cond_9
.line 2
invoke-virtual {p0}, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->cancel()V
return v1
:cond_9
if-eqz p1, :cond_38
if-eqz p4, :cond_20
if-eqz p2, :cond_38
.line 3
iget-object p1, p5, Lio/reactivex/internal/operators/observable/ObservableZip$a;->d:Ljava/lang/Throwable;
.line 4
iput-boolean v1, p0, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->cancelled:Z
.line 5
invoke-virtual {p0}, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->cancel()V
if-eqz p1, :cond_1c
.line 6
invoke-interface {p3, p1}, Lio/reactivex/w;->onError(Ljava/lang/Throwable;)V
goto :goto_1f
.line 7
:cond_1c
invoke-interface {p3}, Lio/reactivex/w;->onComplete()V
:goto_1f
return v1
.line 8
:cond_20
iget-object p1, p5, Lio/reactivex/internal/operators/observable/ObservableZip$a;->d:Ljava/lang/Throwable;
if-eqz p1, :cond_2d
.line 9
iput-boolean v1, p0, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->cancelled:Z
.line 10
invoke-virtual {p0}, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->cancel()V
.line 11
invoke-interface {p3, p1}, Lio/reactivex/w;->onError(Ljava/lang/Throwable;)V
return v1
:cond_2d
if-eqz p2, :cond_38
.line 12
iput-boolean v1, p0, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->cancelled:Z
.line 13
invoke-virtual {p0}, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->cancel()V
.line 14
invoke-interface {p3}, Lio/reactivex/w;->onComplete()V
return v1
:cond_38
const/4 p1, 0x0
return p1
.end method
.method clear()V
.registers 5
.line 1
iget-object v0, p0, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->observers:[Lio/reactivex/internal/operators/observable/ObservableZip$a;
array-length v1, v0
const/4 v2, 0x0
:goto_4
if-ge v2, v1, :cond_10
aget-object v3, v0, v2
.line 2
iget-object v3, v3, Lio/reactivex/internal/operators/observable/ObservableZip$a;->b:Lio/reactivex/internal/queue/a;
invoke-virtual {v3}, Lio/reactivex/internal/queue/a;->clear()V
add-int/lit8 v2, v2, 0x1
goto :goto_4
:cond_10
return-void
.end method
.method public dispose()V
.registers 2
.line 1
iget-boolean v0, p0, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->cancelled:Z
if-nez v0, :cond_13
const/4 v0, 0x1
.line 2
iput-boolean v0, p0, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->cancelled:Z
.line 3
invoke-virtual {p0}, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->cancelSources()V
.line 4
invoke-virtual {p0}, Ljava/util/concurrent/atomic/AtomicInteger;->getAndIncrement()I
move-result v0
if-nez v0, :cond_13
.line 5
invoke-virtual {p0}, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->clear()V
:cond_13
return-void
.end method
.method public drain()V
.registers 21
move-object/from16 v7, p0
.line 1
invoke-virtual/range {p0 .. p0}, Ljava/util/concurrent/atomic/AtomicInteger;->getAndIncrement()I
move-result v0
if-eqz v0, :cond_9
return-void
.line 2
:cond_9
iget-object v0, v7, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->observers:[Lio/reactivex/internal/operators/observable/ObservableZip$a;
.line 3
iget-object v8, v7, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->downstream:Lio/reactivex/w;
.line 4
iget-object v9, v7, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->row:[Ljava/lang/Object;
.line 5
iget-boolean v10, v7, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->delayError:Z
const/4 v11, 0x1
const/4 v12, 0x1
.line 6
:cond_13
:goto_13
array-length v13, v0
const/4 v14, 0x0
const/4 v15, 0x0
const/16 v16, 0x0
const/16 v17, 0x0
:goto_1a
if-ge v15, v13, :cond_5e
aget-object v6, v0, v15
.line 7
aget-object v1, v9, v17
if-nez v1, :cond_46
.line 8
iget-boolean v2, v6, Lio/reactivex/internal/operators/observable/ObservableZip$a;->c:Z
.line 9
iget-object v1, v6, Lio/reactivex/internal/operators/observable/ObservableZip$a;->b:Lio/reactivex/internal/queue/a;
invoke-virtual {v1}, Lio/reactivex/internal/queue/a;->poll()Ljava/lang/Object;
move-result-object v18
if-nez v18, :cond_2f
const/16 v19, 0x1
goto :goto_31
:cond_2f
const/16 v19, 0x0
:goto_31
move-object/from16 v1, p0
move/from16 v3, v19
move-object v4, v8
move v5, v10
.line 10
invoke-virtual/range {v1 .. v6}, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->checkTerminated(ZZLio/reactivex/w;ZLio/reactivex/internal/operators/observable/ObservableZip$a;)Z
move-result v1
if-eqz v1, :cond_3e
return-void
:cond_3e
if-nez v19, :cond_43
.line 11
aput-object v18, v9, v17
goto :goto_59
:cond_43
add-int/lit8 v16, v16, 0x1
goto :goto_59
.line 12
:cond_46
iget-boolean v1, v6, Lio/reactivex/internal/operators/observable/ObservableZip$a;->c:Z
if-eqz v1, :cond_59
if-nez v10, :cond_59
.line 13
iget-object v1, v6, Lio/reactivex/internal/operators/observable/ObservableZip$a;->d:Ljava/lang/Throwable;
if-eqz v1, :cond_59
.line 14
iput-boolean v11, v7, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->cancelled:Z
.line 15
invoke-virtual/range {p0 .. p0}, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->cancel()V
.line 16
invoke-interface {v8, v1}, Lio/reactivex/w;->onError(Ljava/lang/Throwable;)V
return-void
:cond_59
:goto_59
add-int/lit8 v17, v17, 0x1
add-int/lit8 v15, v15, 0x1
goto :goto_1a
:cond_5e
if-eqz v16, :cond_68
neg-int v1, v12
.line 17
invoke-virtual {v7, v1}, Ljava/util/concurrent/atomic/AtomicInteger;->addAndGet(I)I
move-result v12
if-nez v12, :cond_13
return-void
.line 18
:cond_68
:try_start_68
iget-object v1, v7, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->zipper:Lio/reactivex/b/o;
invoke-virtual {v9}, [Ljava/lang/Object;->clone()Ljava/lang/Object;
move-result-object v2
invoke-interface {v1, v2}, Lio/reactivex/b/o;->apply(Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v1
const-string v2, "The zipper returned a null value"
invoke-static {v1, v2}, Lio/reactivex/internal/functions/a;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
:try_end_77
.catch Ljava/lang/Throwable; {:try_start_68 .. :try_end_77} :catch_7f
.line 19
invoke-interface {v8, v1}, Lio/reactivex/w;->onNext(Ljava/lang/Object;)V
const/4 v1, 0x0
.line 20
invoke-static {v9, v1}, Ljava/util/Arrays;->fill([Ljava/lang/Object;Ljava/lang/Object;)V
goto :goto_13
:catch_7f
move-exception v0
.line 21
invoke-static {v0}, Lio/reactivex/exceptions/a;->b(Ljava/lang/Throwable;)V
.line 22
invoke-virtual/range {p0 .. p0}, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->cancel()V
.line 23
invoke-interface {v8, v0}, Lio/reactivex/w;->onError(Ljava/lang/Throwable;)V
return-void
.end method
.method public isDisposed()Z
.registers 2
.line 1
iget-boolean v0, p0, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->cancelled:Z
return v0
.end method
.method public subscribe([Lio/reactivex/u;I)V
.registers 8
.annotation system Ldalvik/annotation/Signature;
value = {
"([",
"Lio/reactivex/u<",
"+TT;>;I)V"
}
.end annotation
.line 1
iget-object v0, p0, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->observers:[Lio/reactivex/internal/operators/observable/ObservableZip$a;
.line 2
array-length v1, v0
const/4 v2, 0x0
const/4 v3, 0x0
:goto_5
if-ge v3, v1, :cond_11
.line 3
new-instance v4, Lio/reactivex/internal/operators/observable/ObservableZip$a;
invoke-direct {v4, p0, p2}, Lio/reactivex/internal/operators/observable/ObservableZip$a;-><init>(Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;I)V
aput-object v4, v0, v3
add-int/lit8 v3, v3, 0x1
goto :goto_5
.line 4
:cond_11
invoke-virtual {p0, v2}, Ljava/util/concurrent/atomic/AtomicInteger;->lazySet(I)V
.line 5
iget-object p2, p0, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->downstream:Lio/reactivex/w;
invoke-interface {p2, p0}, Lio/reactivex/w;->onSubscribe(Lio/reactivex/disposables/b;)V
:goto_19
if-ge v2, v1, :cond_2a
.line 6
iget-boolean p2, p0, Lio/reactivex/internal/operators/observable/ObservableZip$ZipCoordinator;->cancelled:Z
if-eqz p2, :cond_20
return-void
.line 7
:cond_20
aget-object p2, p1, v2
aget-object v3, v0, v2
invoke-interface {p2, v3}, Lio/reactivex/u;->subscribe(Lio/reactivex/w;)V
add-int/lit8 v2, v2, 0x1
goto :goto_19
:cond_2a
return-void
.end method