OnSubscribeToMap.smali
.class public final Lrx/internal/operators/OnSubscribeToMap;
.super Ljava/lang/Object;
.source "OnSubscribeToMap.java"
# interfaces
.implements Lrx/Observable$OnSubscribe;
.implements Lrx/functions/Func0;
# annotations
.annotation system Ldalvik/annotation/MemberClasses;
value = {
Lrx/internal/operators/OnSubscribeToMap$ToMapSubscriber;
}
.end annotation
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
"K:",
"Ljava/lang/Object;",
"V:",
"Ljava/lang/Object;",
">",
"Ljava/lang/Object;",
"Lrx/Observable$OnSubscribe<",
"Ljava/util/Map<",
"TK;TV;>;>;",
"Lrx/functions/Func0<",
"Ljava/util/Map<",
"TK;TV;>;>;"
}
.end annotation
# instance fields
.field final keySelector:Lrx/functions/Func1;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lrx/functions/Func1<",
"-TT;+TK;>;"
}
.end annotation
.end field
.field final mapFactory:Lrx/functions/Func0;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lrx/functions/Func0<",
"+",
"Ljava/util/Map<",
"TK;TV;>;>;"
}
.end annotation
.end field
.field final source:Lrx/Observable;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lrx/Observable<",
"TT;>;"
}
.end annotation
.end field
.field final valueSelector:Lrx/functions/Func1;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lrx/functions/Func1<",
"-TT;+TV;>;"
}
.end annotation
.end field
# direct methods
.method public constructor <init>(Lrx/Observable;Lrx/functions/Func1;Lrx/functions/Func1;)V
.registers 5
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lrx/Observable<",
"TT;>;",
"Lrx/functions/Func1<",
"-TT;+TK;>;",
"Lrx/functions/Func1<",
"-TT;+TV;>;)V"
}
.end annotation
const/4 v0, 0x0
.line 1
invoke-direct {p0, p1, p2, p3, v0}, Lrx/internal/operators/OnSubscribeToMap;-><init>(Lrx/Observable;Lrx/functions/Func1;Lrx/functions/Func1;Lrx/functions/Func0;)V
return-void
.end method
.method public constructor <init>(Lrx/Observable;Lrx/functions/Func1;Lrx/functions/Func1;Lrx/functions/Func0;)V
.registers 5
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lrx/Observable<",
"TT;>;",
"Lrx/functions/Func1<",
"-TT;+TK;>;",
"Lrx/functions/Func1<",
"-TT;+TV;>;",
"Lrx/functions/Func0<",
"+",
"Ljava/util/Map<",
"TK;TV;>;>;)V"
}
.end annotation
.line 2
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
.line 3
iput-object p1, p0, Lrx/internal/operators/OnSubscribeToMap;->source:Lrx/Observable;
.line 4
iput-object p2, p0, Lrx/internal/operators/OnSubscribeToMap;->keySelector:Lrx/functions/Func1;
.line 5
iput-object p3, p0, Lrx/internal/operators/OnSubscribeToMap;->valueSelector:Lrx/functions/Func1;
if-nez p4, :cond_e
.line 6
iput-object p0, p0, Lrx/internal/operators/OnSubscribeToMap;->mapFactory:Lrx/functions/Func0;
goto :goto_10
.line 7
:cond_e
iput-object p4, p0, Lrx/internal/operators/OnSubscribeToMap;->mapFactory:Lrx/functions/Func0;
:goto_10
return-void
.end method
# virtual methods
.method public bridge synthetic call()Ljava/lang/Object;
.registers 2
.line 1
invoke-virtual {p0}, Lrx/internal/operators/OnSubscribeToMap;->call()Ljava/util/Map;
move-result-object v0
return-object v0
.end method
.method public call()Ljava/util/Map;
.registers 2
.annotation system Ldalvik/annotation/Signature;
value = {
"()",
"Ljava/util/Map<",
"TK;TV;>;"
}
.end annotation
.line 3
new-instance v0, Ljava/util/HashMap;
invoke-direct {v0}, Ljava/util/HashMap;-><init>()V
return-object v0
.end method
.method public bridge synthetic call(Ljava/lang/Object;)V
.registers 2
.line 2
check-cast p1, Lrx/Subscriber;
invoke-virtual {p0, p1}, Lrx/internal/operators/OnSubscribeToMap;->call(Lrx/Subscriber;)V
return-void
.end method
.method public call(Lrx/Subscriber;)V
.registers 6
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lrx/Subscriber<",
"-",
"Ljava/util/Map<",
"TK;TV;>;>;)V"
}
.end annotation
.line 4
:try_start_0
iget-object v0, p0, Lrx/internal/operators/OnSubscribeToMap;->mapFactory:Lrx/functions/Func0;
invoke-interface {v0}, Lrx/functions/Func0;->call()Ljava/lang/Object;
move-result-object v0
check-cast v0, Ljava/util/Map;
:try_end_8
.catch Ljava/lang/Throwable; {:try_start_0 .. :try_end_8} :catch_17
.line 5
new-instance v1, Lrx/internal/operators/OnSubscribeToMap$ToMapSubscriber;
iget-object v2, p0, Lrx/internal/operators/OnSubscribeToMap;->keySelector:Lrx/functions/Func1;
iget-object v3, p0, Lrx/internal/operators/OnSubscribeToMap;->valueSelector:Lrx/functions/Func1;
invoke-direct {v1, p1, v0, v2, v3}, Lrx/internal/operators/OnSubscribeToMap$ToMapSubscriber;-><init>(Lrx/Subscriber;Ljava/util/Map;Lrx/functions/Func1;Lrx/functions/Func1;)V
iget-object p1, p0, Lrx/internal/operators/OnSubscribeToMap;->source:Lrx/Observable;
invoke-virtual {v1, p1}, Lrx/internal/operators/DeferredScalarSubscriber;->subscribeTo(Lrx/Observable;)V
return-void
:catch_17
move-exception v0
.line 6
invoke-static {v0, p1}, Lrx/exceptions/Exceptions;->throwOrReport(Ljava/lang/Throwable;Lrx/Observer;)V
return-void
.end method