223 lines
7.1 KiB
Smali
223 lines
7.1 KiB
Smali
.class public abstract Lio/reactivex/Completable;
|
|
.super Ljava/lang/Object;
|
|
.source "Completable.java"
|
|
|
|
# interfaces
|
|
.implements Lio/reactivex/CompletableSource;
|
|
|
|
|
|
# direct methods
|
|
.method public constructor <init>()V
|
|
.locals 0
|
|
|
|
.line 105
|
|
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
|
|
|
|
return-void
|
|
.end method
|
|
|
|
.method public static a(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)Lio/reactivex/Completable;
|
|
.locals 1
|
|
|
|
const-string v0, "unit is null"
|
|
|
|
.line 895
|
|
invoke-static {p2, v0}, Lio/reactivex/internal/functions/ObjectHelper;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
|
|
|
|
const-string v0, "scheduler is null"
|
|
|
|
.line 896
|
|
invoke-static {p3, v0}, Lio/reactivex/internal/functions/ObjectHelper;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
|
|
|
|
.line 897
|
|
new-instance v0, Lio/reactivex/internal/operators/completable/CompletableTimer;
|
|
|
|
invoke-direct {v0, p0, p1, p2, p3}, Lio/reactivex/internal/operators/completable/CompletableTimer;-><init>(JLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)V
|
|
|
|
invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->a(Lio/reactivex/Completable;)Lio/reactivex/Completable;
|
|
|
|
move-result-object p0
|
|
|
|
return-object p0
|
|
.end method
|
|
|
|
.method public static a(Lio/reactivex/CompletableOnSubscribe;)Lio/reactivex/Completable;
|
|
.locals 1
|
|
|
|
const-string v0, "source is null"
|
|
|
|
.line 302
|
|
invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
|
|
|
|
.line 303
|
|
new-instance v0, Lio/reactivex/internal/operators/completable/CompletableCreate;
|
|
|
|
invoke-direct {v0, p0}, Lio/reactivex/internal/operators/completable/CompletableCreate;-><init>(Lio/reactivex/CompletableOnSubscribe;)V
|
|
|
|
invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->a(Lio/reactivex/Completable;)Lio/reactivex/Completable;
|
|
|
|
move-result-object p0
|
|
|
|
return-object p0
|
|
.end method
|
|
|
|
.method private static a(Ljava/lang/Throwable;)Ljava/lang/NullPointerException;
|
|
.locals 2
|
|
|
|
.line 906
|
|
new-instance v0, Ljava/lang/NullPointerException;
|
|
|
|
const-string v1, "Actually not, but can\'t pass out an exception otherwise..."
|
|
|
|
invoke-direct {v0, v1}, Ljava/lang/NullPointerException;-><init>(Ljava/lang/String;)V
|
|
|
|
.line 907
|
|
invoke-virtual {v0, p0}, Ljava/lang/NullPointerException;->initCause(Ljava/lang/Throwable;)Ljava/lang/Throwable;
|
|
|
|
return-object v0
|
|
.end method
|
|
|
|
|
|
# virtual methods
|
|
.method public final a(Lio/reactivex/Scheduler;)Lio/reactivex/Completable;
|
|
.locals 1
|
|
|
|
const-string v0, "scheduler is null"
|
|
|
|
.line 1759
|
|
invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
|
|
|
|
.line 1760
|
|
new-instance v0, Lio/reactivex/internal/operators/completable/CompletableObserveOn;
|
|
|
|
invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/completable/CompletableObserveOn;-><init>(Lio/reactivex/CompletableSource;Lio/reactivex/Scheduler;)V
|
|
|
|
invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->a(Lio/reactivex/Completable;)Lio/reactivex/Completable;
|
|
|
|
move-result-object p1
|
|
|
|
return-object p1
|
|
.end method
|
|
|
|
.method public final a(Lio/reactivex/functions/Action;)Lio/reactivex/disposables/Disposable;
|
|
.locals 1
|
|
|
|
const-string v0, "onComplete is null"
|
|
|
|
.line 2267
|
|
invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
|
|
|
|
.line 2269
|
|
new-instance v0, Lio/reactivex/internal/observers/CallbackCompletableObserver;
|
|
|
|
invoke-direct {v0, p1}, Lio/reactivex/internal/observers/CallbackCompletableObserver;-><init>(Lio/reactivex/functions/Action;)V
|
|
|
|
.line 2270
|
|
invoke-virtual {p0, v0}, Lio/reactivex/Completable;->a(Lio/reactivex/CompletableObserver;)V
|
|
|
|
return-object v0
|
|
.end method
|
|
|
|
.method public final a(Lio/reactivex/functions/Action;Lio/reactivex/functions/Consumer;)Lio/reactivex/disposables/Disposable;
|
|
.locals 1
|
|
.annotation system Ldalvik/annotation/Signature;
|
|
value = {
|
|
"(",
|
|
"Lio/reactivex/functions/Action;",
|
|
"Lio/reactivex/functions/Consumer<",
|
|
"-",
|
|
"Ljava/lang/Throwable;",
|
|
">;)",
|
|
"Lio/reactivex/disposables/Disposable;"
|
|
}
|
|
.end annotation
|
|
|
|
const-string v0, "onError is null"
|
|
|
|
.line 2240
|
|
invoke-static {p2, v0}, Lio/reactivex/internal/functions/ObjectHelper;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
|
|
|
|
const-string v0, "onComplete is null"
|
|
|
|
.line 2241
|
|
invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
|
|
|
|
.line 2243
|
|
new-instance v0, Lio/reactivex/internal/observers/CallbackCompletableObserver;
|
|
|
|
invoke-direct {v0, p2, p1}, Lio/reactivex/internal/observers/CallbackCompletableObserver;-><init>(Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Action;)V
|
|
|
|
.line 2244
|
|
invoke-virtual {p0, v0}, Lio/reactivex/Completable;->a(Lio/reactivex/CompletableObserver;)V
|
|
|
|
return-object v0
|
|
.end method
|
|
|
|
.method public final a(Lio/reactivex/CompletableObserver;)V
|
|
.locals 1
|
|
|
|
const-string v0, "s is null"
|
|
|
|
.line 2166
|
|
invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
|
|
|
|
.line 2169
|
|
:try_start_0
|
|
invoke-static {p0, p1}, Lio/reactivex/plugins/RxJavaPlugins;->a(Lio/reactivex/Completable;Lio/reactivex/CompletableObserver;)Lio/reactivex/CompletableObserver;
|
|
|
|
move-result-object p1
|
|
|
|
.line 2171
|
|
invoke-virtual {p0, p1}, Lio/reactivex/Completable;->b(Lio/reactivex/CompletableObserver;)V
|
|
:try_end_0
|
|
.catch Ljava/lang/NullPointerException; {:try_start_0 .. :try_end_0} :catch_1
|
|
.catch Ljava/lang/Throwable; {:try_start_0 .. :try_end_0} :catch_0
|
|
|
|
return-void
|
|
|
|
:catch_0
|
|
move-exception p1
|
|
|
|
.line 2175
|
|
invoke-static {p1}, Lio/reactivex/exceptions/Exceptions;->b(Ljava/lang/Throwable;)V
|
|
|
|
.line 2176
|
|
invoke-static {p1}, Lio/reactivex/plugins/RxJavaPlugins;->a(Ljava/lang/Throwable;)V
|
|
|
|
.line 2177
|
|
invoke-static {p1}, Lio/reactivex/Completable;->a(Ljava/lang/Throwable;)Ljava/lang/NullPointerException;
|
|
|
|
move-result-object p1
|
|
|
|
throw p1
|
|
|
|
:catch_1
|
|
move-exception p1
|
|
|
|
.line 2173
|
|
throw p1
|
|
.end method
|
|
|
|
.method public final b(Lio/reactivex/Scheduler;)Lio/reactivex/Completable;
|
|
.locals 1
|
|
|
|
const-string v0, "scheduler is null"
|
|
|
|
.line 2290
|
|
invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->a(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
|
|
|
|
.line 2292
|
|
new-instance v0, Lio/reactivex/internal/operators/completable/CompletableSubscribeOn;
|
|
|
|
invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/completable/CompletableSubscribeOn;-><init>(Lio/reactivex/CompletableSource;Lio/reactivex/Scheduler;)V
|
|
|
|
invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->a(Lio/reactivex/Completable;)Lio/reactivex/Completable;
|
|
|
|
move-result-object p1
|
|
|
|
return-object p1
|
|
.end method
|
|
|
|
.method protected abstract b(Lio/reactivex/CompletableObserver;)V
|
|
.end method
|