ObservableSequenceEqualSingle.smali
.class public final Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle;
.super Lio/reactivex/Single;
.source "ObservableSequenceEqualSingle.java"
# interfaces
.implements Lio/reactivex/internal/fuseable/FuseToObservable;
# annotations
.annotation system Ldalvik/annotation/MemberClasses;
value = {
Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualObserver;,
Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;
}
.end annotation
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">",
"Lio/reactivex/Single<",
"Ljava/lang/Boolean;",
">;",
"Lio/reactivex/internal/fuseable/FuseToObservable<",
"Ljava/lang/Boolean;",
">;"
}
.end annotation
# instance fields
.field final bufferSize:I
.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 second:Lio/reactivex/ObservableSource;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/ObservableSource<",
"+TT;>;"
}
.end annotation
.end field
# direct methods
.method static constructor <clinit>()V
.registers 1
return-void
.end method
.method public constructor <init>(Lio/reactivex/ObservableSource;Lio/reactivex/ObservableSource;Lio/reactivex/functions/BiPredicate;I)V
.registers 5
.param p4, "bufferSize" # I
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/ObservableSource<",
"+TT;>;",
"Lio/reactivex/ObservableSource<",
"+TT;>;",
"Lio/reactivex/functions/BiPredicate<",
"-TT;-TT;>;I)V"
}
.end annotation
.line 34
.local p0, "this":Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle;, "Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle<TT;>;"
.local p1, "first":Lio/reactivex/ObservableSource;, "Lio/reactivex/ObservableSource<+TT;>;"
.local p2, "second":Lio/reactivex/ObservableSource;, "Lio/reactivex/ObservableSource<+TT;>;"
.local p3, "comparer":Lio/reactivex/functions/BiPredicate;, "Lio/reactivex/functions/BiPredicate<-TT;-TT;>;"
invoke-direct {p0}, Lio/reactivex/Single;-><init>()V
.line 35
iput-object p1, p0, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle;->first:Lio/reactivex/ObservableSource;
.line 36
iput-object p2, p0, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle;->second:Lio/reactivex/ObservableSource;
.line 37
iput-object p3, p0, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle;->comparer:Lio/reactivex/functions/BiPredicate;
.line 38
iput p4, p0, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle;->bufferSize:I
.line 39
return-void
.end method
# virtual methods
.method public fuseToObservable()Lio/reactivex/Observable;
.registers 6
.annotation system Ldalvik/annotation/Signature;
value = {
"()",
"Lio/reactivex/Observable<",
"Ljava/lang/Boolean;",
">;"
}
.end annotation
.line 50
.local p0, "this":Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle;, "Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle<TT;>;"
new-instance v0, Lio/reactivex/internal/operators/observable/ObservableSequenceEqual;
iget-object v1, p0, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle;->first:Lio/reactivex/ObservableSource;
iget-object v2, p0, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle;->second:Lio/reactivex/ObservableSource;
iget-object v3, p0, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle;->comparer:Lio/reactivex/functions/BiPredicate;
iget v4, p0, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle;->bufferSize:I
invoke-direct {v0, v1, v2, v3, v4}, Lio/reactivex/internal/operators/observable/ObservableSequenceEqual;-><init>(Lio/reactivex/ObservableSource;Lio/reactivex/ObservableSource;Lio/reactivex/functions/BiPredicate;I)V
invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onAssembly(Lio/reactivex/Observable;)Lio/reactivex/Observable;
move-result-object v0
return-object v0
.end method
.method public subscribeActual(Lio/reactivex/SingleObserver;)V
.registers 9
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/SingleObserver<",
"-",
"Ljava/lang/Boolean;",
">;)V"
}
.end annotation
.line 43
.local p0, "this":Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle;, "Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle<TT;>;"
.local p1, "s":Lio/reactivex/SingleObserver;, "Lio/reactivex/SingleObserver<-Ljava/lang/Boolean;>;"
new-instance v6, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;
iget v2, p0, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle;->bufferSize:I
iget-object v3, p0, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle;->first:Lio/reactivex/ObservableSource;
iget-object v4, p0, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle;->second:Lio/reactivex/ObservableSource;
iget-object v5, p0, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle;->comparer:Lio/reactivex/functions/BiPredicate;
move-object v0, v6
move-object v1, p1
invoke-direct/range {v0 .. v5}, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;-><init>(Lio/reactivex/SingleObserver;ILio/reactivex/ObservableSource;Lio/reactivex/ObservableSource;Lio/reactivex/functions/BiPredicate;)V
.line 44
.local v0, "ec":Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;, "Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator<TT;>;"
invoke-interface {p1, v0}, Lio/reactivex/SingleObserver;->onSubscribe(Lio/reactivex/disposables/Disposable;)V
.line 45
invoke-virtual {v0}, Lio/reactivex/internal/operators/observable/ObservableSequenceEqualSingle$EqualCoordinator;->subscribe()V
.line 46
return-void
.end method