h.smali

.class public final Lcom/cmcm/safewallet/data/dapp/h;
.super Ljava/lang/Object;
.source "WalletManager.kt"


# static fields
.field private static final Va:Lkotlin/a;
    .annotation build Lorg/jetbrains/annotations/NotNull;
    .end annotation
.end field

.field public static final Vb:Lcom/cmcm/safewallet/data/dapp/i;


# instance fields
.field private UN:Lcom/cmcm/safewallet/data/dapp/d;

.field private UZ:Lrx/subjects/a;
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "Lrx/subjects/a",
            "<",
            "Lcom/cmcm/safewallet/data/dapp/d;",
            ">;"
        }
    .end annotation
.end field

.field private scheduler:Lrx/j;


# direct methods
.method static constructor <clinit>()V
    .registers 2

    .prologue
    new-instance v0, Lcom/cmcm/safewallet/data/dapp/i;

    const/4 v1, 0x0

    invoke-direct {v0, v1}, Lcom/cmcm/safewallet/data/dapp/i;-><init>(B)V

    sput-object v0, Lcom/cmcm/safewallet/data/dapp/h;->Vb:Lcom/cmcm/safewallet/data/dapp/i;

    .line 19
    sget-object v0, Lcom/cmcm/safewallet/data/dapp/WalletManager$Companion$instance$2;->INSTANCE:Lcom/cmcm/safewallet/data/dapp/WalletManager$Companion$instance$2;

    check-cast v0, Lkotlin/jvm/a/a;

    invoke-static {v0}, Lkotlin/b;->a(Lkotlin/jvm/a/a;)Lkotlin/a;

    move-result-object v0

    sput-object v0, Lcom/cmcm/safewallet/data/dapp/h;->Va:Lkotlin/a;

    return-void
.end method

