ObservableJoin$JoinDisposable.smali
.class final Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;
.super Ljava/util/concurrent/atomic/AtomicInteger;
.source "ObservableJoin.java"
# interfaces
.implements Lio/reactivex/disposables/Disposable;
.implements Lio/reactivex/internal/operators/observable/ObservableGroupJoin$JoinSupport;
# annotations
.annotation system Ldalvik/annotation/EnclosingClass;
value = Lio/reactivex/internal/operators/observable/ObservableJoin;
.end annotation
.annotation system Ldalvik/annotation/InnerClass;
accessFlags = 0x18
name = "JoinDisposable"
.end annotation
.annotation system Ldalvik/annotation/Signature;
value = {
"<T",
"Left:Ljava/lang/Object;",
"TRight:",
"Ljava/lang/Object;",
"T",
"LeftEnd:Ljava/lang/Object;",
"TRightEnd:",
"Ljava/lang/Object;",
"R:",
"Ljava/lang/Object;",
">",
"Ljava/util/concurrent/atomic/AtomicInteger;",
"Lio/reactivex/disposables/Disposable;",
"Lio/reactivex/internal/operators/observable/ObservableGroupJoin$JoinSupport;"
}
.end annotation
# static fields
.field static final LEFT_CLOSE:Ljava/lang/Integer;
.field static final LEFT_VALUE:Ljava/lang/Integer;
.field static final RIGHT_CLOSE:Ljava/lang/Integer;
.field static final RIGHT_VALUE:Ljava/lang/Integer;
.field private static final serialVersionUID:J = -0x54414b546f40e739L
# instance fields
.field final active:Ljava/util/concurrent/atomic/AtomicInteger;
.field final actual:Lio/reactivex/Observer;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/Observer<",
"-TR;>;"
}
.end annotation
.end field
.field volatile cancelled:Z
.field final disposables:Lio/reactivex/disposables/CompositeDisposable;
.field final error: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 leftEnd:Lio/reactivex/functions/Function;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/functions/Function<",
"-TT",
"Left;",
"+",
"Lio/reactivex/ObservableSource<",
"TT",
"LeftEnd;",
">;>;"
}
.end annotation
.end field
.field leftIndex:I
.field final lefts:Ljava/util/Map;
.annotation system Ldalvik/annotation/Signature;
value = {
"Ljava/util/Map<",
"Ljava/lang/Integer;",
"TT",
"Left;",
">;"
}
.end annotation
.end field
.field final queue:Lio/reactivex/internal/queue/SpscLinkedArrayQueue;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/internal/queue/SpscLinkedArrayQueue<",
"Ljava/lang/Object;",
">;"
}
.end annotation
.end field
.field final resultSelector:Lio/reactivex/functions/BiFunction;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/functions/BiFunction<",
"-TT",
"Left;",
"-TTRight;+TR;>;"
}
.end annotation
.end field
.field final rightEnd:Lio/reactivex/functions/Function;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/functions/Function<",
"-TTRight;+",
"Lio/reactivex/ObservableSource<",
"TTRightEnd;>;>;"
}
.end annotation
.end field
.field rightIndex:I
.field final rights:Ljava/util/Map;
.annotation system Ldalvik/annotation/Signature;
value = {
"Ljava/util/Map<",
"Ljava/lang/Integer;",
"TTRight;>;"
}
.end annotation
.end field
# direct methods
.method static constructor <clinit>()V
.registers 1
.line 106
const/4 v0, 0x1
invoke-static {v0}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer;
move-result-object v0
sput-object v0, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->LEFT_VALUE:Ljava/lang/Integer;
.line 108
const/4 v0, 0x2
invoke-static {v0}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer;
move-result-object v0
sput-object v0, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->RIGHT_VALUE:Ljava/lang/Integer;
.line 110
const/4 v0, 0x3
invoke-static {v0}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer;
move-result-object v0
sput-object v0, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->LEFT_CLOSE:Ljava/lang/Integer;
.line 112
const/4 v0, 0x4
invoke-static {v0}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer;
move-result-object v0
sput-object v0, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->RIGHT_CLOSE:Ljava/lang/Integer;
return-void
.end method
.method constructor <init>(Lio/reactivex/Observer;Lio/reactivex/functions/Function;Lio/reactivex/functions/Function;Lio/reactivex/functions/BiFunction;)V
.registers 7
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/Observer<",
"-TR;>;",
"Lio/reactivex/functions/Function<",
"-TT",
"Left;",
"+",
"Lio/reactivex/ObservableSource<",
"TT",
"LeftEnd;",
">;>;",
"Lio/reactivex/functions/Function<",
"-TTRight;+",
"Lio/reactivex/ObservableSource<",
"TTRightEnd;>;>;",
"Lio/reactivex/functions/BiFunction<",
"-TT",
"Left;",
"-TTRight;+TR;>;)V"
}
.end annotation
.line 117
.local p0, "this":Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;, "Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable<TTLeft;TTRight;TTLeftEnd;TTRightEnd;TR;>;"
.local p1, "actual":Lio/reactivex/Observer;, "Lio/reactivex/Observer<-TR;>;"
.local p2, "leftEnd":Lio/reactivex/functions/Function;, "Lio/reactivex/functions/Function<-TTLeft;+Lio/reactivex/ObservableSource<TTLeftEnd;>;>;"
.local p3, "rightEnd":Lio/reactivex/functions/Function;, "Lio/reactivex/functions/Function<-TTRight;+Lio/reactivex/ObservableSource<TTRightEnd;>;>;"
.local p4, "resultSelector":Lio/reactivex/functions/BiFunction;, "Lio/reactivex/functions/BiFunction<-TTLeft;-TTRight;+TR;>;"
invoke-direct {p0}, Ljava/util/concurrent/atomic/AtomicInteger;-><init>()V
.line 118
iput-object p1, p0, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->actual:Lio/reactivex/Observer;
.line 119
new-instance v0, Lio/reactivex/disposables/CompositeDisposable;
invoke-direct {v0}, Lio/reactivex/disposables/CompositeDisposable;-><init>()V
iput-object v0, p0, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->disposables:Lio/reactivex/disposables/CompositeDisposable;
.line 120
new-instance v0, Lio/reactivex/internal/queue/SpscLinkedArrayQueue;
invoke-static {}, Lio/reactivex/Observable;->bufferSize()I
move-result v1
invoke-direct {v0, v1}, Lio/reactivex/internal/queue/SpscLinkedArrayQueue;-><init>(I)V
iput-object v0, p0, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->queue:Lio/reactivex/internal/queue/SpscLinkedArrayQueue;
.line 121
new-instance v0, Ljava/util/LinkedHashMap;
invoke-direct {v0}, Ljava/util/LinkedHashMap;-><init>()V
iput-object v0, p0, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->lefts:Ljava/util/Map;
.line 122
new-instance v0, Ljava/util/LinkedHashMap;
invoke-direct {v0}, Ljava/util/LinkedHashMap;-><init>()V
iput-object v0, p0, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->rights:Ljava/util/Map;
.line 123
new-instance v0, Ljava/util/concurrent/atomic/AtomicReference;
invoke-direct {v0}, Ljava/util/concurrent/atomic/AtomicReference;-><init>()V
iput-object v0, p0, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->error:Ljava/util/concurrent/atomic/AtomicReference;
.line 124
iput-object p2, p0, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->leftEnd:Lio/reactivex/functions/Function;
.line 125
iput-object p3, p0, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->rightEnd:Lio/reactivex/functions/Function;
.line 126
iput-object p4, p0, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->resultSelector:Lio/reactivex/functions/BiFunction;
.line 127
new-instance v0, Ljava/util/concurrent/atomic/AtomicInteger;
const/4 v1, 0x2
invoke-direct {v0, v1}, Ljava/util/concurrent/atomic/AtomicInteger;-><init>(I)V
iput-object v0, p0, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->active:Ljava/util/concurrent/atomic/AtomicInteger;
.line 128
return-void
.end method
# virtual methods
.method cancelAll()V
.registers 2
.line 147
.local p0, "this":Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;, "Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable<TTLeft;TTRight;TTLeftEnd;TTRightEnd;TR;>;"
iget-object v0, p0, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->disposables:Lio/reactivex/disposables/CompositeDisposable;
invoke-virtual {v0}, Lio/reactivex/disposables/CompositeDisposable;->dispose()V
.line 148
return-void
.end method
.method public dispose()V
.registers 2
.line 132
.local p0, "this":Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;, "Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable<TTLeft;TTRight;TTLeftEnd;TTRightEnd;TR;>;"
iget-boolean v0, p0, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->cancelled:Z
if-nez v0, :cond_15
.line 133
const/4 v0, 0x1
iput-boolean v0, p0, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->cancelled:Z
.line 134
invoke-virtual {p0}, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->cancelAll()V
.line 135
invoke-virtual {p0}, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->getAndIncrement()I
move-result v0
if-nez v0, :cond_15
.line 136
iget-object v0, p0, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->queue:Lio/reactivex/internal/queue/SpscLinkedArrayQueue;
invoke-virtual {v0}, Lio/reactivex/internal/queue/SpscLinkedArrayQueue;->clear()V
.line 139
:cond_15
return-void
.end method
.method drain()V
.registers 18
.line 168
.local p0, "this":Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;, "Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable<TTLeft;TTRight;TTLeftEnd;TTRightEnd;TR;>;"
move-object/from16 v1, p0
invoke-virtual/range {p0 .. p0}, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->getAndIncrement()I
move-result v0
if-eqz v0, :cond_9
.line 169
return-void
.line 172
:cond_9
const/4 v0, 0x1
.line 173
.local v0, "missed":I
iget-object v2, v1, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->queue:Lio/reactivex/internal/queue/SpscLinkedArrayQueue;
.line 174
.local v2, "q":Lio/reactivex/internal/queue/SpscLinkedArrayQueue;, "Lio/reactivex/internal/queue/SpscLinkedArrayQueue<Ljava/lang/Object;>;"
iget-object v3, v1, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->actual:Lio/reactivex/Observer;
move v4, v0
.line 178
.end local v0 # "missed":I
.local v3, "a":Lio/reactivex/Observer;, "Lio/reactivex/Observer<-TR;>;"
.local v4, "missed":I
:cond_f
:goto_f
iget-boolean v0, v1, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->cancelled:Z
if-eqz v0, :cond_17
.line 179
invoke-virtual {v2}, Lio/reactivex/internal/queue/SpscLinkedArrayQueue;->clear()V
.line 180
return-void
.line 183
:cond_17
iget-object v0, v1, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->error:Ljava/util/concurrent/atomic/AtomicReference;
invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object;
move-result-object v0
move-object v5, v0
check-cast v5, Ljava/lang/Throwable;
.line 184
.local v5, "ex":Ljava/lang/Throwable;
if-eqz v5, :cond_2c
.line 185
invoke-virtual {v2}, Lio/reactivex/internal/queue/SpscLinkedArrayQueue;->clear()V
.line 186
invoke-virtual/range {p0 .. p0}, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->cancelAll()V
.line 187
invoke-virtual {v1, v3}, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->errorAll(Lio/reactivex/Observer;)V
.line 188
return-void
.line 191
:cond_2c
iget-object v0, v1, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->active:Ljava/util/concurrent/atomic/AtomicInteger;
invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicInteger;->get()I
move-result v0
const/4 v6, 0x0
const/4 v7, 0x1
if-nez v0, :cond_38
const/4 v0, 0x1
goto :goto_39
:cond_38
const/4 v0, 0x0
:goto_39
move v8, v0
.line 193
.local v8, "d":Z
invoke-virtual {v2}, Lio/reactivex/internal/queue/SpscLinkedArrayQueue;->poll()Ljava/lang/Object;
move-result-object v0
move-object v9, v0
check-cast v9, Ljava/lang/Integer;
.line 195
.local v9, "mode":Ljava/lang/Integer;
if-nez v9, :cond_45
const/4 v0, 0x1
goto :goto_46
:cond_45
const/4 v0, 0x0
:goto_46
move v10, v0
.line 197
.local v10, "empty":Z
if-eqz v8, :cond_5e
if-eqz v10, :cond_5e
.line 199
iget-object v0, v1, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->lefts:Ljava/util/Map;
invoke-interface {v0}, Ljava/util/Map;->clear()V
.line 200
iget-object v0, v1, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->rights:Ljava/util/Map;
invoke-interface {v0}, Ljava/util/Map;->clear()V
.line 201
iget-object v0, v1, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->disposables:Lio/reactivex/disposables/CompositeDisposable;
invoke-virtual {v0}, Lio/reactivex/disposables/CompositeDisposable;->dispose()V
.line 203
invoke-interface {v3}, Lio/reactivex/Observer;->onComplete()V
.line 204
return-void
.line 207
:cond_5e
if-eqz v10, :cond_6a
.line 208
nop
.line 313
.end local v5 # "ex":Ljava/lang/Throwable;
.end local v8 # "d":Z
.end local v9 # "mode":Ljava/lang/Integer;
.end local v10 # "empty":Z
neg-int v0, v4
invoke-virtual {v1, v0}, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->addAndGet(I)I
move-result v4
.line 314
if-nez v4, :cond_f
.line 315
nop
.line 318
return-void
.line 211
.restart local v5 # "ex":Ljava/lang/Throwable;
.restart local v8 # "d":Z
.restart local v9 # "mode":Ljava/lang/Integer;
.restart local v10 # "empty":Z
:cond_6a
invoke-virtual {v2}, Lio/reactivex/internal/queue/SpscLinkedArrayQueue;->poll()Ljava/lang/Object;
move-result-object v11
.line 213
.local v11, "val":Ljava/lang/Object;
sget-object v0, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->LEFT_VALUE:Ljava/lang/Integer;
const-string v12, "The resultSelector returned a null value"
if-ne v9, v0, :cond_eb
.line 215
move-object v6, v11
.line 217
.local v6, "left":Ljava/lang/Object;, "TTLeft;"
iget v0, v1, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->leftIndex:I
add-int/lit8 v13, v0, 0x1
iput v13, v1, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->leftIndex:I
move v13, v0
.line 218
.local v13, "idx":I
iget-object v0, v1, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->lefts:Ljava/util/Map;
invoke-static {v13}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer;
move-result-object v14
invoke-interface {v0, v14, v6}, Ljava/util/Map;->put(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
.line 223
:try_start_85
iget-object v0, v1, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->leftEnd:Lio/reactivex/functions/Function;
invoke-interface {v0, v6}, Lio/reactivex/functions/Function;->apply(Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v0
const-string v14, "The leftEnd returned a null ObservableSource"
invoke-static {v0, v14}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
move-result-object v0
check-cast v0, Lio/reactivex/ObservableSource;
:try_end_93
.catchall {:try_start_85 .. :try_end_93} :catchall_e6
move-object v14, v0
.line 227
.local v14, "p":Lio/reactivex/ObservableSource;, "Lio/reactivex/ObservableSource<TTLeftEnd;>;"
nop
.line 229
new-instance v0, Lio/reactivex/internal/operators/observable/ObservableGroupJoin$LeftRightEndObserver;
invoke-direct {v0, v1, v7, v13}, Lio/reactivex/internal/operators/observable/ObservableGroupJoin$LeftRightEndObserver;-><init>(Lio/reactivex/internal/operators/observable/ObservableGroupJoin$JoinSupport;ZI)V
move-object v7, v0
.line 230
.local v7, "end":Lio/reactivex/internal/operators/observable/ObservableGroupJoin$LeftRightEndObserver;
iget-object v0, v1, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->disposables:Lio/reactivex/disposables/CompositeDisposable;
invoke-virtual {v0, v7}, Lio/reactivex/disposables/CompositeDisposable;->add(Lio/reactivex/disposables/Disposable;)Z
.line 232
invoke-interface {v14, v7}, Lio/reactivex/ObservableSource;->subscribe(Lio/reactivex/Observer;)V
.line 234
iget-object v0, v1, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->error:Ljava/util/concurrent/atomic/AtomicReference;
invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object;
move-result-object v0
move-object v5, v0
check-cast v5, Ljava/lang/Throwable;
.line 235
if-eqz v5, :cond_b8
.line 236
invoke-virtual {v2}, Lio/reactivex/internal/queue/SpscLinkedArrayQueue;->clear()V
.line 237
invoke-virtual/range {p0 .. p0}, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->cancelAll()V
.line 238
invoke-virtual {v1, v3}, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->errorAll(Lio/reactivex/Observer;)V
.line 239
return-void
.line 242
:cond_b8
iget-object v0, v1, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->rights:Ljava/util/Map;
invoke-interface {v0}, Ljava/util/Map;->values()Ljava/util/Collection;
move-result-object v0
invoke-interface {v0}, Ljava/util/Collection;->iterator()Ljava/util/Iterator;
move-result-object v0
:goto_c2
invoke-interface {v0}, Ljava/util/Iterator;->hasNext()Z
move-result v15
if-eqz v15, :cond_e4
invoke-interface {v0}, Ljava/util/Iterator;->next()Ljava/lang/Object;
move-result-object v15
.line 247
.local v15, "right":Ljava/lang/Object;, "TTRight;"
move-object/from16 v16, v0
:try_start_ce
iget-object v0, v1, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->resultSelector:Lio/reactivex/functions/BiFunction;
invoke-interface {v0, v6, v15}, Lio/reactivex/functions/BiFunction;->apply(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v0
invoke-static {v0, v12}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
move-result-object v0
:try_end_d8
.catchall {:try_start_ce .. :try_end_d8} :catchall_df
.line 251
.local v0, "w":Ljava/lang/Object;, "TR;"
nop
.line 253
invoke-interface {v3, v0}, Lio/reactivex/Observer;->onNext(Ljava/lang/Object;)V
.line 254
.end local v0 # "w":Ljava/lang/Object;, "TR;"
.end local v15 # "right":Ljava/lang/Object;, "TTRight;"
move-object/from16 v0, v16
goto :goto_c2
.line 248
.restart local v15 # "right":Ljava/lang/Object;, "TTRight;"
:catchall_df
move-exception v0
.line 249
.local v0, "exc":Ljava/lang/Throwable;
invoke-virtual {v1, v0, v3, v2}, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->fail(Ljava/lang/Throwable;Lio/reactivex/Observer;Lio/reactivex/internal/queue/SpscLinkedArrayQueue;)V
.line 250
return-void
.line 255
.end local v0 # "exc":Ljava/lang/Throwable;
.end local v6 # "left":Ljava/lang/Object;, "TTLeft;"
.end local v7 # "end":Lio/reactivex/internal/operators/observable/ObservableGroupJoin$LeftRightEndObserver;
.end local v13 # "idx":I
.end local v14 # "p":Lio/reactivex/ObservableSource;, "Lio/reactivex/ObservableSource<TTLeftEnd;>;"
.end local v15 # "right":Ljava/lang/Object;, "TTRight;"
:cond_e4
goto/16 :goto_190
.line 224
.restart local v6 # "left":Ljava/lang/Object;, "TTLeft;"
.restart local v13 # "idx":I
:catchall_e6
move-exception v0
.line 225
.restart local v0 # "exc":Ljava/lang/Throwable;
invoke-virtual {v1, v0, v3, v2}, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->fail(Ljava/lang/Throwable;Lio/reactivex/Observer;Lio/reactivex/internal/queue/SpscLinkedArrayQueue;)V
.line 226
return-void
.line 256
.end local v0 # "exc":Ljava/lang/Throwable;
.end local v6 # "left":Ljava/lang/Object;, "TTLeft;"
.end local v13 # "idx":I
:cond_eb
sget-object v0, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->RIGHT_VALUE:Ljava/lang/Integer;
if-ne v9, v0, :cond_165
.line 258
move-object v7, v11
.line 260
.local v7, "right":Ljava/lang/Object;, "TTRight;"
iget v0, v1, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->rightIndex:I
add-int/lit8 v13, v0, 0x1
iput v13, v1, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->rightIndex:I
move v13, v0
.line 262
.restart local v13 # "idx":I
iget-object v0, v1, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->rights:Ljava/util/Map;
invoke-static {v13}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer;
move-result-object v14
invoke-interface {v0, v14, v7}, Ljava/util/Map;->put(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
.line 267
:try_start_100
iget-object v0, v1, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->rightEnd:Lio/reactivex/functions/Function;
invoke-interface {v0, v7}, Lio/reactivex/functions/Function;->apply(Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v0
const-string v14, "The rightEnd returned a null ObservableSource"
invoke-static {v0, v14}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
move-result-object v0
check-cast v0, Lio/reactivex/ObservableSource;
:try_end_10e
.catchall {:try_start_100 .. :try_end_10e} :catchall_160
move-object v14, v0
.line 271
.local v14, "p":Lio/reactivex/ObservableSource;, "Lio/reactivex/ObservableSource<TTRightEnd;>;"
nop
.line 273
new-instance v0, Lio/reactivex/internal/operators/observable/ObservableGroupJoin$LeftRightEndObserver;
invoke-direct {v0, v1, v6, v13}, Lio/reactivex/internal/operators/observable/ObservableGroupJoin$LeftRightEndObserver;-><init>(Lio/reactivex/internal/operators/observable/ObservableGroupJoin$JoinSupport;ZI)V
move-object v6, v0
.line 274
.local v6, "end":Lio/reactivex/internal/operators/observable/ObservableGroupJoin$LeftRightEndObserver;
iget-object v0, v1, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->disposables:Lio/reactivex/disposables/CompositeDisposable;
invoke-virtual {v0, v6}, Lio/reactivex/disposables/CompositeDisposable;->add(Lio/reactivex/disposables/Disposable;)Z
.line 276
invoke-interface {v14, v6}, Lio/reactivex/ObservableSource;->subscribe(Lio/reactivex/Observer;)V
.line 278
iget-object v0, v1, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->error:Ljava/util/concurrent/atomic/AtomicReference;
invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object;
move-result-object v0
move-object v5, v0
check-cast v5, Ljava/lang/Throwable;
.line 279
if-eqz v5, :cond_133
.line 280
invoke-virtual {v2}, Lio/reactivex/internal/queue/SpscLinkedArrayQueue;->clear()V
.line 281
invoke-virtual/range {p0 .. p0}, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->cancelAll()V
.line 282
invoke-virtual {v1, v3}, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->errorAll(Lio/reactivex/Observer;)V
.line 283
return-void
.line 286
:cond_133
iget-object v0, v1, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->lefts:Ljava/util/Map;
invoke-interface {v0}, Ljava/util/Map;->values()Ljava/util/Collection;
move-result-object v0
invoke-interface {v0}, Ljava/util/Collection;->iterator()Ljava/util/Iterator;
move-result-object v0
:goto_13d
invoke-interface {v0}, Ljava/util/Iterator;->hasNext()Z
move-result v15
if-eqz v15, :cond_15f
invoke-interface {v0}, Ljava/util/Iterator;->next()Ljava/lang/Object;
move-result-object v15
.line 291
.local v15, "left":Ljava/lang/Object;, "TTLeft;"
move-object/from16 v16, v0
:try_start_149
iget-object v0, v1, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->resultSelector:Lio/reactivex/functions/BiFunction;
invoke-interface {v0, v15, v7}, Lio/reactivex/functions/BiFunction;->apply(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v0
invoke-static {v0, v12}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
move-result-object v0
:try_end_153
.catchall {:try_start_149 .. :try_end_153} :catchall_15a
.line 295
.local v0, "w":Ljava/lang/Object;, "TR;"
nop
.line 297
invoke-interface {v3, v0}, Lio/reactivex/Observer;->onNext(Ljava/lang/Object;)V
.line 298
.end local v0 # "w":Ljava/lang/Object;, "TR;"
.end local v15 # "left":Ljava/lang/Object;, "TTLeft;"
move-object/from16 v0, v16
goto :goto_13d
.line 292
.restart local v15 # "left":Ljava/lang/Object;, "TTLeft;"
:catchall_15a
move-exception v0
.line 293
.local v0, "exc":Ljava/lang/Throwable;
invoke-virtual {v1, v0, v3, v2}, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->fail(Ljava/lang/Throwable;Lio/reactivex/Observer;Lio/reactivex/internal/queue/SpscLinkedArrayQueue;)V
.line 294
return-void
.line 299
.end local v0 # "exc":Ljava/lang/Throwable;
.end local v6 # "end":Lio/reactivex/internal/operators/observable/ObservableGroupJoin$LeftRightEndObserver;
.end local v7 # "right":Ljava/lang/Object;, "TTRight;"
.end local v13 # "idx":I
.end local v14 # "p":Lio/reactivex/ObservableSource;, "Lio/reactivex/ObservableSource<TTRightEnd;>;"
.end local v15 # "left":Ljava/lang/Object;, "TTLeft;"
:cond_15f
goto :goto_190
.line 268
.restart local v7 # "right":Ljava/lang/Object;, "TTRight;"
.restart local v13 # "idx":I
:catchall_160
move-exception v0
.line 269
.restart local v0 # "exc":Ljava/lang/Throwable;
invoke-virtual {v1, v0, v3, v2}, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->fail(Ljava/lang/Throwable;Lio/reactivex/Observer;Lio/reactivex/internal/queue/SpscLinkedArrayQueue;)V
.line 270
return-void
.line 300
.end local v0 # "exc":Ljava/lang/Throwable;
.end local v7 # "right":Ljava/lang/Object;, "TTRight;"
.end local v13 # "idx":I
:cond_165
sget-object v0, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->LEFT_CLOSE:Ljava/lang/Integer;
if-ne v9, v0, :cond_17d
.line 301
move-object v0, v11
check-cast v0, Lio/reactivex/internal/operators/observable/ObservableGroupJoin$LeftRightEndObserver;
.line 303
.local v0, "end":Lio/reactivex/internal/operators/observable/ObservableGroupJoin$LeftRightEndObserver;
iget-object v6, v1, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->lefts:Ljava/util/Map;
iget v7, v0, Lio/reactivex/internal/operators/observable/ObservableGroupJoin$LeftRightEndObserver;->index:I
invoke-static {v7}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer;
move-result-object v7
invoke-interface {v6, v7}, Ljava/util/Map;->remove(Ljava/lang/Object;)Ljava/lang/Object;
.line 304
iget-object v6, v1, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->disposables:Lio/reactivex/disposables/CompositeDisposable;
invoke-virtual {v6, v0}, Lio/reactivex/disposables/CompositeDisposable;->remove(Lio/reactivex/disposables/Disposable;)Z
.line 305
.end local v0 # "end":Lio/reactivex/internal/operators/observable/ObservableGroupJoin$LeftRightEndObserver;
goto :goto_190
.line 306
:cond_17d
move-object v0, v11
check-cast v0, Lio/reactivex/internal/operators/observable/ObservableGroupJoin$LeftRightEndObserver;
.line 308
.restart local v0 # "end":Lio/reactivex/internal/operators/observable/ObservableGroupJoin$LeftRightEndObserver;
iget-object v6, v1, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->rights:Ljava/util/Map;
iget v7, v0, Lio/reactivex/internal/operators/observable/ObservableGroupJoin$LeftRightEndObserver;->index:I
invoke-static {v7}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer;
move-result-object v7
invoke-interface {v6, v7}, Ljava/util/Map;->remove(Ljava/lang/Object;)Ljava/lang/Object;
.line 309
iget-object v6, v1, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->disposables:Lio/reactivex/disposables/CompositeDisposable;
invoke-virtual {v6, v0}, Lio/reactivex/disposables/CompositeDisposable;->remove(Lio/reactivex/disposables/Disposable;)Z
.line 311
.end local v0 # "end":Lio/reactivex/internal/operators/observable/ObservableGroupJoin$LeftRightEndObserver;
.end local v5 # "ex":Ljava/lang/Throwable;
.end local v8 # "d":Z
.end local v9 # "mode":Ljava/lang/Integer;
.end local v10 # "empty":Z
.end local v11 # "val":Ljava/lang/Object;
:goto_190
goto/16 :goto_f
.end method
.method errorAll(Lio/reactivex/Observer;)V
.registers 4
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/Observer<",
"*>;)V"
}
.end annotation
.line 151
.local p0, "this":Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;, "Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable<TTLeft;TTRight;TTLeftEnd;TTRightEnd;TR;>;"
.local p1, "a":Lio/reactivex/Observer;, "Lio/reactivex/Observer<*>;"
iget-object v0, p0, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->error:Ljava/util/concurrent/atomic/AtomicReference;
invoke-static {v0}, Lio/reactivex/internal/util/ExceptionHelper;->terminate(Ljava/util/concurrent/atomic/AtomicReference;)Ljava/lang/Throwable;
move-result-object v0
.line 153
.local v0, "ex":Ljava/lang/Throwable;
iget-object v1, p0, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->lefts:Ljava/util/Map;
invoke-interface {v1}, Ljava/util/Map;->clear()V
.line 154
iget-object v1, p0, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->rights:Ljava/util/Map;
invoke-interface {v1}, Ljava/util/Map;->clear()V
.line 156
invoke-interface {p1, v0}, Lio/reactivex/Observer;->onError(Ljava/lang/Throwable;)V
.line 157
return-void
.end method
.method fail(Ljava/lang/Throwable;Lio/reactivex/Observer;Lio/reactivex/internal/queue/SpscLinkedArrayQueue;)V
.registers 5
.param p1, "exc" # Ljava/lang/Throwable;
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Ljava/lang/Throwable;",
"Lio/reactivex/Observer<",
"*>;",
"Lio/reactivex/internal/queue/SpscLinkedArrayQueue<",
"*>;)V"
}
.end annotation
.line 160
.local p0, "this":Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;, "Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable<TTLeft;TTRight;TTLeftEnd;TTRightEnd;TR;>;"
.local p2, "a":Lio/reactivex/Observer;, "Lio/reactivex/Observer<*>;"
.local p3, "q":Lio/reactivex/internal/queue/SpscLinkedArrayQueue;, "Lio/reactivex/internal/queue/SpscLinkedArrayQueue<*>;"
invoke-static {p1}, Lio/reactivex/exceptions/Exceptions;->throwIfFatal(Ljava/lang/Throwable;)V
.line 161
iget-object v0, p0, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->error:Ljava/util/concurrent/atomic/AtomicReference;
invoke-static {v0, p1}, Lio/reactivex/internal/util/ExceptionHelper;->addThrowable(Ljava/util/concurrent/atomic/AtomicReference;Ljava/lang/Throwable;)Z
.line 162
invoke-virtual {p3}, Lio/reactivex/internal/queue/SpscLinkedArrayQueue;->clear()V
.line 163
invoke-virtual {p0}, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->cancelAll()V
.line 164
invoke-virtual {p0, p2}, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->errorAll(Lio/reactivex/Observer;)V
.line 165
return-void
.end method
.method public innerClose(ZLio/reactivex/internal/operators/observable/ObservableGroupJoin$LeftRightEndObserver;)V
.registers 5
.param p1, "isLeft" # Z
.param p2, "index" # Lio/reactivex/internal/operators/observable/ObservableGroupJoin$LeftRightEndObserver;
.line 347
.local p0, "this":Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;, "Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable<TTLeft;TTRight;TTLeftEnd;TTRightEnd;TR;>;"
monitor-enter p0
.line 348
:try_start_1
iget-object v0, p0, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->queue:Lio/reactivex/internal/queue/SpscLinkedArrayQueue;
if-eqz p1, :cond_8
sget-object v1, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->LEFT_CLOSE:Ljava/lang/Integer;
goto :goto_a
:cond_8
sget-object v1, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->RIGHT_CLOSE:Ljava/lang/Integer;
:goto_a
invoke-virtual {v0, v1, p2}, Lio/reactivex/internal/queue/SpscLinkedArrayQueue;->offer(Ljava/lang/Object;Ljava/lang/Object;)Z
.line 349
monitor-exit p0
:try_end_e
.catchall {:try_start_1 .. :try_end_e} :catchall_12
.line 350
invoke-virtual {p0}, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->drain()V
.line 351
return-void
.line 349
:catchall_12
move-exception v0
:try_start_13
monitor-exit p0
:try_end_14
.catchall {:try_start_13 .. :try_end_14} :catchall_12
throw v0
.end method
.method public innerCloseError(Ljava/lang/Throwable;)V
.registers 3
.param p1, "ex" # Ljava/lang/Throwable;
.line 355
.local p0, "this":Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;, "Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable<TTLeft;TTRight;TTLeftEnd;TTRightEnd;TR;>;"
iget-object v0, p0, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->error:Ljava/util/concurrent/atomic/AtomicReference;
invoke-static {v0, p1}, Lio/reactivex/internal/util/ExceptionHelper;->addThrowable(Ljava/util/concurrent/atomic/AtomicReference;Ljava/lang/Throwable;)Z
move-result v0
if-eqz v0, :cond_c
.line 356
invoke-virtual {p0}, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->drain()V
goto :goto_f
.line 358
:cond_c
invoke-static {p1}, Lio/reactivex/plugins/RxJavaPlugins;->onError(Ljava/lang/Throwable;)V
.line 360
:goto_f
return-void
.end method
.method public innerComplete(Lio/reactivex/internal/operators/observable/ObservableGroupJoin$LeftRightObserver;)V
.registers 3
.param p1, "sender" # Lio/reactivex/internal/operators/observable/ObservableGroupJoin$LeftRightObserver;
.line 332
.local p0, "this":Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;, "Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable<TTLeft;TTRight;TTLeftEnd;TTRightEnd;TR;>;"
iget-object v0, p0, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->disposables:Lio/reactivex/disposables/CompositeDisposable;
invoke-virtual {v0, p1}, Lio/reactivex/disposables/CompositeDisposable;->delete(Lio/reactivex/disposables/Disposable;)Z
.line 333
iget-object v0, p0, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->active:Ljava/util/concurrent/atomic/AtomicInteger;
invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicInteger;->decrementAndGet()I
.line 334
invoke-virtual {p0}, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->drain()V
.line 335
return-void
.end method
.method public innerError(Ljava/lang/Throwable;)V
.registers 3
.param p1, "ex" # Ljava/lang/Throwable;
.line 322
.local p0, "this":Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;, "Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable<TTLeft;TTRight;TTLeftEnd;TTRightEnd;TR;>;"
iget-object v0, p0, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->error:Ljava/util/concurrent/atomic/AtomicReference;
invoke-static {v0, p1}, Lio/reactivex/internal/util/ExceptionHelper;->addThrowable(Ljava/util/concurrent/atomic/AtomicReference;Ljava/lang/Throwable;)Z
move-result v0
if-eqz v0, :cond_11
.line 323
iget-object v0, p0, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->active:Ljava/util/concurrent/atomic/AtomicInteger;
invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicInteger;->decrementAndGet()I
.line 324
invoke-virtual {p0}, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->drain()V
goto :goto_14
.line 326
:cond_11
invoke-static {p1}, Lio/reactivex/plugins/RxJavaPlugins;->onError(Ljava/lang/Throwable;)V
.line 328
:goto_14
return-void
.end method
.method public innerValue(ZLjava/lang/Object;)V
.registers 5
.param p1, "isLeft" # Z
.param p2, "o" # Ljava/lang/Object;
.line 339
.local p0, "this":Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;, "Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable<TTLeft;TTRight;TTLeftEnd;TTRightEnd;TR;>;"
monitor-enter p0
.line 340
:try_start_1
iget-object v0, p0, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->queue:Lio/reactivex/internal/queue/SpscLinkedArrayQueue;
if-eqz p1, :cond_8
sget-object v1, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->LEFT_VALUE:Ljava/lang/Integer;
goto :goto_a
:cond_8
sget-object v1, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->RIGHT_VALUE:Ljava/lang/Integer;
:goto_a
invoke-virtual {v0, v1, p2}, Lio/reactivex/internal/queue/SpscLinkedArrayQueue;->offer(Ljava/lang/Object;Ljava/lang/Object;)Z
.line 341
monitor-exit p0
:try_end_e
.catchall {:try_start_1 .. :try_end_e} :catchall_12
.line 342
invoke-virtual {p0}, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->drain()V
.line 343
return-void
.line 341
:catchall_12
move-exception v0
:try_start_13
monitor-exit p0
:try_end_14
.catchall {:try_start_13 .. :try_end_14} :catchall_12
throw v0
.end method
.method public isDisposed()Z
.registers 2
.line 143
.local p0, "this":Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;, "Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable<TTLeft;TTRight;TTLeftEnd;TTRightEnd;TR;>;"
iget-boolean v0, p0, Lio/reactivex/internal/operators/observable/ObservableJoin$JoinDisposable;->cancelled:Z
return v0
.end method