z.smali
.class public final Lio/reactivex/internal/operators/observable/z;
.super Lio/reactivex/internal/operators/observable/a;
.source "ObservableDoOnEach.java"
# annotations
.annotation system Ldalvik/annotation/MemberClasses;
value = {
Lio/reactivex/internal/operators/observable/z$a;
}
.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 final b:Lio/reactivex/b/g;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/b/g<",
"-TT;>;"
}
.end annotation
.end field
.field final c:Lio/reactivex/b/g;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/b/g<",
"-",
"Ljava/lang/Throwable;",
">;"
}
.end annotation
.end field
.field final d:Lio/reactivex/b/a;
.field final e:Lio/reactivex/b/a;
# direct methods
.method public constructor <init>(Lio/reactivex/u;Lio/reactivex/b/g;Lio/reactivex/b/g;Lio/reactivex/b/a;Lio/reactivex/b/a;)V
.registers 6
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/u<",
"TT;>;",
"Lio/reactivex/b/g<",
"-TT;>;",
"Lio/reactivex/b/g<",
"-",
"Ljava/lang/Throwable;",
">;",
"Lio/reactivex/b/a;",
"Lio/reactivex/b/a;",
")V"
}
.end annotation
.line 1
invoke-direct {p0, p1}, Lio/reactivex/internal/operators/observable/a;-><init>(Lio/reactivex/u;)V
.line 2
iput-object p2, p0, Lio/reactivex/internal/operators/observable/z;->b:Lio/reactivex/b/g;
.line 3
iput-object p3, p0, Lio/reactivex/internal/operators/observable/z;->c:Lio/reactivex/b/g;
.line 4
iput-object p4, p0, Lio/reactivex/internal/operators/observable/z;->d:Lio/reactivex/b/a;
.line 5
iput-object p5, p0, Lio/reactivex/internal/operators/observable/z;->e:Lio/reactivex/b/a;
return-void
.end method
# virtual methods
.method public subscribeActual(Lio/reactivex/w;)V
.registers 10
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/w<",
"-TT;>;)V"
}
.end annotation
.line 1
iget-object v0, p0, Lio/reactivex/internal/operators/observable/a;->a:Lio/reactivex/u;
new-instance v7, Lio/reactivex/internal/operators/observable/z$a;
iget-object v3, p0, Lio/reactivex/internal/operators/observable/z;->b:Lio/reactivex/b/g;
iget-object v4, p0, Lio/reactivex/internal/operators/observable/z;->c:Lio/reactivex/b/g;
iget-object v5, p0, Lio/reactivex/internal/operators/observable/z;->d:Lio/reactivex/b/a;
iget-object v6, p0, Lio/reactivex/internal/operators/observable/z;->e:Lio/reactivex/b/a;
move-object v1, v7
move-object v2, p1
invoke-direct/range {v1 .. v6}, Lio/reactivex/internal/operators/observable/z$a;-><init>(Lio/reactivex/w;Lio/reactivex/b/g;Lio/reactivex/b/g;Lio/reactivex/b/a;Lio/reactivex/b/a;)V
invoke-interface {v0, v7}, Lio/reactivex/u;->subscribe(Lio/reactivex/w;)V
return-void
.end method