.method private constructor <init>()V
    .registers 5

    .prologue
    .line 12
    invoke-direct {p0}, Ljava/lang/Object;-><init>()V

    .line 14101
    new-instance v0, Lrx/subjects/SubjectSubscriptionManager;

    invoke-direct {v0}, Lrx/subjects/SubjectSubscriptionManager;-><init>()V

    .line 14105
    new-instance v1, Lrx/subjects/a$1;

    invoke-direct {v1, v0}, Lrx/subjects/a$1;-><init>(Lrx/subjects/SubjectSubscriptionManager;)V

    iput-object v1, v0, Lrx/subjects/SubjectSubscriptionManager;->onAdded:Lrx/b/b;

    .line 14113
    iget-object v1, v0, Lrx/subjects/SubjectSubscriptionManager;->onAdded:Lrx/b/b;

    iput-object v1, v0, Lrx/subjects/SubjectSubscriptionManager;->onTerminated:Lrx/b/b;

    .line 14114
    new-instance v1, Lrx/subjects/a;

    invoke-direct {v1, v0, v0}, Lrx/subjects/a;-><init>(Lrx/f;Lrx/subjects/SubjectSubscriptionManager;)V

    .line 13
    const-string v0, "BehaviorSubject.create<HDWallet>()"

    invoke-static {v1, v0}, Lkotlin/jvm/internal/e;->e(Ljava/lang/Object;Ljava/lang/String;)V

    iput-object v1, p0, Lcom/cmcm/safewallet/data/dapp/h;->UZ:Lrx/subjects/a;

    .line 14
    invoke-static {}, Ljava/util/concurrent/Executors;->newSingleThreadExecutor()Ljava/util/concurrent/ExecutorService;

    move-result-object v0

    check-cast v0, Ljava/util/concurrent/Executor;

    invoke-static {v0}, Lrx/e/a;->b(Ljava/util/concurrent/Executor;)Lrx/j;

    move-result-object v0

    const-string v1, "Schedulers.from(Executor\u2026ewSingleThreadExecutor())"

    invoke-static {v0, v1}, Lkotlin/jvm/internal/e;->e(Ljava/lang/Object;Ljava/lang/String;)V

    iput-object v0, p0, Lcom/cmcm/safewallet/data/dapp/h;->scheduler:Lrx/j;

    .line 15
    new-instance v0, Lcom/cmcm/safewallet/data/dapp/e;

    invoke-direct {v0}, Lcom/cmcm/safewallet/data/dapp/e;-><init>()V

    .line 23
    iget-object v0, p0, Lcom/cmcm/safewallet/data/dapp/h;->UZ:Lrx/subjects/a;

    const/4 v1, 0x0

    invoke-virtual {v0, v1}, Lrx/subjects/a;->onNext(Ljava/lang/Object;)V

    .line 15040
    iget-object v0, p0, Lcom/cmcm/safewallet/data/dapp/h;->UN:Lcom/cmcm/safewallet/data/dapp/d;

    if-eqz v0, :cond_58

    .line 15041
    invoke-static {}, Lrx/a;->SF()Lrx/a;

    move-result-object v0

    const-string v1, "Completable.complete()"

    invoke-static {v0, v1}, Lkotlin/jvm/internal/e;->e(Ljava/lang/Object;Ljava/lang/String;)V

    move-object v2, v0

    .line 15031
    :goto_49
    sget-object v0, Lcom/cmcm/safewallet/data/dapp/h$a;->Vc:Lcom/cmcm/safewallet/data/dapp/h$a;

    check-cast v0, Lrx/b/a;

    .line 15032
    new-instance v1, Lcom/cmcm/safewallet/data/dapp/h$b;

    invoke-direct {v1}, Lcom/cmcm/safewallet/data/dapp/h$b;-><init>()V

    check-cast v1, Lrx/b/b;

    .line 15030
    invoke-virtual {v2, v0, v1}, Lrx/a;->a(Lrx/b/a;Lrx/b/b;)Lrx/p;

    .line 24
    return-void

    .line 16010
    :cond_58
    new-instance v0, Lcom/cmcm/safewallet/data/dapp/e$a;

    invoke-direct {v0}, Lcom/cmcm/safewallet/data/dapp/e$a;-><init>()V

    check-cast v0, Ljava/util/concurrent/Callable;

    invoke-static {v0}, Lrx/l;->e(Ljava/util/concurrent/Callable;)Lrx/l;

    move-result-object v1

    .line 16013
    sget-object v0, Lcom/cmcm/safewallet/data/dapp/e$b;->UW:Lcom/cmcm/safewallet/data/dapp/e$b;

    check-cast v0, Lrx/b/b;

    invoke-virtual {v1, v0}, Lrx/l;->a(Lrx/b/b;)Lrx/l;

    move-result-object v1

    const-string v0, "Single.fromCallable {\n//\u2026tting existing wallet\") }"

    invoke-static {v1, v0}, Lkotlin/jvm/internal/e;->e(Ljava/lang/Object;Ljava/lang/String;)V

    .line 15044
    new-instance v0, Lcom/cmcm/safewallet/data/dapp/h$c;

    invoke-direct {v0, p0}, Lcom/cmcm/safewallet/data/dapp/h$c;-><init>(Lcom/cmcm/safewallet/data/dapp/h;)V

    check-cast v0, Lrx/b/b;

    .line 16301
    invoke-static {}, Lrx/b/c;->SP()Lrx/b/d;

    move-result-object v2

    .line 16302
    new-instance v3, Lrx/internal/operators/y;

    invoke-direct {v3, v1, v0, v2}, Lrx/internal/operators/y;-><init>(Lrx/l;Lrx/b/b;Lrx/b/b;)V

    invoke-static {v3}, Lrx/l;->a(Lrx/m;)Lrx/l;

    move-result-object v1

    .line 15045
    sget-object v0, Lcom/cmcm/safewallet/data/dapp/h$d;->Ve:Lcom/cmcm/safewallet/data/dapp/h$d;

    check-cast v0, Lrx/b/b;

    invoke-virtual {v1, v0}, Lrx/l;->a(Lrx/b/b;)Lrx/l;

    move-result-object v0

    .line 17067
    invoke-static {v0}, Lrx/a;->a(Lrx/l;)Lrx/a;

    move-result-object v0

    .line 15046
    iget-object v1, p0, Lcom/cmcm/safewallet/data/dapp/h;->scheduler:Lrx/j;

    invoke-virtual {v0, v1}, Lrx/a;->a(Lrx/j;)Lrx/a;

    move-result-object v0

    const-string v1, "walletBuilder\n          \u2026  .subscribeOn(scheduler)"

    invoke-static {v0, v1}, Lkotlin/jvm/internal/e;->e(Ljava/lang/Object;Ljava/lang/String;)V

    move-object v2, v0

    goto :goto_49
.end method

.method public synthetic constructor <init>(B)V
    .registers 2

    .prologue
    .line 12
    invoke-direct {p0}, Lcom/cmcm/safewallet/data/dapp/h;-><init>()V

    return-void
