801 lines
23 KiB
Smali
801 lines
23 KiB
Smali
.class public final Lcom/vk/common/cache/SerializerCache;
|
|
.super Ljava/lang/Object;
|
|
.source "SerializerCache.kt"
|
|
|
|
|
|
# annotations
|
|
.annotation system Ldalvik/annotation/MemberClasses;
|
|
value = {
|
|
Lcom/vk/common/cache/SerializerCache$a;
|
|
}
|
|
.end annotation
|
|
|
|
|
|
# static fields
|
|
.field private static final a:Lcom/vk/common/cache/SerializerCache$a;
|
|
|
|
.field private static final b:Ljava/util/HashMap;
|
|
.annotation system Ldalvik/annotation/Signature;
|
|
value = {
|
|
"Ljava/util/HashMap<",
|
|
"Ljava/lang/String;",
|
|
"Ljava/lang/ref/SoftReference<",
|
|
"Ljava/lang/Object;",
|
|
">;>;"
|
|
}
|
|
.end annotation
|
|
.end field
|
|
|
|
.field public static final c:Lcom/vk/common/cache/SerializerCache;
|
|
|
|
|
|
# direct methods
|
|
.method static constructor <clinit>()V
|
|
.locals 3
|
|
|
|
.line 1
|
|
new-instance v0, Lcom/vk/common/cache/SerializerCache;
|
|
|
|
invoke-direct {v0}, Lcom/vk/common/cache/SerializerCache;-><init>()V
|
|
|
|
sput-object v0, Lcom/vk/common/cache/SerializerCache;->c:Lcom/vk/common/cache/SerializerCache;
|
|
|
|
.line 2
|
|
new-instance v0, Lcom/vk/common/cache/SerializerCache$a;
|
|
|
|
sget-object v1, Lcom/vk/core/util/AppContextHolder;->a:Landroid/content/Context;
|
|
|
|
const-string v2, "AppContextHolder.context"
|
|
|
|
invoke-static {v1, v2}, Lkotlin/jvm/internal/Intrinsics;->a(Ljava/lang/Object;Ljava/lang/String;)V
|
|
|
|
invoke-direct {v0, v1}, Lcom/vk/common/cache/SerializerCache$a;-><init>(Landroid/content/Context;)V
|
|
|
|
sput-object v0, Lcom/vk/common/cache/SerializerCache;->a:Lcom/vk/common/cache/SerializerCache$a;
|
|
|
|
.line 3
|
|
new-instance v0, Ljava/util/HashMap;
|
|
|
|
invoke-direct {v0}, Ljava/util/HashMap;-><init>()V
|
|
|
|
sput-object v0, Lcom/vk/common/cache/SerializerCache;->b:Ljava/util/HashMap;
|
|
|
|
return-void
|
|
.end method
|
|
|
|
.method private constructor <init>()V
|
|
.locals 0
|
|
|
|
.line 1
|
|
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
|
|
|
|
return-void
|
|
.end method
|
|
|
|
.method public static synthetic a(Lcom/vk/common/cache/SerializerCache;Ljava/lang/String;ZILjava/lang/Object;)Lio/reactivex/Observable;
|
|
.locals 0
|
|
|
|
and-int/lit8 p3, p3, 0x2
|
|
|
|
if-eqz p3, :cond_0
|
|
|
|
const/4 p2, 0x1
|
|
|
|
.line 21
|
|
:cond_0
|
|
invoke-virtual {p0, p1, p2}, Lcom/vk/common/cache/SerializerCache;->a(Ljava/lang/String;Z)Lio/reactivex/Observable;
|
|
|
|
move-result-object p0
|
|
|
|
return-object p0
|
|
.end method
|
|
|
|
.method public static synthetic a(Lcom/vk/common/cache/SerializerCache;Ljava/lang/String;ZLio/reactivex/Scheduler;ILjava/lang/Object;)Lio/reactivex/Observable;
|
|
.locals 0
|
|
|
|
and-int/lit8 p5, p4, 0x2
|
|
|
|
if-eqz p5, :cond_0
|
|
|
|
const/4 p2, 0x1
|
|
|
|
:cond_0
|
|
and-int/lit8 p4, p4, 0x4
|
|
|
|
if-eqz p4, :cond_1
|
|
|
|
.line 27
|
|
invoke-static {}, Lio/reactivex/schedulers/Schedulers;->c()Lio/reactivex/Scheduler;
|
|
|
|
move-result-object p3
|
|
|
|
const-string p4, "Schedulers.single()"
|
|
|
|
invoke-static {p3, p4}, Lkotlin/jvm/internal/Intrinsics;->a(Ljava/lang/Object;Ljava/lang/String;)V
|
|
|
|
:cond_1
|
|
invoke-virtual {p0, p1, p2, p3}, Lcom/vk/common/cache/SerializerCache;->a(Ljava/lang/String;ZLio/reactivex/Scheduler;)Lio/reactivex/Observable;
|
|
|
|
move-result-object p0
|
|
|
|
return-object p0
|
|
.end method
|
|
|
|
.method public static final synthetic a(Lcom/vk/common/cache/SerializerCache;)Ljava/util/HashMap;
|
|
.locals 0
|
|
|
|
.line 1
|
|
sget-object p0, Lcom/vk/common/cache/SerializerCache;->b:Ljava/util/HashMap;
|
|
|
|
return-object p0
|
|
.end method
|
|
|
|
.method public static synthetic b(Lcom/vk/common/cache/SerializerCache;Ljava/lang/String;ZILjava/lang/Object;)Lio/reactivex/Observable;
|
|
.locals 0
|
|
|
|
and-int/lit8 p3, p3, 0x2
|
|
|
|
if-eqz p3, :cond_0
|
|
|
|
const/4 p2, 0x1
|
|
|
|
.line 2
|
|
:cond_0
|
|
invoke-virtual {p0, p1, p2}, Lcom/vk/common/cache/SerializerCache;->b(Ljava/lang/String;Z)Lio/reactivex/Observable;
|
|
|
|
move-result-object p0
|
|
|
|
return-object p0
|
|
.end method
|
|
|
|
.method public static final synthetic b(Lcom/vk/common/cache/SerializerCache;)Lcom/vk/common/cache/SerializerCache$a;
|
|
.locals 0
|
|
|
|
.line 1
|
|
sget-object p0, Lcom/vk/common/cache/SerializerCache;->a:Lcom/vk/common/cache/SerializerCache$a;
|
|
|
|
return-object p0
|
|
.end method
|
|
|
|
|
|
# virtual methods
|
|
.method public final a(Ljava/lang/String;)Lio/reactivex/Observable;
|
|
.locals 2
|
|
.annotation system Ldalvik/annotation/Signature;
|
|
value = {
|
|
"<T::",
|
|
"Lcom/vk/core/serialize/Serializer$StreamParcelable;",
|
|
">(",
|
|
"Ljava/lang/String;",
|
|
")",
|
|
"Lio/reactivex/Observable<",
|
|
"Ljava/util/List<",
|
|
"TT;>;>;"
|
|
}
|
|
.end annotation
|
|
|
|
.line 11
|
|
sget-object v0, Lcom/vk/common/cache/SerializerCache;->b:Ljava/util/HashMap;
|
|
|
|
invoke-virtual {v0, p1}, Ljava/util/HashMap;->get(Ljava/lang/Object;)Ljava/lang/Object;
|
|
|
|
move-result-object v0
|
|
|
|
check-cast v0, Ljava/lang/ref/SoftReference;
|
|
|
|
if-eqz v0, :cond_1
|
|
|
|
invoke-virtual {v0}, Ljava/lang/ref/SoftReference;->get()Ljava/lang/Object;
|
|
|
|
move-result-object v0
|
|
|
|
if-eqz v0, :cond_1
|
|
|
|
if-eqz v0, :cond_0
|
|
|
|
check-cast v0, Ljava/util/List;
|
|
|
|
invoke-static {v0}, Lio/reactivex/Observable;->e(Ljava/lang/Object;)Lio/reactivex/Observable;
|
|
|
|
move-result-object p1
|
|
|
|
const-string v0, "Observable.just(it as List<T>)"
|
|
|
|
invoke-static {p1, v0}, Lkotlin/jvm/internal/Intrinsics;->a(Ljava/lang/Object;Ljava/lang/String;)V
|
|
|
|
return-object p1
|
|
|
|
:cond_0
|
|
new-instance p1, Lkotlin/TypeCastException;
|
|
|
|
const-string v0, "null cannot be cast to non-null type kotlin.collections.List<T>"
|
|
|
|
invoke-direct {p1, v0}, Lkotlin/TypeCastException;-><init>(Ljava/lang/String;)V
|
|
|
|
throw p1
|
|
|
|
.line 12
|
|
:cond_1
|
|
new-instance v0, Lcom/vk/common/cache/SerializerCache$f;
|
|
|
|
invoke-direct {v0, p1}, Lcom/vk/common/cache/SerializerCache$f;-><init>(Ljava/lang/String;)V
|
|
|
|
invoke-static {v0}, Lio/reactivex/Observable;->c(Ljava/util/concurrent/Callable;)Lio/reactivex/Observable;
|
|
|
|
move-result-object v0
|
|
|
|
.line 13
|
|
invoke-static {}, Lio/reactivex/schedulers/Schedulers;->c()Lio/reactivex/Scheduler;
|
|
|
|
move-result-object v1
|
|
|
|
invoke-virtual {v0, v1}, Lio/reactivex/Observable;->b(Lio/reactivex/Scheduler;)Lio/reactivex/Observable;
|
|
|
|
move-result-object v0
|
|
|
|
.line 14
|
|
invoke-static {}, Lio/reactivex/schedulers/AndroidSchedulers;->a()Lio/reactivex/Scheduler;
|
|
|
|
move-result-object v1
|
|
|
|
invoke-virtual {v0, v1}, Lio/reactivex/Observable;->a(Lio/reactivex/Scheduler;)Lio/reactivex/Observable;
|
|
|
|
move-result-object v0
|
|
|
|
.line 15
|
|
new-instance v1, Lcom/vk/common/cache/SerializerCache$g;
|
|
|
|
invoke-direct {v1, p1}, Lcom/vk/common/cache/SerializerCache$g;-><init>(Ljava/lang/String;)V
|
|
|
|
invoke-virtual {v0, v1}, Lio/reactivex/Observable;->d(Lio/reactivex/functions/Consumer;)Lio/reactivex/Observable;
|
|
|
|
move-result-object p1
|
|
|
|
const-string v0, "Observable.fromCallable \u2026oftReference(it as Any) }"
|
|
|
|
invoke-static {p1, v0}, Lkotlin/jvm/internal/Intrinsics;->a(Ljava/lang/Object;Ljava/lang/String;)V
|
|
|
|
return-object p1
|
|
.end method
|
|
|
|
.method public final a(Ljava/lang/String;Z)Lio/reactivex/Observable;
|
|
.locals 2
|
|
.annotation system Ldalvik/annotation/Signature;
|
|
value = {
|
|
"<T::",
|
|
"Lcom/vk/core/serialize/Serializer$StreamParcelable;",
|
|
">(",
|
|
"Ljava/lang/String;",
|
|
"Z)",
|
|
"Lio/reactivex/Observable<",
|
|
"TT;>;"
|
|
}
|
|
.end annotation
|
|
|
|
.line 22
|
|
sget-object v0, Lcom/vk/common/cache/SerializerCache;->b:Ljava/util/HashMap;
|
|
|
|
invoke-virtual {v0, p1}, Ljava/util/HashMap;->get(Ljava/lang/Object;)Ljava/lang/Object;
|
|
|
|
move-result-object v0
|
|
|
|
check-cast v0, Ljava/lang/ref/SoftReference;
|
|
|
|
if-eqz v0, :cond_1
|
|
|
|
invoke-virtual {v0}, Ljava/lang/ref/SoftReference;->get()Ljava/lang/Object;
|
|
|
|
move-result-object v0
|
|
|
|
if-eqz v0, :cond_1
|
|
|
|
if-eqz v0, :cond_0
|
|
|
|
check-cast v0, Lcom/vk/core/serialize/Serializer$StreamParcelable;
|
|
|
|
invoke-static {v0}, Lio/reactivex/Observable;->e(Ljava/lang/Object;)Lio/reactivex/Observable;
|
|
|
|
move-result-object p1
|
|
|
|
const-string p2, "Observable.just(it as T)"
|
|
|
|
invoke-static {p1, p2}, Lkotlin/jvm/internal/Intrinsics;->a(Ljava/lang/Object;Ljava/lang/String;)V
|
|
|
|
return-object p1
|
|
|
|
:cond_0
|
|
new-instance p1, Lkotlin/TypeCastException;
|
|
|
|
const-string p2, "null cannot be cast to non-null type T"
|
|
|
|
invoke-direct {p1, p2}, Lkotlin/TypeCastException;-><init>(Ljava/lang/String;)V
|
|
|
|
throw p1
|
|
|
|
.line 23
|
|
:cond_1
|
|
new-instance v0, Lcom/vk/common/cache/SerializerCache$h;
|
|
|
|
invoke-direct {v0, p1}, Lcom/vk/common/cache/SerializerCache$h;-><init>(Ljava/lang/String;)V
|
|
|
|
invoke-static {v0}, Lio/reactivex/Observable;->a(Lio/reactivex/ObservableOnSubscribe;)Lio/reactivex/Observable;
|
|
|
|
move-result-object v0
|
|
|
|
.line 24
|
|
invoke-static {}, Lio/reactivex/schedulers/Schedulers;->c()Lio/reactivex/Scheduler;
|
|
|
|
move-result-object v1
|
|
|
|
invoke-virtual {v0, v1}, Lio/reactivex/Observable;->b(Lio/reactivex/Scheduler;)Lio/reactivex/Observable;
|
|
|
|
move-result-object v0
|
|
|
|
.line 25
|
|
invoke-static {}, Lio/reactivex/schedulers/AndroidSchedulers;->a()Lio/reactivex/Scheduler;
|
|
|
|
move-result-object v1
|
|
|
|
invoke-virtual {v0, v1}, Lio/reactivex/Observable;->a(Lio/reactivex/Scheduler;)Lio/reactivex/Observable;
|
|
|
|
move-result-object v0
|
|
|
|
.line 26
|
|
new-instance v1, Lcom/vk/common/cache/SerializerCache$i;
|
|
|
|
invoke-direct {v1, p2, p1}, Lcom/vk/common/cache/SerializerCache$i;-><init>(ZLjava/lang/String;)V
|
|
|
|
invoke-virtual {v0, v1}, Lio/reactivex/Observable;->d(Lio/reactivex/functions/Consumer;)Lio/reactivex/Observable;
|
|
|
|
move-result-object p1
|
|
|
|
const-string p2, "Observable.create<T> {\n \u2026oftReference(it as Any) }"
|
|
|
|
invoke-static {p1, p2}, Lkotlin/jvm/internal/Intrinsics;->a(Ljava/lang/Object;Ljava/lang/String;)V
|
|
|
|
return-object p1
|
|
.end method
|
|
|
|
.method public final a(Ljava/lang/String;ZLio/reactivex/Scheduler;)Lio/reactivex/Observable;
|
|
.locals 1
|
|
.annotation system Ldalvik/annotation/Signature;
|
|
value = {
|
|
"<T::",
|
|
"Lcom/vk/core/serialize/Serializer$StreamParcelable;",
|
|
">(",
|
|
"Ljava/lang/String;",
|
|
"Z",
|
|
"Lio/reactivex/Scheduler;",
|
|
")",
|
|
"Lio/reactivex/Observable<",
|
|
"TT;>;"
|
|
}
|
|
.end annotation
|
|
|
|
.line 28
|
|
sget-object v0, Lcom/vk/common/cache/SerializerCache;->b:Ljava/util/HashMap;
|
|
|
|
invoke-virtual {v0, p1}, Ljava/util/HashMap;->get(Ljava/lang/Object;)Ljava/lang/Object;
|
|
|
|
move-result-object v0
|
|
|
|
check-cast v0, Ljava/lang/ref/SoftReference;
|
|
|
|
if-eqz v0, :cond_1
|
|
|
|
invoke-virtual {v0}, Ljava/lang/ref/SoftReference;->get()Ljava/lang/Object;
|
|
|
|
move-result-object v0
|
|
|
|
if-eqz v0, :cond_1
|
|
|
|
if-eqz v0, :cond_0
|
|
|
|
check-cast v0, Lcom/vk/core/serialize/Serializer$StreamParcelable;
|
|
|
|
invoke-static {v0}, Lio/reactivex/Observable;->e(Ljava/lang/Object;)Lio/reactivex/Observable;
|
|
|
|
move-result-object p1
|
|
|
|
invoke-virtual {p1, p3}, Lio/reactivex/Observable;->b(Lio/reactivex/Scheduler;)Lio/reactivex/Observable;
|
|
|
|
move-result-object p1
|
|
|
|
const-string p2, "Observable.just(it as T).subscribeOn(scheduler)"
|
|
|
|
invoke-static {p1, p2}, Lkotlin/jvm/internal/Intrinsics;->a(Ljava/lang/Object;Ljava/lang/String;)V
|
|
|
|
return-object p1
|
|
|
|
:cond_0
|
|
new-instance p1, Lkotlin/TypeCastException;
|
|
|
|
const-string p2, "null cannot be cast to non-null type T"
|
|
|
|
invoke-direct {p1, p2}, Lkotlin/TypeCastException;-><init>(Ljava/lang/String;)V
|
|
|
|
throw p1
|
|
|
|
.line 29
|
|
:cond_1
|
|
new-instance v0, Lcom/vk/common/cache/SerializerCache$j;
|
|
|
|
invoke-direct {v0, p1}, Lcom/vk/common/cache/SerializerCache$j;-><init>(Ljava/lang/String;)V
|
|
|
|
invoke-static {v0}, Lio/reactivex/Observable;->a(Lio/reactivex/ObservableOnSubscribe;)Lio/reactivex/Observable;
|
|
|
|
move-result-object v0
|
|
|
|
.line 30
|
|
invoke-virtual {v0, p3}, Lio/reactivex/Observable;->b(Lio/reactivex/Scheduler;)Lio/reactivex/Observable;
|
|
|
|
move-result-object p3
|
|
|
|
.line 31
|
|
invoke-static {}, Lio/reactivex/schedulers/AndroidSchedulers;->a()Lio/reactivex/Scheduler;
|
|
|
|
move-result-object v0
|
|
|
|
invoke-virtual {p3, v0}, Lio/reactivex/Observable;->a(Lio/reactivex/Scheduler;)Lio/reactivex/Observable;
|
|
|
|
move-result-object p3
|
|
|
|
.line 32
|
|
new-instance v0, Lcom/vk/common/cache/SerializerCache$k;
|
|
|
|
invoke-direct {v0, p2, p1}, Lcom/vk/common/cache/SerializerCache$k;-><init>(ZLjava/lang/String;)V
|
|
|
|
invoke-virtual {p3, v0}, Lio/reactivex/Observable;->d(Lio/reactivex/functions/Consumer;)Lio/reactivex/Observable;
|
|
|
|
move-result-object p1
|
|
|
|
const-string p2, "Observable.create<T> {\n \u2026oftReference(it as Any) }"
|
|
|
|
invoke-static {p1, p2}, Lkotlin/jvm/internal/Intrinsics;->a(Ljava/lang/Object;Ljava/lang/String;)V
|
|
|
|
return-object p1
|
|
.end method
|
|
|
|
.method public final a()V
|
|
.locals 2
|
|
|
|
.line 2
|
|
sget-object v0, Lcom/vk/common/cache/SerializerCache$b;->a:Lcom/vk/common/cache/SerializerCache$b;
|
|
|
|
invoke-static {v0}, Lio/reactivex/Observable;->c(Ljava/util/concurrent/Callable;)Lio/reactivex/Observable;
|
|
|
|
move-result-object v0
|
|
|
|
.line 3
|
|
invoke-static {}, Lio/reactivex/schedulers/Schedulers;->c()Lio/reactivex/Scheduler;
|
|
|
|
move-result-object v1
|
|
|
|
invoke-virtual {v0, v1}, Lio/reactivex/Observable;->b(Lio/reactivex/Scheduler;)Lio/reactivex/Observable;
|
|
|
|
move-result-object v0
|
|
|
|
.line 4
|
|
invoke-static {}, Lio/reactivex/schedulers/AndroidSchedulers;->a()Lio/reactivex/Scheduler;
|
|
|
|
move-result-object v1
|
|
|
|
invoke-virtual {v0, v1}, Lio/reactivex/Observable;->a(Lio/reactivex/Scheduler;)Lio/reactivex/Observable;
|
|
|
|
move-result-object v0
|
|
|
|
.line 5
|
|
sget-object v1, Lcom/vk/common/cache/SerializerCache$c;->a:Lcom/vk/common/cache/SerializerCache$c;
|
|
|
|
invoke-virtual {v0, v1}, Lio/reactivex/Observable;->d(Lio/reactivex/functions/Consumer;)Lio/reactivex/Observable;
|
|
|
|
move-result-object v0
|
|
|
|
const-string v1, "Observable.fromCallable \u2026oOnNext { cache.clear() }"
|
|
|
|
invoke-static {v0, v1}, Lkotlin/jvm/internal/Intrinsics;->a(Ljava/lang/Object;Ljava/lang/String;)V
|
|
|
|
invoke-static {v0}, Lcom/vk/core/extensions/RxExtKt;->b(Lio/reactivex/Observable;)Lio/reactivex/disposables/Disposable;
|
|
|
|
return-void
|
|
.end method
|
|
|
|
.method public final a(Ljava/lang/String;Lcom/vk/core/serialize/Serializer$StreamParcelable;)V
|
|
.locals 2
|
|
.annotation build Landroidx/annotation/AnyThread;
|
|
.end annotation
|
|
|
|
.annotation system Ldalvik/annotation/Signature;
|
|
value = {
|
|
"<T::",
|
|
"Lcom/vk/core/serialize/Serializer$StreamParcelable;",
|
|
">(",
|
|
"Ljava/lang/String;",
|
|
"TT;)V"
|
|
}
|
|
.end annotation
|
|
|
|
.line 33
|
|
sget-object v0, Lcom/vk/common/cache/SerializerCache;->b:Ljava/util/HashMap;
|
|
|
|
new-instance v1, Ljava/lang/ref/SoftReference;
|
|
|
|
invoke-direct {v1, p2}, Ljava/lang/ref/SoftReference;-><init>(Ljava/lang/Object;)V
|
|
|
|
invoke-interface {v0, p1, v1}, Ljava/util/Map;->put(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
|
|
|
|
.line 34
|
|
invoke-static {p2}, Ljava/util/Collections;->singletonList(Ljava/lang/Object;)Ljava/util/List;
|
|
|
|
move-result-object p2
|
|
|
|
.line 35
|
|
new-instance v0, Lcom/vk/common/cache/SerializerCache$o;
|
|
|
|
invoke-direct {v0, p1, p2}, Lcom/vk/common/cache/SerializerCache$o;-><init>(Ljava/lang/String;Ljava/util/List;)V
|
|
|
|
invoke-static {v0}, Lio/reactivex/Observable;->c(Ljava/util/concurrent/Callable;)Lio/reactivex/Observable;
|
|
|
|
move-result-object p1
|
|
|
|
.line 36
|
|
invoke-static {}, Lio/reactivex/schedulers/Schedulers;->c()Lio/reactivex/Scheduler;
|
|
|
|
move-result-object p2
|
|
|
|
invoke-virtual {p1, p2}, Lio/reactivex/Observable;->b(Lio/reactivex/Scheduler;)Lio/reactivex/Observable;
|
|
|
|
move-result-object p1
|
|
|
|
.line 37
|
|
invoke-static {}, Lio/reactivex/schedulers/AndroidSchedulers;->a()Lio/reactivex/Scheduler;
|
|
|
|
move-result-object p2
|
|
|
|
invoke-virtual {p1, p2}, Lio/reactivex/Observable;->a(Lio/reactivex/Scheduler;)Lio/reactivex/Observable;
|
|
|
|
move-result-object p1
|
|
|
|
const-string p2, "Observable.fromCallable \u2026dSchedulers.mainThread())"
|
|
|
|
invoke-static {p1, p2}, Lkotlin/jvm/internal/Intrinsics;->a(Ljava/lang/Object;Ljava/lang/String;)V
|
|
|
|
.line 38
|
|
invoke-static {p1}, Lcom/vk/core/extensions/RxExtKt;->b(Lio/reactivex/Observable;)Lio/reactivex/disposables/Disposable;
|
|
|
|
return-void
|
|
.end method
|
|
|
|
.method public final a(Ljava/lang/String;Ljava/util/List;)V
|
|
.locals 2
|
|
.annotation system Ldalvik/annotation/Signature;
|
|
value = {
|
|
"<T::",
|
|
"Lcom/vk/core/serialize/Serializer$StreamParcelable;",
|
|
">(",
|
|
"Ljava/lang/String;",
|
|
"Ljava/util/List<",
|
|
"+TT;>;)V"
|
|
}
|
|
.end annotation
|
|
|
|
.line 16
|
|
new-instance v0, Ljava/util/ArrayList;
|
|
|
|
invoke-direct {v0, p2}, Ljava/util/ArrayList;-><init>(Ljava/util/Collection;)V
|
|
|
|
.line 17
|
|
sget-object p2, Lcom/vk/common/cache/SerializerCache;->b:Ljava/util/HashMap;
|
|
|
|
new-instance v1, Ljava/lang/ref/SoftReference;
|
|
|
|
invoke-direct {v1, v0}, Ljava/lang/ref/SoftReference;-><init>(Ljava/lang/Object;)V
|
|
|
|
invoke-interface {p2, p1, v1}, Ljava/util/Map;->put(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
|
|
|
|
.line 18
|
|
new-instance p2, Lcom/vk/common/cache/SerializerCache$n;
|
|
|
|
invoke-direct {p2, p1, v0}, Lcom/vk/common/cache/SerializerCache$n;-><init>(Ljava/lang/String;Ljava/util/ArrayList;)V
|
|
|
|
invoke-static {p2}, Lio/reactivex/Observable;->c(Ljava/util/concurrent/Callable;)Lio/reactivex/Observable;
|
|
|
|
move-result-object p1
|
|
|
|
.line 19
|
|
invoke-static {}, Lio/reactivex/schedulers/Schedulers;->c()Lio/reactivex/Scheduler;
|
|
|
|
move-result-object p2
|
|
|
|
invoke-virtual {p1, p2}, Lio/reactivex/Observable;->b(Lio/reactivex/Scheduler;)Lio/reactivex/Observable;
|
|
|
|
move-result-object p1
|
|
|
|
const-string p2, "Observable.fromCallable \u2026beOn(Schedulers.single())"
|
|
|
|
invoke-static {p1, p2}, Lkotlin/jvm/internal/Intrinsics;->a(Ljava/lang/Object;Ljava/lang/String;)V
|
|
|
|
.line 20
|
|
invoke-static {p1}, Lcom/vk/core/extensions/RxExtKt;->b(Lio/reactivex/Observable;)Lio/reactivex/disposables/Disposable;
|
|
|
|
return-void
|
|
.end method
|
|
|
|
.method public final varargs a([Ljava/lang/String;)V
|
|
.locals 2
|
|
|
|
.line 6
|
|
new-instance v0, Lcom/vk/common/cache/SerializerCache$d;
|
|
|
|
invoke-direct {v0, p1}, Lcom/vk/common/cache/SerializerCache$d;-><init>([Ljava/lang/String;)V
|
|
|
|
invoke-static {v0}, Lio/reactivex/Observable;->c(Ljava/util/concurrent/Callable;)Lio/reactivex/Observable;
|
|
|
|
move-result-object v0
|
|
|
|
.line 7
|
|
invoke-static {}, Lio/reactivex/schedulers/Schedulers;->c()Lio/reactivex/Scheduler;
|
|
|
|
move-result-object v1
|
|
|
|
invoke-virtual {v0, v1}, Lio/reactivex/Observable;->b(Lio/reactivex/Scheduler;)Lio/reactivex/Observable;
|
|
|
|
move-result-object v0
|
|
|
|
.line 8
|
|
invoke-static {}, Lio/reactivex/schedulers/AndroidSchedulers;->a()Lio/reactivex/Scheduler;
|
|
|
|
move-result-object v1
|
|
|
|
invoke-virtual {v0, v1}, Lio/reactivex/Observable;->a(Lio/reactivex/Scheduler;)Lio/reactivex/Observable;
|
|
|
|
move-result-object v0
|
|
|
|
.line 9
|
|
new-instance v1, Lcom/vk/common/cache/SerializerCache$e;
|
|
|
|
invoke-direct {v1, p1}, Lcom/vk/common/cache/SerializerCache$e;-><init>([Ljava/lang/String;)V
|
|
|
|
invoke-virtual {v0, v1}, Lio/reactivex/Observable;->d(Lio/reactivex/functions/Consumer;)Lio/reactivex/Observable;
|
|
|
|
move-result-object p1
|
|
|
|
const-string v0, "Observable.fromCallable \u2026 }\n }"
|
|
|
|
invoke-static {p1, v0}, Lkotlin/jvm/internal/Intrinsics;->a(Ljava/lang/Object;Ljava/lang/String;)V
|
|
|
|
.line 10
|
|
invoke-static {p1}, Lcom/vk/core/extensions/RxExtKt;->b(Lio/reactivex/Observable;)Lio/reactivex/disposables/Disposable;
|
|
|
|
return-void
|
|
.end method
|
|
|
|
.method public final b(Ljava/lang/String;Z)Lio/reactivex/Observable;
|
|
.locals 2
|
|
.annotation system Ldalvik/annotation/Signature;
|
|
value = {
|
|
"<T::",
|
|
"Lcom/vk/core/serialize/Serializer$StreamParcelable;",
|
|
">(",
|
|
"Ljava/lang/String;",
|
|
"Z)",
|
|
"Lio/reactivex/Observable<",
|
|
"Lcom/vk/core/util/Optional<",
|
|
"TT;>;>;"
|
|
}
|
|
.end annotation
|
|
|
|
.line 3
|
|
sget-object v0, Lcom/vk/common/cache/SerializerCache;->b:Ljava/util/HashMap;
|
|
|
|
invoke-virtual {v0, p1}, Ljava/util/HashMap;->get(Ljava/lang/Object;)Ljava/lang/Object;
|
|
|
|
move-result-object v0
|
|
|
|
check-cast v0, Ljava/lang/ref/SoftReference;
|
|
|
|
if-eqz v0, :cond_1
|
|
|
|
invoke-virtual {v0}, Ljava/lang/ref/SoftReference;->get()Ljava/lang/Object;
|
|
|
|
move-result-object v0
|
|
|
|
if-eqz v0, :cond_1
|
|
|
|
.line 4
|
|
new-instance p1, Lcom/vk/core/util/Optional;
|
|
|
|
if-eqz v0, :cond_0
|
|
|
|
check-cast v0, Lcom/vk/core/serialize/Serializer$StreamParcelable;
|
|
|
|
invoke-direct {p1, v0}, Lcom/vk/core/util/Optional;-><init>(Ljava/lang/Object;)V
|
|
|
|
invoke-static {p1}, Lio/reactivex/Observable;->e(Ljava/lang/Object;)Lio/reactivex/Observable;
|
|
|
|
move-result-object p1
|
|
|
|
const-string p2, "Observable.just(Optional(it as T))"
|
|
|
|
invoke-static {p1, p2}, Lkotlin/jvm/internal/Intrinsics;->a(Ljava/lang/Object;Ljava/lang/String;)V
|
|
|
|
return-object p1
|
|
|
|
:cond_0
|
|
new-instance p1, Lkotlin/TypeCastException;
|
|
|
|
const-string p2, "null cannot be cast to non-null type T"
|
|
|
|
invoke-direct {p1, p2}, Lkotlin/TypeCastException;-><init>(Ljava/lang/String;)V
|
|
|
|
throw p1
|
|
|
|
.line 5
|
|
:cond_1
|
|
new-instance v0, Lcom/vk/common/cache/SerializerCache$l;
|
|
|
|
invoke-direct {v0, p1}, Lcom/vk/common/cache/SerializerCache$l;-><init>(Ljava/lang/String;)V
|
|
|
|
invoke-static {v0}, Lio/reactivex/Observable;->a(Lio/reactivex/ObservableOnSubscribe;)Lio/reactivex/Observable;
|
|
|
|
move-result-object v0
|
|
|
|
.line 6
|
|
invoke-static {}, Lio/reactivex/schedulers/Schedulers;->c()Lio/reactivex/Scheduler;
|
|
|
|
move-result-object v1
|
|
|
|
invoke-virtual {v0, v1}, Lio/reactivex/Observable;->b(Lio/reactivex/Scheduler;)Lio/reactivex/Observable;
|
|
|
|
move-result-object v0
|
|
|
|
.line 7
|
|
invoke-static {}, Lio/reactivex/schedulers/AndroidSchedulers;->a()Lio/reactivex/Scheduler;
|
|
|
|
move-result-object v1
|
|
|
|
invoke-virtual {v0, v1}, Lio/reactivex/Observable;->a(Lio/reactivex/Scheduler;)Lio/reactivex/Observable;
|
|
|
|
move-result-object v0
|
|
|
|
.line 8
|
|
new-instance v1, Lcom/vk/common/cache/SerializerCache$m;
|
|
|
|
invoke-direct {v1, p2, p1}, Lcom/vk/common/cache/SerializerCache$m;-><init>(ZLjava/lang/String;)V
|
|
|
|
invoke-virtual {v0, v1}, Lio/reactivex/Observable;->d(Lio/reactivex/functions/Consumer;)Lio/reactivex/Observable;
|
|
|
|
move-result-object p1
|
|
|
|
const-string p2, "Observable.create<Option\u2026erence(it.value as Any) }"
|
|
|
|
invoke-static {p1, p2}, Lkotlin/jvm/internal/Intrinsics;->a(Ljava/lang/Object;Ljava/lang/String;)V
|
|
|
|
return-object p1
|
|
.end method
|
|
|
|
.method public final b(Ljava/lang/String;Lcom/vk/core/serialize/Serializer$StreamParcelable;)V
|
|
.locals 1
|
|
.annotation system Ldalvik/annotation/Signature;
|
|
value = {
|
|
"<T::",
|
|
"Lcom/vk/core/serialize/Serializer$StreamParcelable;",
|
|
">(",
|
|
"Ljava/lang/String;",
|
|
"TT;)V"
|
|
}
|
|
.end annotation
|
|
|
|
.line 9
|
|
invoke-static {p2}, Ljava/util/Collections;->singletonList(Ljava/lang/Object;)Ljava/util/List;
|
|
|
|
move-result-object p2
|
|
|
|
.line 10
|
|
sget-object v0, Lcom/vk/common/cache/SerializerCache;->a:Lcom/vk/common/cache/SerializerCache$a;
|
|
|
|
invoke-virtual {v0, p1, p2}, Lcom/vk/common/cache/SerializerCache$a;->a(Ljava/lang/String;Ljava/util/List;)V
|
|
|
|
return-void
|
|
.end method
|