tmap/smali_classes5/io/reactivex/internal/operators/observable/ObservableConcatWithCompletable.smali
2022-06-10 21:38:30 +09:00

75 lines
2.0 KiB
Smali

.class public final Lio/reactivex/internal/operators/observable/ObservableConcatWithCompletable;
.super Lio/reactivex/internal/operators/observable/a;
.source "ObservableConcatWithCompletable.java"
# annotations
.annotation system Ldalvik/annotation/MemberClasses;
value = {
Lio/reactivex/internal/operators/observable/ObservableConcatWithCompletable$ConcatWithObserver;
}
.end annotation
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">",
"Lio/reactivex/internal/operators/observable/a<",
"TT;TT;>;"
}
.end annotation
# instance fields
.field public final b:Lkh/g;
# direct methods
.method public constructor <init>(Lkh/z;Lkh/g;)V
.locals 0
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lkh/z<",
"TT;>;",
"Lkh/g;",
")V"
}
.end annotation
.line 1
invoke-direct {p0, p1}, Lio/reactivex/internal/operators/observable/a;-><init>(Lkh/e0;)V
.line 2
iput-object p2, p0, Lio/reactivex/internal/operators/observable/ObservableConcatWithCompletable;->b:Lkh/g;
return-void
.end method
# virtual methods
.method public subscribeActual(Lkh/g0;)V
.locals 3
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lkh/g0<",
"-TT;>;)V"
}
.end annotation
.line 1
iget-object v0, p0, Lio/reactivex/internal/operators/observable/a;->a:Lkh/e0;
new-instance v1, Lio/reactivex/internal/operators/observable/ObservableConcatWithCompletable$ConcatWithObserver;
iget-object v2, p0, Lio/reactivex/internal/operators/observable/ObservableConcatWithCompletable;->b:Lkh/g;
invoke-direct {v1, p1, v2}, Lio/reactivex/internal/operators/observable/ObservableConcatWithCompletable$ConcatWithObserver;-><init>(Lkh/g0;Lkh/g;)V
invoke-interface {v0, v1}, Lkh/e0;->subscribe(Lkh/g0;)V
return-void
.end method