.end method

.method public static final synthetic a(Lcom/cmcm/safewallet/data/dapp/h;Lcom/cmcm/safewallet/data/dapp/d;)V
    .registers 3
    .param p1    # Lcom/cmcm/safewallet/data/dapp/d;
        .annotation build Lorg/jetbrains/annotations/Nullable;
        .end annotation
    .end param

    .prologue
    .line 12
    .line 18050
    iput-object p1, p0, Lcom/cmcm/safewallet/data/dapp/h;->UN:Lcom/cmcm/safewallet/data/dapp/d;

    .line 18051
    iget-object v0, p0, Lcom/cmcm/safewallet/data/dapp/h;->UZ:Lrx/subjects/a;

    invoke-virtual {v0, p1}, Lrx/subjects/a;->onNext(Ljava/lang/Object;)V

    .line 12
    return-void
.end method

.method public static final synthetic jo()V
    .registers 0

    .prologue
    .line 12
    return-void
.end method

.method public static final synthetic jp()Lkotlin/a;
    .registers 1
    .annotation build Lorg/jetbrains/annotations/NotNull;
    .end annotation

    .prologue
    .line 12
    sget-object v0, Lcom/cmcm/safewallet/data/dapp/h;->Va:Lkotlin/a;

    return-object v0
.end method


# virtual methods
.method public final jn()Lrx/l;
    .registers 4
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "()",
            "Lrx/l",
            "<",
            "Lcom/cmcm/safewallet/data/dapp/d;",
            ">;"
        }
    .end annotation

    .annotation build Lorg/jetbrains/annotations/NotNull;
    .end annotation

    .prologue
    .line 55
    iget-object v0, p0, Lcom/cmcm/safewallet/data/dapp/h;->UZ:Lrx/subjects/a;

    check-cast v0, Lrx/e;

    const-string v1, "$receiver"

    invoke-static {v0, v1}, Lkotlin/jvm/internal/e;->f(Ljava/lang/Object;Ljava/lang/String;)V

    .line 11026
    sget-object v1, Lcom/cmcm/safewallet/data/dapp/f$a;->UX:Lcom/cmcm/safewallet/data/dapp/f$a;

    check-cast v1, Lrx/b/f;

    .line 11560
    new-instance v2, Lrx/internal/operators/g;

    invoke-direct {v2, v0, v1}, Lrx/internal/operators/g;-><init>(Lrx/e;Lrx/b/f;)V

    invoke-static {v2}, Lrx/e;->a(Lrx/f;)Lrx/e;

    move-result-object v0

    .line 12381
    new-instance v1, Lrx/internal/operators/x;

    invoke-direct {v1}, Lrx/internal/operators/x;-><init>()V

    invoke-virtual {v0, v1}, Lrx/e;->a(Lrx/g;)Lrx/e;

    move-result-object v0

    .line 14049
    sget-object v1, Lrx/internal/operators/u;->caZ:Lrx/internal/operators/t;

    .line 13328
    invoke-virtual {v0, v1}, Lrx/e;->a(Lrx/g;)Lrx/e;

    move-result-object v0

    .line 11028
    invoke-virtual {v0}, Lrx/e;->SH()Lrx/l;

    move-result-object v1

    .line 11030
    sget-object v0, Lcom/cmcm/safewallet/data/dapp/f$b;->UY:Lcom/cmcm/safewallet/data/dapp/f$b;

    check-cast v0, Lrx/b/b;

    invoke-virtual {v1, v0}, Lrx/l;->a(Lrx/b/b;)Lrx/l;

    move-result-object v0

    const-string v1, "filter { it != null }\n  \u2026,\"Wallet is null\" + it) }"

    invoke-static {v0, v1}, Lkotlin/jvm/internal/e;->e(Ljava/lang/Object;Ljava/lang/String;)V

    .line 56
    iget-object v1, p0, Lcom/cmcm/safewallet/data/dapp/h;->scheduler:Lrx/j;

    invoke-virtual {v0, v1}, Lrx/l;->d(Lrx/j;)Lrx/l;

    move-result-object v0

    const-string v1, "walletSubject.getTimeout\u2026  .subscribeOn(scheduler)"

    invoke-static {v0, v1}, Lkotlin/jvm/internal/e;->e(Ljava/lang/Object;Ljava/lang/String;)V

    return-object v0
.end method