n4.smali
.class public final Lio/reactivex/internal/operators/observable/n4;
.super Lio/reactivex/internal/operators/observable/a;
.source "SourceFile"
# annotations
.annotation system Ldalvik/annotation/MemberClasses;
value = {
Lio/reactivex/internal/operators/observable/n4$a;,
Lio/reactivex/internal/operators/observable/n4$b;,
Lio/reactivex/internal/operators/observable/n4$d;,
Lio/reactivex/internal/operators/observable/n4$c;
}
.end annotation
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
"B:",
"Ljava/lang/Object;",
"V:",
"Ljava/lang/Object;",
">",
"Lio/reactivex/internal/operators/observable/a<",
"TT;",
"Lio/reactivex/l<",
"TT;>;>;"
}
.end annotation
# instance fields
.field public final b:Lio/reactivex/q;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/q<",
"TB;>;"
}
.end annotation
.end field
.field public final c:Lio/reactivex/functions/n;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/functions/n<",
"-TB;+",
"Lio/reactivex/q<",
"TV;>;>;"
}
.end annotation
.end field
.field public final d:I
# direct methods
.method public constructor <init>(Lio/reactivex/q;Lio/reactivex/q;Lio/reactivex/functions/n;I)V
.registers 5
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/q<",
"TT;>;",
"Lio/reactivex/q<",
"TB;>;",
"Lio/reactivex/functions/n<",
"-TB;+",
"Lio/reactivex/q<",
"TV;>;>;I)V"
}
.end annotation
.line 1
invoke-direct {p0, p1}, Lio/reactivex/internal/operators/observable/a;-><init>(Lio/reactivex/q;)V
.line 2
iput-object p2, p0, Lio/reactivex/internal/operators/observable/n4;->b:Lio/reactivex/q;
.line 3
iput-object p3, p0, Lio/reactivex/internal/operators/observable/n4;->c:Lio/reactivex/functions/n;
.line 4
iput p4, p0, Lio/reactivex/internal/operators/observable/n4;->d:I
return-void
.end method
# virtual methods
.method public final subscribeActual(Lio/reactivex/s;)V
.registers 7
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/s<",
"-",
"Lio/reactivex/l<",
"TT;>;>;)V"
}
.end annotation
iget-object v0, p0, Lio/reactivex/internal/operators/observable/a;->a:Lio/reactivex/q;
new-instance v1, Lio/reactivex/internal/operators/observable/n4$c;
new-instance v2, Lio/reactivex/observers/e;
invoke-direct {v2, p1}, Lio/reactivex/observers/e;-><init>(Lio/reactivex/s;)V
iget-object p1, p0, Lio/reactivex/internal/operators/observable/n4;->b:Lio/reactivex/q;
iget-object v3, p0, Lio/reactivex/internal/operators/observable/n4;->c:Lio/reactivex/functions/n;
iget v4, p0, Lio/reactivex/internal/operators/observable/n4;->d:I
invoke-direct {v1, v2, p1, v3, v4}, Lio/reactivex/internal/operators/observable/n4$c;-><init>(Lio/reactivex/s;Lio/reactivex/q;Lio/reactivex/functions/n;I)V
invoke-interface {v0, v1}, Lio/reactivex/q;->subscribe(Lio/reactivex/s;)V
return-void
.end method