ObservableSequenceEqualSingle$EqualCoordinator.smali
.class final Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;
.super Ljava/util/concurrent/atomic/AtomicInteger;
.source "ObservableSequenceEqualSingle.java"
# interfaces
.implements Lio/reactivex/disposables/Disposable;
# annotations
.annotation system Ldalvik/annotation/EnclosingClass;
value = Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle;
.end annotation
.annotation system Ldalvik/annotation/InnerClass;
accessFlags = 0x18
name = "EqualCoordinator"
.end annotation
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">",
"Ljava/util/concurrent/atomic/AtomicInteger;",
"Lio/reactivex/disposables/Disposable;"
}
.end annotation
# static fields
.field private static final serialVersionUID:J = -0x55bcb3aaa8a061f8L
# instance fields
.field final actual:Lio/reactivex/SingleObserver;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/SingleObserver<",
"-",
"Ljava/lang/Boolean;",
">;"
}
.end annotation
.end field
.field volatile cancelled:Z
.field final comparer:Lio/reactivex/functions/BiPredicate;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/functions/BiPredicate<",
"-TT;-TT;>;"
}
.end annotation
.end field
.field final first:Lio/reactivex/ObservableSource;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/ObservableSource<",
"+TT;>;"
}
.end annotation
.end field
.field final observers:[Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualObserver;
.annotation system Ldalvik/annotation/Signature;
value = {
"[",
"Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualObserver<",
"TT;>;"
}
.end annotation
.end field
.field final resources:Lio/reactivex/internal/disposables/ArrayCompositeDisposable;
.field final second:Lio/reactivex/ObservableSource;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/ObservableSource<",
"+TT;>;"
}
.end annotation
.end field
.field v1:Ljava/lang/Object;
.annotation system Ldalvik/annotation/Signature;
value = {
"TT;"
}
.end annotation
.end field
.field v2:Ljava/lang/Object;
.annotation system Ldalvik/annotation/Signature;
value = {
"TT;"
}
.end annotation
.end field
# direct methods
.method static constructor <clinit>()V
.registers 1
return-void
.end method
.method constructor <init>(Lio/reactivex/SingleObserver;ILio/reactivex/ObservableSource;Lio/reactivex/ObservableSource;Lio/reactivex/functions/BiPredicate;)V
.registers 10
.param p2, "bufferSize" # I
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/SingleObserver<",
"-",
"Ljava/lang/Boolean;",
">;I",
"Lio/reactivex/ObservableSource<",
"+TT;>;",
"Lio/reactivex/ObservableSource<",
"+TT;>;",
"Lio/reactivex/functions/BiPredicate<",
"-TT;-TT;>;)V"
}
.end annotation
.line 71
.local p0, "this":Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;, "Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator<TT;>;"
.local p1, "actual":Lio/reactivex/SingleObserver;, "Lio/reactivex/SingleObserver<-Ljava/lang/Boolean;>;"
.local p3, "first":Lio/reactivex/ObservableSource;, "Lio/reactivex/ObservableSource<+TT;>;"
.local p4, "second":Lio/reactivex/ObservableSource;, "Lio/reactivex/ObservableSource<+TT;>;"
.local p5, "comparer":Lio/reactivex/functions/BiPredicate;, "Lio/reactivex/functions/BiPredicate<-TT;-TT;>;"
invoke-direct {p0}, Ljava/util/concurrent/atomic/AtomicInteger;-><init>()V
.line 72
iput-object p1, p0, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;->actual:Lio/reactivex/SingleObserver;
.line 73
iput-object p3, p0, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;->first:Lio/reactivex/ObservableSource;
.line 74
iput-object p4, p0, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;->second:Lio/reactivex/ObservableSource;
.line 75
iput-object p5, p0, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;->comparer:Lio/reactivex/functions/BiPredicate;
.line 77
const/4 v0, 0x2
new-array v1, v0, [Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualObserver;
.line 78
.local v1, "as":[Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualObserver;, "[Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualObserver<TT;>;"
iput-object v1, p0, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;->observers:[Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualObserver;
.line 79
new-instance v2, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualObserver;
const/4 v3, 0x0
invoke-direct {v2, p0, v3, p2}, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualObserver;-><init>(Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;II)V
aput-object v2, v1, v3
.line 80
new-instance v2, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualObserver;
const/4 v3, 0x1
invoke-direct {v2, p0, v3, p2}, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualObserver;-><init>(Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;II)V
aput-object v2, v1, v3
.line 81
new-instance v2, Lio/reactivex/internal/disposables/ArrayCompositeDisposable;
invoke-direct {v2, v0}, Lio/reactivex/internal/disposables/ArrayCompositeDisposable;-><init>(I)V
iput-object v2, p0, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;->resources:Lio/reactivex/internal/disposables/ArrayCompositeDisposable;
.line 82
return-void
.end method
# virtual methods
.method cancel(Lio/reactivex/internal/queue/SpscLinkedArrayQueue;Lio/reactivex/internal/queue/SpscLinkedArrayQueue;)V
.registers 4
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/internal/queue/SpscLinkedArrayQueue<",
"TT;>;",
"Lio/reactivex/internal/queue/SpscLinkedArrayQueue<",
"TT;>;)V"
}
.end annotation
.line 114
.local p0, "this":Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;, "Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator<TT;>;"
.local p1, "q1":Lio/reactivex/internal/queue/SpscLinkedArrayQueue;, "Lio/reactivex/internal/queue/SpscLinkedArrayQueue<TT;>;"
.local p2, "q2":Lio/reactivex/internal/queue/SpscLinkedArrayQueue;, "Lio/reactivex/internal/queue/SpscLinkedArrayQueue<TT;>;"
const/4 v0, 0x1
iput-boolean v0, p0, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;->cancelled:Z
.line 115
invoke-virtual {p1}, Lio/reactivex/internal/queue/SpscLinkedArrayQueue;->clear()V
.line 116
invoke-virtual {p2}, Lio/reactivex/internal/queue/SpscLinkedArrayQueue;->clear()V
.line 117
return-void
.end method
.method public dispose()V
.registers 4
.line 96
.local p0, "this":Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;, "Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator<TT;>;"
iget-boolean v0, p0, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;->cancelled:Z
if-nez v0, :cond_23
.line 97
const/4 v0, 0x1
iput-boolean v0, p0, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;->cancelled:Z
.line 98
iget-object v1, p0, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;->resources:Lio/reactivex/internal/disposables/ArrayCompositeDisposable;
invoke-virtual {v1}, Lio/reactivex/internal/disposables/ArrayCompositeDisposable;->dispose()V
.line 100
invoke-virtual {p0}, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;->getAndIncrement()I
move-result v1
if-nez v1, :cond_23
.line 101
iget-object v1, p0, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;->observers:[Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualObserver;
.line 102
.local v1, "as":[Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualObserver;, "[Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualObserver<TT;>;"
const/4 v2, 0x0
aget-object v2, v1, v2
iget-object v2, v2, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualObserver;->queue:Lio/reactivex/internal/queue/SpscLinkedArrayQueue;
invoke-virtual {v2}, Lio/reactivex/internal/queue/SpscLinkedArrayQueue;->clear()V
.line 103
aget-object v0, v1, v0
iget-object v0, v0, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualObserver;->queue:Lio/reactivex/internal/queue/SpscLinkedArrayQueue;
invoke-virtual {v0}, Lio/reactivex/internal/queue/SpscLinkedArrayQueue;->clear()V
.line 106
.end local v1 # "as":[Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualObserver;, "[Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualObserver<TT;>;"
:cond_23
return-void
.end method
.method drain()V
.registers 16
.line 120
.local p0, "this":Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;, "Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator<TT;>;"
invoke-virtual {p0}, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;->getAndIncrement()I
move-result v0
if-eqz v0, :cond_7
.line 121
return-void
.line 124
:cond_7
const/4 v0, 0x1
.line 125
.local v0, "missed":I
iget-object v1, p0, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;->observers:[Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualObserver;
.line 127
.local v1, "as":[Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualObserver;, "[Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualObserver<TT;>;"
const/4 v2, 0x0
aget-object v3, v1, v2
.line 128
.local v3, "s1":Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualObserver;, "Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualObserver<TT;>;"
iget-object v4, v3, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualObserver;->queue:Lio/reactivex/internal/queue/SpscLinkedArrayQueue;
.line 129
.local v4, "q1":Lio/reactivex/internal/queue/SpscLinkedArrayQueue;, "Lio/reactivex/internal/queue/SpscLinkedArrayQueue<TT;>;"
const/4 v5, 0x1
aget-object v6, v1, v5
.line 130
.local v6, "s2":Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualObserver;, "Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualObserver<TT;>;"
iget-object v7, v6, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualObserver;->queue:Lio/reactivex/internal/queue/SpscLinkedArrayQueue;
.line 135
.local v7, "q2":Lio/reactivex/internal/queue/SpscLinkedArrayQueue;, "Lio/reactivex/internal/queue/SpscLinkedArrayQueue<TT;>;"
:goto_14
iget-boolean v8, p0, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;->cancelled:Z
if-eqz v8, :cond_1f
.line 136
invoke-virtual {v4}, Lio/reactivex/internal/queue/SpscLinkedArrayQueue;->clear()V
.line 137
invoke-virtual {v7}, Lio/reactivex/internal/queue/SpscLinkedArrayQueue;->clear()V
.line 138
return-void
.line 141
:cond_1f
iget-boolean v8, v3, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualObserver;->done:Z
.line 143
.local v8, "d1":Z
if-eqz v8, :cond_30
.line 144
iget-object v9, v3, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualObserver;->error:Ljava/lang/Throwable;
.line 145
.local v9, "e":Ljava/lang/Throwable;
if-eqz v9, :cond_30
.line 146
invoke-virtual {p0, v4, v7}, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;->cancel(Lio/reactivex/internal/queue/SpscLinkedArrayQueue;Lio/reactivex/internal/queue/SpscLinkedArrayQueue;)V
.line 148
iget-object v2, p0, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;->actual:Lio/reactivex/SingleObserver;
invoke-interface {v2, v9}, Lio/reactivex/SingleObserver;->onError(Ljava/lang/Throwable;)V
.line 149
return-void
.line 153
.end local v9 # "e":Ljava/lang/Throwable;
:cond_30
iget-boolean v9, v6, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualObserver;->done:Z
.line 154
.local v9, "d2":Z
if-eqz v9, :cond_41
.line 155
iget-object v10, v6, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualObserver;->error:Ljava/lang/Throwable;
.line 156
.local v10, "e":Ljava/lang/Throwable;
if-eqz v10, :cond_41
.line 157
invoke-virtual {p0, v4, v7}, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;->cancel(Lio/reactivex/internal/queue/SpscLinkedArrayQueue;Lio/reactivex/internal/queue/SpscLinkedArrayQueue;)V
.line 159
iget-object v2, p0, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;->actual:Lio/reactivex/SingleObserver;
invoke-interface {v2, v10}, Lio/reactivex/SingleObserver;->onError(Ljava/lang/Throwable;)V
.line 160
return-void
.line 164
.end local v10 # "e":Ljava/lang/Throwable;
:cond_41
iget-object v10, p0, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;->v1:Ljava/lang/Object;
if-nez v10, :cond_4b
.line 165
invoke-virtual {v4}, Lio/reactivex/internal/queue/SpscLinkedArrayQueue;->poll()Ljava/lang/Object;
move-result-object v10
iput-object v10, p0, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;->v1:Ljava/lang/Object;
.line 167
:cond_4b
iget-object v10, p0, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;->v1:Ljava/lang/Object;
if-nez v10, :cond_51
const/4 v10, 0x1
goto :goto_52
:cond_51
const/4 v10, 0x0
.line 169
.local v10, "e1":Z
:goto_52
iget-object v11, p0, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;->v2:Ljava/lang/Object;
if-nez v11, :cond_5c
.line 170
invoke-virtual {v7}, Lio/reactivex/internal/queue/SpscLinkedArrayQueue;->poll()Ljava/lang/Object;
move-result-object v11
iput-object v11, p0, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;->v2:Ljava/lang/Object;
.line 172
:cond_5c
iget-object v11, p0, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;->v2:Ljava/lang/Object;
if-nez v11, :cond_62
const/4 v11, 0x1
goto :goto_63
:cond_62
const/4 v11, 0x0
.line 174
.local v11, "e2":Z
:goto_63
if-eqz v8, :cond_75
if-eqz v9, :cond_75
if-eqz v10, :cond_75
if-eqz v11, :cond_75
.line 175
iget-object v2, p0, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;->actual:Lio/reactivex/SingleObserver;
invoke-static {v5}, Ljava/lang/Boolean;->valueOf(Z)Ljava/lang/Boolean;
move-result-object v5
invoke-interface {v2, v5}, Lio/reactivex/SingleObserver;->onSuccess(Ljava/lang/Object;)V
.line 176
return-void
.line 178
:cond_75
if-eqz v8, :cond_88
if-eqz v9, :cond_88
if-eq v10, v11, :cond_88
.line 179
invoke-virtual {p0, v4, v7}, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;->cancel(Lio/reactivex/internal/queue/SpscLinkedArrayQueue;Lio/reactivex/internal/queue/SpscLinkedArrayQueue;)V
.line 181
iget-object v5, p0, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;->actual:Lio/reactivex/SingleObserver;
invoke-static {v2}, Ljava/lang/Boolean;->valueOf(Z)Ljava/lang/Boolean;
move-result-object v2
invoke-interface {v5, v2}, Lio/reactivex/SingleObserver;->onSuccess(Ljava/lang/Object;)V
.line 182
return-void
.line 185
:cond_88
if-nez v10, :cond_b9
if-nez v11, :cond_b9
.line 189
:try_start_8c
iget-object v12, p0, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;->comparer:Lio/reactivex/functions/BiPredicate;
iget-object v13, p0, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;->v1:Ljava/lang/Object;
iget-object v14, p0, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;->v2:Ljava/lang/Object;
invoke-interface {v12, v13, v14}, Lio/reactivex/functions/BiPredicate;->test(Ljava/lang/Object;Ljava/lang/Object;)Z
move-result v12
:try_end_96
.catchall {:try_start_8c .. :try_end_96} :catchall_ac
.line 196
.local v12, "c":Z
nop
.line 198
if-nez v12, :cond_a6
.line 199
invoke-virtual {p0, v4, v7}, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;->cancel(Lio/reactivex/internal/queue/SpscLinkedArrayQueue;Lio/reactivex/internal/queue/SpscLinkedArrayQueue;)V
.line 201
iget-object v5, p0, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;->actual:Lio/reactivex/SingleObserver;
invoke-static {v2}, Ljava/lang/Boolean;->valueOf(Z)Ljava/lang/Boolean;
move-result-object v2
invoke-interface {v5, v2}, Lio/reactivex/SingleObserver;->onSuccess(Ljava/lang/Object;)V
.line 202
return-void
.line 205
:cond_a6
const/4 v13, 0x0
iput-object v13, p0, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;->v1:Ljava/lang/Object;
.line 206
iput-object v13, p0, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;->v2:Ljava/lang/Object;
goto :goto_b9
.line 190
.end local v12 # "c":Z
:catchall_ac
move-exception v2
.line 191
.local v2, "ex":Ljava/lang/Throwable;
invoke-static {v2}, Lio/reactivex/exceptions/Exceptions;->throwIfFatal(Ljava/lang/Throwable;)V
.line 192
invoke-virtual {p0, v4, v7}, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;->cancel(Lio/reactivex/internal/queue/SpscLinkedArrayQueue;Lio/reactivex/internal/queue/SpscLinkedArrayQueue;)V
.line 194
iget-object v5, p0, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;->actual:Lio/reactivex/SingleObserver;
invoke-interface {v5, v2}, Lio/reactivex/SingleObserver;->onError(Ljava/lang/Throwable;)V
.line 195
return-void
.line 209
.end local v2 # "ex":Ljava/lang/Throwable;
:cond_b9
:goto_b9
if-nez v10, :cond_c0
if-eqz v11, :cond_be
.line 210
goto :goto_c0
.line 212
.end local v8 # "d1":Z
.end local v9 # "d2":Z
.end local v10 # "e1":Z
.end local v11 # "e2":Z
:cond_be
goto/16 :goto_14
.line 214
:cond_c0
:goto_c0
neg-int v8, v0
invoke-virtual {p0, v8}, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;->addAndGet(I)I
move-result v0
.line 215
if-nez v0, :cond_c9
.line 216
nop
.line 219
return-void
.line 215
:cond_c9
goto/16 :goto_14
.end method
.method public isDisposed()Z
.registers 2
.line 110
.local p0, "this":Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;, "Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator<TT;>;"
iget-boolean v0, p0, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;->cancelled:Z
return v0
.end method
.method setDisposable(Lio/reactivex/disposables/Disposable;I)Z
.registers 4
.param p1, "s" # Lio/reactivex/disposables/Disposable;
.param p2, "index" # I
.line 85
.local p0, "this":Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;, "Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator<TT;>;"
iget-object v0, p0, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;->resources:Lio/reactivex/internal/disposables/ArrayCompositeDisposable;
invoke-virtual {v0, p2, p1}, Lio/reactivex/internal/disposables/ArrayCompositeDisposable;->setResource(ILio/reactivex/disposables/Disposable;)Z
move-result v0
return v0
.end method
.method subscribe()V
.registers 4
.line 89
.local p0, "this":Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;, "Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator<TT;>;"
iget-object v0, p0, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;->observers:[Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualObserver;
.line 90
.local v0, "as":[Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualObserver;, "[Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualObserver<TT;>;"
iget-object v1, p0, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;->first:Lio/reactivex/ObservableSource;
const/4 v2, 0x0
aget-object v2, v0, v2
invoke-interface {v1, v2}, Lio/reactivex/ObservableSource;->subscribe(Lio/reactivex/Observer;)V
.line 91
iget-object v1, p0, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;->second:Lio/reactivex/ObservableSource;
const/4 v2, 0x1
aget-object v2, v0, v2
invoke-interface {v1, v2}, Lio/reactivex/ObservableSource;->subscribe(Lio/reactivex/Observer;)V
.line 92
return-void
.end method