2022-06-10 21:38:30 +09:00

131 lines
3.7 KiB
Smali

.class public final Lcom/amplifyframework/datastore/AmplifyDisposables;
.super Ljava/lang/Object;
.source "AmplifyDisposables.java"
# static fields
.field private static final LOG:Lcom/amplifyframework/logging/Logger;
# direct methods
.method public static constructor <clinit>()V
.locals 2
.line 1
sget-object v0, Lcom/amplifyframework/core/Amplify;->Logging:Lcom/amplifyframework/logging/LoggingCategory;
const-string v1, "amplify:aws-datastore"
invoke-virtual {v0, v1}, Lcom/amplifyframework/logging/LoggingCategory;->forNamespace(Ljava/lang/String;)Lcom/amplifyframework/logging/Logger;
move-result-object v0
sput-object v0, Lcom/amplifyframework/datastore/AmplifyDisposables;->LOG:Lcom/amplifyframework/logging/Logger;
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(Lai/i0;Lcom/amplifyframework/AmplifyException;)V
.locals 0
invoke-static {p0, p1}, Lcom/amplifyframework/datastore/AmplifyDisposables;->lambda$onErrorConsumerWrapperFor$0(Lai/i0;Lcom/amplifyframework/AmplifyException;)V
return-void
.end method
.method public static fromCancelable(Lcom/amplifyframework/core/async/Cancelable;)Lio/reactivex/rxjava3/disposables/c;
.locals 1
.param p0 # Lcom/amplifyframework/core/async/Cancelable;
.annotation build Landroidx/annotation/Nullable;
.end annotation
.end param
.annotation build Landroidx/annotation/NonNull;
.end annotation
if-nez p0, :cond_0
.line 1
invoke-static {}, Lio/reactivex/rxjava3/disposables/c;->k()Lio/reactivex/rxjava3/disposables/c;
move-result-object p0
return-object p0
.line 2
:cond_0
new-instance v0, Lcom/amplifyframework/datastore/AmplifyDisposables$1;
invoke-direct {v0, p0}, Lcom/amplifyframework/datastore/AmplifyDisposables$1;-><init>(Lcom/amplifyframework/core/async/Cancelable;)V
return-object v0
.end method
.method private static synthetic lambda$onErrorConsumerWrapperFor$0(Lai/i0;Lcom/amplifyframework/AmplifyException;)V
.locals 1
.line 1
invoke-interface {p0}, Lai/i0;->isDisposed()Z
move-result v0
if-eqz v0, :cond_0
.line 2
sget-object p0, Lcom/amplifyframework/datastore/AmplifyDisposables;->LOG:Lcom/amplifyframework/logging/Logger;
const-string v0, "Attempted to invoke an emitter that is already disposed"
invoke-interface {p0, v0, p1}, Lcom/amplifyframework/logging/Logger;->warn(Ljava/lang/String;Ljava/lang/Throwable;)V
goto :goto_0
.line 3
:cond_0
invoke-interface {p0, p1}, Lai/i;->onError(Ljava/lang/Throwable;)V
:goto_0
return-void
.end method
.method public static onErrorConsumerWrapperFor(Lai/i0;)Lcom/amplifyframework/core/Consumer;
.locals 1
.param p0 # Lai/i0;
.annotation build Landroidx/annotation/NonNull;
.end annotation
.end param
.annotation build Landroidx/annotation/NonNull;
.end annotation
.annotation system Ldalvik/annotation/Signature;
value = {
"<T::",
"Lcom/amplifyframework/core/model/Model;",
"E:",
"Lcom/amplifyframework/AmplifyException;",
">(",
"Lai/i0<",
"Lcom/amplifyframework/api/graphql/GraphQLResponse<",
"Lcom/amplifyframework/datastore/appsync/ModelWithMetadata<",
"TT;>;>;>;)",
"Lcom/amplifyframework/core/Consumer<",
"TE;>;"
}
.end annotation
.line 1
new-instance v0, Lcom/amplifyframework/datastore/i0;
invoke-direct {v0, p0}, Lcom/amplifyframework/datastore/i0;-><init>(Lai/i0;)V
return-object v0
.end method