MaybeFlatMapPublisher.smali
.class public final Lio/reactivex/internal/operators/mixed/MaybeFlatMapPublisher;
.super Lio/reactivex/e;
.source "MaybeFlatMapPublisher.java"
# annotations
.annotation system Ldalvik/annotation/MemberClasses;
value = {
Lio/reactivex/internal/operators/mixed/MaybeFlatMapPublisher$FlatMapPublisherSubscriber;
}
.end annotation
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
"R:",
"Ljava/lang/Object;",
">",
"Lio/reactivex/e<",
"TR;>;"
}
.end annotation
# instance fields
.field final b:Lio/reactivex/m;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/m<",
"TT;>;"
}
.end annotation
.end field
.field final c:Lio/reactivex/b/o;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/b/o<",
"-TT;+",
"Lf/b/b<",
"+TR;>;>;"
}
.end annotation
.end field
# direct methods
.method public constructor <init>(Lio/reactivex/m;Lio/reactivex/b/o;)V
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/m<",
"TT;>;",
"Lio/reactivex/b/o<",
"-TT;+",
"Lf/b/b<",
"+TR;>;>;)V"
}
.end annotation
.line 1
invoke-direct {p0}, Lio/reactivex/e;-><init>()V
.line 2
iput-object p1, p0, Lio/reactivex/internal/operators/mixed/MaybeFlatMapPublisher;->b:Lio/reactivex/m;
.line 3
iput-object p2, p0, Lio/reactivex/internal/operators/mixed/MaybeFlatMapPublisher;->c:Lio/reactivex/b/o;
return-void
.end method
# virtual methods
.method protected b(Lf/b/c;)V
.registers 5
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lf/b/c<",
"-TR;>;)V"
}
.end annotation
.line 1
iget-object v0, p0, Lio/reactivex/internal/operators/mixed/MaybeFlatMapPublisher;->b:Lio/reactivex/m;
new-instance v1, Lio/reactivex/internal/operators/mixed/MaybeFlatMapPublisher$FlatMapPublisherSubscriber;
iget-object v2, p0, Lio/reactivex/internal/operators/mixed/MaybeFlatMapPublisher;->c:Lio/reactivex/b/o;
invoke-direct {v1, p1, v2}, Lio/reactivex/internal/operators/mixed/MaybeFlatMapPublisher$FlatMapPublisherSubscriber;-><init>(Lf/b/c;Lio/reactivex/b/o;)V
invoke-interface {v0, v1}, Lio/reactivex/m;->a(Lio/reactivex/k;)V
return-void
.end method