ObservableTakeUntil.smali
.class public final Lio/reactivex/internal/operators/observable/ObservableTakeUntil;
.super Lio/reactivex/internal/operators/observable/a;
.source "ObservableTakeUntil.java"
# annotations
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
"U:",
"Ljava/lang/Object;",
">",
"Lio/reactivex/internal/operators/observable/a",
"<TT;TT;>;"
}
.end annotation
# instance fields
.field private other:Lio/reactivex/p;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/p",
"<+TU;>;"
}
.end annotation
.end field
# direct methods
.method public constructor <init>(Lio/reactivex/p;Lio/reactivex/p;)V
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/p",
"<TT;>;",
"Lio/reactivex/p",
"<+TU;>;)V"
}
.end annotation
.prologue
.line 26
invoke-direct {p0, p1}, Lio/reactivex/internal/operators/observable/a;-><init>(Lio/reactivex/p;)V
.line 27
iput-object p2, p0, Lio/reactivex/internal/operators/observable/ObservableTakeUntil;->other:Lio/reactivex/p;
.line 28
return-void
.end method
# virtual methods
.method public final subscribeActual(Lio/reactivex/r;)V
.registers 7
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/r",
"<-TT;>;)V"
}
.end annotation
.prologue
.line 31
new-instance v0, Lio/reactivex/observers/e;
invoke-direct {v0, p1}, Lio/reactivex/observers/e;-><init>(Lio/reactivex/r;)V
.line 33
new-instance v1, Lio/reactivex/internal/disposables/ArrayCompositeDisposable;
const/4 v2, 0x2
invoke-direct {v1, v2}, Lio/reactivex/internal/disposables/ArrayCompositeDisposable;-><init>(I)V
.line 35
new-instance v2, Lio/reactivex/internal/operators/observable/ObservableTakeUntil$TakeUntilObserver;
invoke-direct {v2, v0, v1}, Lio/reactivex/internal/operators/observable/ObservableTakeUntil$TakeUntilObserver;-><init>(Lio/reactivex/r;Lio/reactivex/internal/disposables/ArrayCompositeDisposable;)V
.line 37
invoke-interface {p1, v1}, Lio/reactivex/r;->onSubscribe(Lio/reactivex/disposables/b;)V
.line 39
iget-object v3, p0, Lio/reactivex/internal/operators/observable/ObservableTakeUntil;->other:Lio/reactivex/p;
new-instance v4, Lio/reactivex/internal/operators/observable/fw;
invoke-direct {v4, v1, v0}, Lio/reactivex/internal/operators/observable/fw;-><init>(Lio/reactivex/internal/disposables/ArrayCompositeDisposable;Lio/reactivex/observers/e;)V
invoke-interface {v3, v4}, Lio/reactivex/p;->subscribe(Lio/reactivex/r;)V
.line 41
iget-object v0, p0, Lio/reactivex/internal/operators/observable/ObservableTakeUntil;->source:Lio/reactivex/p;
invoke-interface {v0, v2}, Lio/reactivex/p;->subscribe(Lio/reactivex/r;)V
.line 42
return-void
.end method