T$c.smali
.class final Lio/reactivex/internal/operators/observable/T$c;
.super Ljava/lang/Object;
.source "ObservableInternalHelper.java"
# interfaces
.implements Lio/reactivex/b/o;
# annotations
.annotation system Ldalvik/annotation/EnclosingClass;
value = Lio/reactivex/internal/operators/observable/T;
.end annotation
.annotation system Ldalvik/annotation/InnerClass;
accessFlags = 0x18
name = "c"
.end annotation
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
"U:",
"Ljava/lang/Object;",
">",
"Ljava/lang/Object;",
"Lio/reactivex/b/o<",
"TT;",
"Lio/reactivex/u<",
"TU;>;>;"
}
.end annotation
# instance fields
.field private final a:Lio/reactivex/b/o;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/b/o<",
"-TT;+",
"Ljava/lang/Iterable<",
"+TU;>;>;"
}
.end annotation
.end field
# direct methods
.method constructor <init>(Lio/reactivex/b/o;)V
.registers 2
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/b/o<",
"-TT;+",
"Ljava/lang/Iterable<",
"+TU;>;>;)V"
}
.end annotation
.line 1
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
.line 2
iput-object p1, p0, Lio/reactivex/internal/operators/observable/T$c;->a:Lio/reactivex/b/o;
return-void
.end method
# virtual methods
.method public apply(Ljava/lang/Object;)Lio/reactivex/u;
.registers 4
.annotation system Ldalvik/annotation/Signature;
value = {
"(TT;)",
"Lio/reactivex/u<",
"TU;>;"
}
.end annotation
.annotation system Ldalvik/annotation/Throws;
value = {
Ljava/lang/Exception;
}
.end annotation
.line 2
new-instance v0, Lio/reactivex/internal/operators/observable/L;
iget-object v1, p0, Lio/reactivex/internal/operators/observable/T$c;->a:Lio/reactivex/b/o;
invoke-interface {v1, p1}, Lio/reactivex/b/o;->apply(Ljava/lang/Object;)Ljava/lang/Object;
move-result-object p1
const-string v1, "The mapper returned a null Iterable"
invoke-static {p1, v1}, Lio/reactivex/internal/functions/a;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
check-cast p1, Ljava/lang/Iterable;
invoke-direct {v0, p1}, Lio/reactivex/internal/operators/observable/L;-><init>(Ljava/lang/Iterable;)V
return-object v0
.end method
.method public bridge synthetic apply(Ljava/lang/Object;)Ljava/lang/Object;
.registers 2
.annotation system Ldalvik/annotation/Throws;
value = {
Ljava/lang/Exception;
}
.end annotation
.line 1
invoke-virtual {p0, p1}, Lio/reactivex/internal/operators/observable/T$c;->apply(Ljava/lang/Object;)Lio/reactivex/u;
move-result-object p1
return-object p1
.end method