RxJavaPlugins.smali
.class public final Lio/reactivex/plugins/RxJavaPlugins;
.super Ljava/lang/Object;
.source "RxJavaPlugins.java"
# static fields
.field static volatile errorHandler:Lio/reactivex/functions/Consumer;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/functions/Consumer<",
"-",
"Ljava/lang/Throwable;",
">;"
}
.end annotation
.end field
.field static volatile failNonBlockingScheduler:Z
.field static volatile lockdown:Z
.field static volatile onBeforeBlocking:Lio/reactivex/functions/BooleanSupplier;
.field static volatile onCompletableAssembly:Lio/reactivex/functions/Function;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/functions/Function<",
"-",
"Lio/reactivex/Completable;",
"+",
"Lio/reactivex/Completable;",
">;"
}
.end annotation
.end field
.field static volatile onCompletableSubscribe:Lio/reactivex/functions/BiFunction;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/functions/BiFunction<",
"-",
"Lio/reactivex/Completable;",
"-",
"Lio/reactivex/CompletableObserver;",
"+",
"Lio/reactivex/CompletableObserver;",
">;"
}
.end annotation
.end field
.field static volatile onComputationHandler:Lio/reactivex/functions/Function;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/functions/Function<",
"-",
"Lio/reactivex/Scheduler;",
"+",
"Lio/reactivex/Scheduler;",
">;"
}
.end annotation
.end field
.field static volatile onConnectableFlowableAssembly:Lio/reactivex/functions/Function;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/functions/Function<",
"-",
"Lio/reactivex/flowables/ConnectableFlowable;",
"+",
"Lio/reactivex/flowables/ConnectableFlowable;",
">;"
}
.end annotation
.end field
.field static volatile onConnectableObservableAssembly:Lio/reactivex/functions/Function;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/functions/Function<",
"-",
"Lio/reactivex/observables/ConnectableObservable;",
"+",
"Lio/reactivex/observables/ConnectableObservable;",
">;"
}
.end annotation
.end field
.field static volatile onFlowableAssembly:Lio/reactivex/functions/Function;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/functions/Function<",
"-",
"Lio/reactivex/Flowable;",
"+",
"Lio/reactivex/Flowable;",
">;"
}
.end annotation
.end field
.field static volatile onFlowableSubscribe:Lio/reactivex/functions/BiFunction;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/functions/BiFunction<",
"-",
"Lio/reactivex/Flowable;",
"-",
"Lorg/reactivestreams/Subscriber;",
"+",
"Lorg/reactivestreams/Subscriber;",
">;"
}
.end annotation
.end field
.field static volatile onInitComputationHandler:Lio/reactivex/functions/Function;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/functions/Function<",
"-",
"Ljava/util/concurrent/Callable<",
"Lio/reactivex/Scheduler;",
">;+",
"Lio/reactivex/Scheduler;",
">;"
}
.end annotation
.end field
.field static volatile onInitIoHandler:Lio/reactivex/functions/Function;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/functions/Function<",
"-",
"Ljava/util/concurrent/Callable<",
"Lio/reactivex/Scheduler;",
">;+",
"Lio/reactivex/Scheduler;",
">;"
}
.end annotation
.end field
.field static volatile onInitNewThreadHandler:Lio/reactivex/functions/Function;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/functions/Function<",
"-",
"Ljava/util/concurrent/Callable<",
"Lio/reactivex/Scheduler;",
">;+",
"Lio/reactivex/Scheduler;",
">;"
}
.end annotation
.end field
.field static volatile onInitSingleHandler:Lio/reactivex/functions/Function;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/functions/Function<",
"-",
"Ljava/util/concurrent/Callable<",
"Lio/reactivex/Scheduler;",
">;+",
"Lio/reactivex/Scheduler;",
">;"
}
.end annotation
.end field
.field static volatile onIoHandler:Lio/reactivex/functions/Function;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/functions/Function<",
"-",
"Lio/reactivex/Scheduler;",
"+",
"Lio/reactivex/Scheduler;",
">;"
}
.end annotation
.end field
.field static volatile onMaybeAssembly:Lio/reactivex/functions/Function;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/functions/Function<",
"-",
"Lio/reactivex/Maybe;",
"+",
"Lio/reactivex/Maybe;",
">;"
}
.end annotation
.end field
.field static volatile onMaybeSubscribe:Lio/reactivex/functions/BiFunction;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/functions/BiFunction<",
"-",
"Lio/reactivex/Maybe;",
"-",
"Lio/reactivex/MaybeObserver;",
"+",
"Lio/reactivex/MaybeObserver;",
">;"
}
.end annotation
.end field
.field static volatile onNewThreadHandler:Lio/reactivex/functions/Function;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/functions/Function<",
"-",
"Lio/reactivex/Scheduler;",
"+",
"Lio/reactivex/Scheduler;",
">;"
}
.end annotation
.end field
.field static volatile onObservableAssembly:Lio/reactivex/functions/Function;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/functions/Function<",
"-",
"Lio/reactivex/Observable;",
"+",
"Lio/reactivex/Observable;",
">;"
}
.end annotation
.end field
.field static volatile onObservableSubscribe:Lio/reactivex/functions/BiFunction;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/functions/BiFunction<",
"-",
"Lio/reactivex/Observable;",
"-",
"Lio/reactivex/Observer;",
"+",
"Lio/reactivex/Observer;",
">;"
}
.end annotation
.end field
.field static volatile onParallelAssembly:Lio/reactivex/functions/Function;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/functions/Function<",
"-",
"Lio/reactivex/parallel/ParallelFlowable;",
"+",
"Lio/reactivex/parallel/ParallelFlowable;",
">;"
}
.end annotation
.end field
.field static volatile onScheduleHandler:Lio/reactivex/functions/Function;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/functions/Function<",
"-",
"Ljava/lang/Runnable;",
"+",
"Ljava/lang/Runnable;",
">;"
}
.end annotation
.end field
.field static volatile onSingleAssembly:Lio/reactivex/functions/Function;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/functions/Function<",
"-",
"Lio/reactivex/Single;",
"+",
"Lio/reactivex/Single;",
">;"
}
.end annotation
.end field
.field static volatile onSingleHandler:Lio/reactivex/functions/Function;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/functions/Function<",
"-",
"Lio/reactivex/Scheduler;",
"+",
"Lio/reactivex/Scheduler;",
">;"
}
.end annotation
.end field
.field static volatile onSingleSubscribe:Lio/reactivex/functions/BiFunction;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/functions/BiFunction<",
"-",
"Lio/reactivex/Single;",
"-",
"Lio/reactivex/SingleObserver;",
"+",
"Lio/reactivex/SingleObserver;",
">;"
}
.end annotation
.end field
# direct methods
.method static constructor <clinit>()V
.registers 1
return-void
.end method
.method private constructor <init>()V
.registers 3
.line 1307
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
.line 1308
new-instance v0, Ljava/lang/IllegalStateException;
const-string v1, "No instances!"
invoke-direct {v0, v1}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
throw v0
.end method
.method static apply(Lio/reactivex/functions/BiFunction;Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
.registers 5
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
"U:",
"Ljava/lang/Object;",
"R:",
"Ljava/lang/Object;",
">(",
"Lio/reactivex/functions/BiFunction<",
"TT;TU;TR;>;TT;TU;)TR;"
}
.end annotation
.line 1271
.local p0, "f":Lio/reactivex/functions/BiFunction;, "Lio/reactivex/functions/BiFunction<TT;TU;TR;>;"
.local p1, "t":Ljava/lang/Object;, "TT;"
.local p2, "u":Ljava/lang/Object;, "TU;"
:try_start_0
invoke-interface {p0, p1, p2}, Lio/reactivex/functions/BiFunction;->apply(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v0
:try_end_4
.catchall {:try_start_0 .. :try_end_4} :catchall_5
return-object v0
.line 1272
:catchall_5
move-exception v0
.line 1273
.local v0, "ex":Ljava/lang/Throwable;
invoke-static {v0}, Lio/reactivex/internal/util/ExceptionHelper;->wrapOrThrow(Ljava/lang/Throwable;)Ljava/lang/RuntimeException;
move-result-object v1
throw v1
.end method
.method static apply(Lio/reactivex/functions/Function;Ljava/lang/Object;)Ljava/lang/Object;
.registers 4
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
"R:",
"Ljava/lang/Object;",
">(",
"Lio/reactivex/functions/Function<",
"TT;TR;>;TT;)TR;"
}
.end annotation
.line 1251
.local p0, "f":Lio/reactivex/functions/Function;, "Lio/reactivex/functions/Function<TT;TR;>;"
.local p1, "t":Ljava/lang/Object;, "TT;"
:try_start_0
invoke-interface {p0, p1}, Lio/reactivex/functions/Function;->apply(Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v0
:try_end_4
.catchall {:try_start_0 .. :try_end_4} :catchall_5
return-object v0
.line 1252
:catchall_5
move-exception v0
.line 1253
.local v0, "ex":Ljava/lang/Throwable;
invoke-static {v0}, Lio/reactivex/internal/util/ExceptionHelper;->wrapOrThrow(Ljava/lang/Throwable;)Ljava/lang/RuntimeException;
move-result-object v1
throw v1
.end method
.method static applyRequireNonNull(Lio/reactivex/functions/Function;Ljava/util/concurrent/Callable;)Lio/reactivex/Scheduler;
.registers 4
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/functions/Function<",
"-",
"Ljava/util/concurrent/Callable<",
"Lio/reactivex/Scheduler;",
">;+",
"Lio/reactivex/Scheduler;",
">;",
"Ljava/util/concurrent/Callable<",
"Lio/reactivex/Scheduler;",
">;)",
"Lio/reactivex/Scheduler;"
}
.end annotation
.line 1303
.local p0, "f":Lio/reactivex/functions/Function;, "Lio/reactivex/functions/Function<-Ljava/util/concurrent/Callable<Lio/reactivex/Scheduler;>;+Lio/reactivex/Scheduler;>;"
.local p1, "s":Ljava/util/concurrent/Callable;, "Ljava/util/concurrent/Callable<Lio/reactivex/Scheduler;>;"
invoke-static {p0, p1}, Lio/reactivex/plugins/RxJavaPlugins;->apply(Lio/reactivex/functions/Function;Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v0
const-string v1, "Scheduler Callable result can\'t be null"
invoke-static {v0, v1}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
move-result-object v0
check-cast v0, Lio/reactivex/Scheduler;
return-object v0
.end method
.method static callRequireNonNull(Ljava/util/concurrent/Callable;)Lio/reactivex/Scheduler;
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Ljava/util/concurrent/Callable<",
"Lio/reactivex/Scheduler;",
">;)",
"Lio/reactivex/Scheduler;"
}
.end annotation
.line 1287
.local p0, "s":Ljava/util/concurrent/Callable;, "Ljava/util/concurrent/Callable<Lio/reactivex/Scheduler;>;"
:try_start_0
invoke-interface {p0}, Ljava/util/concurrent/Callable;->call()Ljava/lang/Object;
move-result-object v0
const-string v1, "Scheduler Callable result can\'t be null"
invoke-static {v0, v1}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
move-result-object v0
check-cast v0, Lio/reactivex/Scheduler;
:try_end_c
.catchall {:try_start_0 .. :try_end_c} :catchall_d
return-object v0
.line 1288
:catchall_d
move-exception v0
.line 1289
.local v0, "ex":Ljava/lang/Throwable;
invoke-static {v0}, Lio/reactivex/internal/util/ExceptionHelper;->wrapOrThrow(Ljava/lang/Throwable;)Ljava/lang/RuntimeException;
move-result-object v1
throw v1
.end method
.method public static createComputationScheduler(Ljava/util/concurrent/ThreadFactory;)Lio/reactivex/Scheduler;
.registers 3
.param p0, "threadFactory" # Ljava/util/concurrent/ThreadFactory;
.line 1194
new-instance v0, Lio/reactivex/internal/schedulers/ComputationScheduler;
const-string v1, "threadFactory is null"
invoke-static {p0, v1}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
move-result-object v1
check-cast v1, Ljava/util/concurrent/ThreadFactory;
invoke-direct {v0, v1}, Lio/reactivex/internal/schedulers/ComputationScheduler;-><init>(Ljava/util/concurrent/ThreadFactory;)V
return-object v0
.end method
.method public static createIoScheduler(Ljava/util/concurrent/ThreadFactory;)Lio/reactivex/Scheduler;
.registers 3
.param p0, "threadFactory" # Ljava/util/concurrent/ThreadFactory;
.line 1208
new-instance v0, Lio/reactivex/internal/schedulers/IoScheduler;
const-string v1, "threadFactory is null"
invoke-static {p0, v1}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
move-result-object v1
check-cast v1, Ljava/util/concurrent/ThreadFactory;
invoke-direct {v0, v1}, Lio/reactivex/internal/schedulers/IoScheduler;-><init>(Ljava/util/concurrent/ThreadFactory;)V
return-object v0
.end method
.method public static createNewThreadScheduler(Ljava/util/concurrent/ThreadFactory;)Lio/reactivex/Scheduler;
.registers 3
.param p0, "threadFactory" # Ljava/util/concurrent/ThreadFactory;
.line 1222
new-instance v0, Lio/reactivex/internal/schedulers/NewThreadScheduler;
const-string v1, "threadFactory is null"
invoke-static {p0, v1}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
move-result-object v1
check-cast v1, Ljava/util/concurrent/ThreadFactory;
invoke-direct {v0, v1}, Lio/reactivex/internal/schedulers/NewThreadScheduler;-><init>(Ljava/util/concurrent/ThreadFactory;)V
return-object v0
.end method
.method public static createSingleScheduler(Ljava/util/concurrent/ThreadFactory;)Lio/reactivex/Scheduler;
.registers 3
.param p0, "threadFactory" # Ljava/util/concurrent/ThreadFactory;
.line 1236
new-instance v0, Lio/reactivex/internal/schedulers/SingleScheduler;
const-string v1, "threadFactory is null"
invoke-static {p0, v1}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
move-result-object v1
check-cast v1, Ljava/util/concurrent/ThreadFactory;
invoke-direct {v0, v1}, Lio/reactivex/internal/schedulers/SingleScheduler;-><init>(Ljava/util/concurrent/ThreadFactory;)V
return-object v0
.end method
.method public static getComputationSchedulerHandler()Lio/reactivex/functions/Function;
.registers 1
.annotation system Ldalvik/annotation/Signature;
value = {
"()",
"Lio/reactivex/functions/Function<",
"-",
"Lio/reactivex/Scheduler;",
"+",
"Lio/reactivex/Scheduler;",
">;"
}
.end annotation
.line 176
sget-object v0, Lio/reactivex/plugins/RxJavaPlugins;->onComputationHandler:Lio/reactivex/functions/Function;
return-object v0
.end method
.method public static getErrorHandler()Lio/reactivex/functions/Consumer;
.registers 1
.annotation system Ldalvik/annotation/Signature;
value = {
"()",
"Lio/reactivex/functions/Consumer<",
"-",
"Ljava/lang/Throwable;",
">;"
}
.end annotation
.line 185
sget-object v0, Lio/reactivex/plugins/RxJavaPlugins;->errorHandler:Lio/reactivex/functions/Consumer;
return-object v0
.end method
.method public static getInitComputationSchedulerHandler()Lio/reactivex/functions/Function;
.registers 1
.annotation system Ldalvik/annotation/Signature;
value = {
"()",
"Lio/reactivex/functions/Function<",
"-",
"Ljava/util/concurrent/Callable<",
"Lio/reactivex/Scheduler;",
">;+",
"Lio/reactivex/Scheduler;",
">;"
}
.end annotation
.line 194
sget-object v0, Lio/reactivex/plugins/RxJavaPlugins;->onInitComputationHandler:Lio/reactivex/functions/Function;
return-object v0
.end method
.method public static getInitIoSchedulerHandler()Lio/reactivex/functions/Function;
.registers 1
.annotation system Ldalvik/annotation/Signature;
value = {
"()",
"Lio/reactivex/functions/Function<",
"-",
"Ljava/util/concurrent/Callable<",
"Lio/reactivex/Scheduler;",
">;+",
"Lio/reactivex/Scheduler;",
">;"
}
.end annotation
.line 203
sget-object v0, Lio/reactivex/plugins/RxJavaPlugins;->onInitIoHandler:Lio/reactivex/functions/Function;
return-object v0
.end method
.method public static getInitNewThreadSchedulerHandler()Lio/reactivex/functions/Function;
.registers 1
.annotation system Ldalvik/annotation/Signature;
value = {
"()",
"Lio/reactivex/functions/Function<",
"-",
"Ljava/util/concurrent/Callable<",
"Lio/reactivex/Scheduler;",
">;+",
"Lio/reactivex/Scheduler;",
">;"
}
.end annotation
.line 212
sget-object v0, Lio/reactivex/plugins/RxJavaPlugins;->onInitNewThreadHandler:Lio/reactivex/functions/Function;
return-object v0
.end method
.method public static getInitSingleSchedulerHandler()Lio/reactivex/functions/Function;
.registers 1
.annotation system Ldalvik/annotation/Signature;
value = {
"()",
"Lio/reactivex/functions/Function<",
"-",
"Ljava/util/concurrent/Callable<",
"Lio/reactivex/Scheduler;",
">;+",
"Lio/reactivex/Scheduler;",
">;"
}
.end annotation
.line 221
sget-object v0, Lio/reactivex/plugins/RxJavaPlugins;->onInitSingleHandler:Lio/reactivex/functions/Function;
return-object v0
.end method
.method public static getIoSchedulerHandler()Lio/reactivex/functions/Function;
.registers 1
.annotation system Ldalvik/annotation/Signature;
value = {
"()",
"Lio/reactivex/functions/Function<",
"-",
"Lio/reactivex/Scheduler;",
"+",
"Lio/reactivex/Scheduler;",
">;"
}
.end annotation
.line 230
sget-object v0, Lio/reactivex/plugins/RxJavaPlugins;->onIoHandler:Lio/reactivex/functions/Function;
return-object v0
.end method
.method public static getNewThreadSchedulerHandler()Lio/reactivex/functions/Function;
.registers 1
.annotation system Ldalvik/annotation/Signature;
value = {
"()",
"Lio/reactivex/functions/Function<",
"-",
"Lio/reactivex/Scheduler;",
"+",
"Lio/reactivex/Scheduler;",
">;"
}
.end annotation
.line 239
sget-object v0, Lio/reactivex/plugins/RxJavaPlugins;->onNewThreadHandler:Lio/reactivex/functions/Function;
return-object v0
.end method
.method public static getOnBeforeBlocking()Lio/reactivex/functions/BooleanSupplier;
.registers 1
.line 1180
sget-object v0, Lio/reactivex/plugins/RxJavaPlugins;->onBeforeBlocking:Lio/reactivex/functions/BooleanSupplier;
return-object v0
.end method
.method public static getOnCompletableAssembly()Lio/reactivex/functions/Function;
.registers 1
.annotation system Ldalvik/annotation/Signature;
value = {
"()",
"Lio/reactivex/functions/Function<",
"-",
"Lio/reactivex/Completable;",
"+",
"Lio/reactivex/Completable;",
">;"
}
.end annotation
.line 636
sget-object v0, Lio/reactivex/plugins/RxJavaPlugins;->onCompletableAssembly:Lio/reactivex/functions/Function;
return-object v0
.end method
.method public static getOnCompletableSubscribe()Lio/reactivex/functions/BiFunction;
.registers 1
.annotation system Ldalvik/annotation/Signature;
value = {
"()",
"Lio/reactivex/functions/BiFunction<",
"-",
"Lio/reactivex/Completable;",
"-",
"Lio/reactivex/CompletableObserver;",
"+",
"Lio/reactivex/CompletableObserver;",
">;"
}
.end annotation
.line 645
sget-object v0, Lio/reactivex/plugins/RxJavaPlugins;->onCompletableSubscribe:Lio/reactivex/functions/BiFunction;
return-object v0
.end method
.method public static getOnConnectableFlowableAssembly()Lio/reactivex/functions/Function;
.registers 1
.annotation system Ldalvik/annotation/Signature;
value = {
"()",
"Lio/reactivex/functions/Function<",
"-",
"Lio/reactivex/flowables/ConnectableFlowable;",
"+",
"Lio/reactivex/flowables/ConnectableFlowable;",
">;"
}
.end annotation
.line 665
sget-object v0, Lio/reactivex/plugins/RxJavaPlugins;->onConnectableFlowableAssembly:Lio/reactivex/functions/Function;
return-object v0
.end method
.method public static getOnConnectableObservableAssembly()Lio/reactivex/functions/Function;
.registers 1
.annotation system Ldalvik/annotation/Signature;
value = {
"()",
"Lio/reactivex/functions/Function<",
"-",
"Lio/reactivex/observables/ConnectableObservable;",
"+",
"Lio/reactivex/observables/ConnectableObservable;",
">;"
}
.end annotation
.line 735
sget-object v0, Lio/reactivex/plugins/RxJavaPlugins;->onConnectableObservableAssembly:Lio/reactivex/functions/Function;
return-object v0
.end method
.method public static getOnFlowableAssembly()Lio/reactivex/functions/Function;
.registers 1
.annotation system Ldalvik/annotation/Signature;
value = {
"()",
"Lio/reactivex/functions/Function<",
"-",
"Lio/reactivex/Flowable;",
"+",
"Lio/reactivex/Flowable;",
">;"
}
.end annotation
.line 655
sget-object v0, Lio/reactivex/plugins/RxJavaPlugins;->onFlowableAssembly:Lio/reactivex/functions/Function;
return-object v0
.end method
.method public static getOnFlowableSubscribe()Lio/reactivex/functions/BiFunction;
.registers 1
.annotation system Ldalvik/annotation/Signature;
value = {
"()",
"Lio/reactivex/functions/BiFunction<",
"-",
"Lio/reactivex/Flowable;",
"-",
"Lorg/reactivestreams/Subscriber;",
"+",
"Lorg/reactivestreams/Subscriber;",
">;"
}
.end annotation
.line 675
sget-object v0, Lio/reactivex/plugins/RxJavaPlugins;->onFlowableSubscribe:Lio/reactivex/functions/BiFunction;
return-object v0
.end method
.method public static getOnMaybeAssembly()Lio/reactivex/functions/Function;
.registers 1
.annotation system Ldalvik/annotation/Signature;
value = {
"()",
"Lio/reactivex/functions/Function<",
"-",
"Lio/reactivex/Maybe;",
"+",
"Lio/reactivex/Maybe;",
">;"
}
.end annotation
.line 695
sget-object v0, Lio/reactivex/plugins/RxJavaPlugins;->onMaybeAssembly:Lio/reactivex/functions/Function;
return-object v0
.end method
.method public static getOnMaybeSubscribe()Lio/reactivex/functions/BiFunction;
.registers 1
.annotation system Ldalvik/annotation/Signature;
value = {
"()",
"Lio/reactivex/functions/BiFunction<",
"-",
"Lio/reactivex/Maybe;",
"-",
"Lio/reactivex/MaybeObserver;",
"+",
"Lio/reactivex/MaybeObserver;",
">;"
}
.end annotation
.line 685
sget-object v0, Lio/reactivex/plugins/RxJavaPlugins;->onMaybeSubscribe:Lio/reactivex/functions/BiFunction;
return-object v0
.end method
.method public static getOnObservableAssembly()Lio/reactivex/functions/Function;
.registers 1
.annotation system Ldalvik/annotation/Signature;
value = {
"()",
"Lio/reactivex/functions/Function<",
"-",
"Lio/reactivex/Observable;",
"+",
"Lio/reactivex/Observable;",
">;"
}
.end annotation
.line 725
sget-object v0, Lio/reactivex/plugins/RxJavaPlugins;->onObservableAssembly:Lio/reactivex/functions/Function;
return-object v0
.end method
.method public static getOnObservableSubscribe()Lio/reactivex/functions/BiFunction;
.registers 1
.annotation system Ldalvik/annotation/Signature;
value = {
"()",
"Lio/reactivex/functions/BiFunction<",
"-",
"Lio/reactivex/Observable;",
"-",
"Lio/reactivex/Observer;",
"+",
"Lio/reactivex/Observer;",
">;"
}
.end annotation
.line 745
sget-object v0, Lio/reactivex/plugins/RxJavaPlugins;->onObservableSubscribe:Lio/reactivex/functions/BiFunction;
return-object v0
.end method
.method public static getOnParallelAssembly()Lio/reactivex/functions/Function;
.registers 1
.annotation system Ldalvik/annotation/Signature;
value = {
"()",
"Lio/reactivex/functions/Function<",
"-",
"Lio/reactivex/parallel/ParallelFlowable;",
"+",
"Lio/reactivex/parallel/ParallelFlowable;",
">;"
}
.end annotation
.line 1110
sget-object v0, Lio/reactivex/plugins/RxJavaPlugins;->onParallelAssembly:Lio/reactivex/functions/Function;
return-object v0
.end method
.method public static getOnSingleAssembly()Lio/reactivex/functions/Function;
.registers 1
.annotation system Ldalvik/annotation/Signature;
value = {
"()",
"Lio/reactivex/functions/Function<",
"-",
"Lio/reactivex/Single;",
"+",
"Lio/reactivex/Single;",
">;"
}
.end annotation
.line 705
sget-object v0, Lio/reactivex/plugins/RxJavaPlugins;->onSingleAssembly:Lio/reactivex/functions/Function;
return-object v0
.end method
.method public static getOnSingleSubscribe()Lio/reactivex/functions/BiFunction;
.registers 1
.annotation system Ldalvik/annotation/Signature;
value = {
"()",
"Lio/reactivex/functions/BiFunction<",
"-",
"Lio/reactivex/Single;",
"-",
"Lio/reactivex/SingleObserver;",
"+",
"Lio/reactivex/SingleObserver;",
">;"
}
.end annotation
.line 715
sget-object v0, Lio/reactivex/plugins/RxJavaPlugins;->onSingleSubscribe:Lio/reactivex/functions/BiFunction;
return-object v0
.end method
.method public static getScheduleHandler()Lio/reactivex/functions/Function;
.registers 1
.annotation system Ldalvik/annotation/Signature;
value = {
"()",
"Lio/reactivex/functions/Function<",
"-",
"Ljava/lang/Runnable;",
"+",
"Ljava/lang/Runnable;",
">;"
}
.end annotation
.line 248
sget-object v0, Lio/reactivex/plugins/RxJavaPlugins;->onScheduleHandler:Lio/reactivex/functions/Function;
return-object v0
.end method
.method public static getSingleSchedulerHandler()Lio/reactivex/functions/Function;
.registers 1
.annotation system Ldalvik/annotation/Signature;
value = {
"()",
"Lio/reactivex/functions/Function<",
"-",
"Lio/reactivex/Scheduler;",
"+",
"Lio/reactivex/Scheduler;",
">;"
}
.end annotation
.line 257
sget-object v0, Lio/reactivex/plugins/RxJavaPlugins;->onSingleHandler:Lio/reactivex/functions/Function;
return-object v0
.end method
.method public static initComputationScheduler(Ljava/util/concurrent/Callable;)Lio/reactivex/Scheduler;
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Ljava/util/concurrent/Callable<",
"Lio/reactivex/Scheduler;",
">;)",
"Lio/reactivex/Scheduler;"
}
.end annotation
.line 268
.local p0, "defaultScheduler":Ljava/util/concurrent/Callable;, "Ljava/util/concurrent/Callable<Lio/reactivex/Scheduler;>;"
const-string v0, "Scheduler Callable can\'t be null"
invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
.line 269
sget-object v0, Lio/reactivex/plugins/RxJavaPlugins;->onInitComputationHandler:Lio/reactivex/functions/Function;
.line 270
.local v0, "f":Lio/reactivex/functions/Function;, "Lio/reactivex/functions/Function<-Ljava/util/concurrent/Callable<Lio/reactivex/Scheduler;>;+Lio/reactivex/Scheduler;>;"
if-nez v0, :cond_e
.line 271
invoke-static {p0}, Lio/reactivex/plugins/RxJavaPlugins;->callRequireNonNull(Ljava/util/concurrent/Callable;)Lio/reactivex/Scheduler;
move-result-object v1
return-object v1
.line 273
:cond_e
invoke-static {v0, p0}, Lio/reactivex/plugins/RxJavaPlugins;->applyRequireNonNull(Lio/reactivex/functions/Function;Ljava/util/concurrent/Callable;)Lio/reactivex/Scheduler;
move-result-object v1
return-object v1
.end method
.method public static initIoScheduler(Ljava/util/concurrent/Callable;)Lio/reactivex/Scheduler;
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Ljava/util/concurrent/Callable<",
"Lio/reactivex/Scheduler;",
">;)",
"Lio/reactivex/Scheduler;"
}
.end annotation
.line 284
.local p0, "defaultScheduler":Ljava/util/concurrent/Callable;, "Ljava/util/concurrent/Callable<Lio/reactivex/Scheduler;>;"
const-string v0, "Scheduler Callable can\'t be null"
invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
.line 285
sget-object v0, Lio/reactivex/plugins/RxJavaPlugins;->onInitIoHandler:Lio/reactivex/functions/Function;
.line 286
.local v0, "f":Lio/reactivex/functions/Function;, "Lio/reactivex/functions/Function<-Ljava/util/concurrent/Callable<Lio/reactivex/Scheduler;>;+Lio/reactivex/Scheduler;>;"
if-nez v0, :cond_e
.line 287
invoke-static {p0}, Lio/reactivex/plugins/RxJavaPlugins;->callRequireNonNull(Ljava/util/concurrent/Callable;)Lio/reactivex/Scheduler;
move-result-object v1
return-object v1
.line 289
:cond_e
invoke-static {v0, p0}, Lio/reactivex/plugins/RxJavaPlugins;->applyRequireNonNull(Lio/reactivex/functions/Function;Ljava/util/concurrent/Callable;)Lio/reactivex/Scheduler;
move-result-object v1
return-object v1
.end method
.method public static initNewThreadScheduler(Ljava/util/concurrent/Callable;)Lio/reactivex/Scheduler;
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Ljava/util/concurrent/Callable<",
"Lio/reactivex/Scheduler;",
">;)",
"Lio/reactivex/Scheduler;"
}
.end annotation
.line 300
.local p0, "defaultScheduler":Ljava/util/concurrent/Callable;, "Ljava/util/concurrent/Callable<Lio/reactivex/Scheduler;>;"
const-string v0, "Scheduler Callable can\'t be null"
invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
.line 301
sget-object v0, Lio/reactivex/plugins/RxJavaPlugins;->onInitNewThreadHandler:Lio/reactivex/functions/Function;
.line 302
.local v0, "f":Lio/reactivex/functions/Function;, "Lio/reactivex/functions/Function<-Ljava/util/concurrent/Callable<Lio/reactivex/Scheduler;>;+Lio/reactivex/Scheduler;>;"
if-nez v0, :cond_e
.line 303
invoke-static {p0}, Lio/reactivex/plugins/RxJavaPlugins;->callRequireNonNull(Ljava/util/concurrent/Callable;)Lio/reactivex/Scheduler;
move-result-object v1
return-object v1
.line 305
:cond_e
invoke-static {v0, p0}, Lio/reactivex/plugins/RxJavaPlugins;->applyRequireNonNull(Lio/reactivex/functions/Function;Ljava/util/concurrent/Callable;)Lio/reactivex/Scheduler;
move-result-object v1
return-object v1
.end method
.method public static initSingleScheduler(Ljava/util/concurrent/Callable;)Lio/reactivex/Scheduler;
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Ljava/util/concurrent/Callable<",
"Lio/reactivex/Scheduler;",
">;)",
"Lio/reactivex/Scheduler;"
}
.end annotation
.line 316
.local p0, "defaultScheduler":Ljava/util/concurrent/Callable;, "Ljava/util/concurrent/Callable<Lio/reactivex/Scheduler;>;"
const-string v0, "Scheduler Callable can\'t be null"
invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
.line 317
sget-object v0, Lio/reactivex/plugins/RxJavaPlugins;->onInitSingleHandler:Lio/reactivex/functions/Function;
.line 318
.local v0, "f":Lio/reactivex/functions/Function;, "Lio/reactivex/functions/Function<-Ljava/util/concurrent/Callable<Lio/reactivex/Scheduler;>;+Lio/reactivex/Scheduler;>;"
if-nez v0, :cond_e
.line 319
invoke-static {p0}, Lio/reactivex/plugins/RxJavaPlugins;->callRequireNonNull(Ljava/util/concurrent/Callable;)Lio/reactivex/Scheduler;
move-result-object v1
return-object v1
.line 321
:cond_e
invoke-static {v0, p0}, Lio/reactivex/plugins/RxJavaPlugins;->applyRequireNonNull(Lio/reactivex/functions/Function;Ljava/util/concurrent/Callable;)Lio/reactivex/Scheduler;
move-result-object v1
return-object v1
.end method
.method static isBug(Ljava/lang/Throwable;)Z
.registers 3
.param p0, "error" # Ljava/lang/Throwable;
.line 378
instance-of v0, p0, Lio/reactivex/exceptions/OnErrorNotImplementedException;
const/4 v1, 0x1
if-eqz v0, :cond_6
.line 379
return v1
.line 383
:cond_6
instance-of v0, p0, Lio/reactivex/exceptions/MissingBackpressureException;
if-eqz v0, :cond_b
.line 384
return v1
.line 388
:cond_b
instance-of v0, p0, Ljava/lang/IllegalStateException;
if-eqz v0, :cond_10
.line 389
return v1
.line 393
:cond_10
instance-of v0, p0, Ljava/lang/NullPointerException;
if-eqz v0, :cond_15
.line 394
return v1
.line 397
:cond_15
instance-of v0, p0, Ljava/lang/IllegalArgumentException;
if-eqz v0, :cond_1a
.line 398
return v1
.line 401
:cond_1a
instance-of v0, p0, Lio/reactivex/exceptions/CompositeException;
if-eqz v0, :cond_1f
.line 402
return v1
.line 405
:cond_1f
const/4 v0, 0x0
return v0
.end method
.method public static isFailOnNonBlockingScheduler()Z
.registers 1
.line 167
sget-boolean v0, Lio/reactivex/plugins/RxJavaPlugins;->failNonBlockingScheduler:Z
return v0
.end method
.method public static isLockdown()Z
.registers 1
.line 140
sget-boolean v0, Lio/reactivex/plugins/RxJavaPlugins;->lockdown:Z
return v0
.end method
.method public static lockdown()V
.registers 1
.line 132
const/4 v0, 0x1
sput-boolean v0, Lio/reactivex/plugins/RxJavaPlugins;->lockdown:Z
.line 133
return-void
.end method
.method public static onAssembly(Lio/reactivex/Completable;)Lio/reactivex/Completable;
.registers 3
.param p0, "source" # Lio/reactivex/Completable;
.line 1078
sget-object v0, Lio/reactivex/plugins/RxJavaPlugins;->onCompletableAssembly:Lio/reactivex/functions/Function;
.line 1079
.local v0, "f":Lio/reactivex/functions/Function;, "Lio/reactivex/functions/Function<-Lio/reactivex/Completable;+Lio/reactivex/Completable;>;"
if-eqz v0, :cond_b
.line 1080
invoke-static {v0, p0}, Lio/reactivex/plugins/RxJavaPlugins;->apply(Lio/reactivex/functions/Function;Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v1
check-cast v1, Lio/reactivex/Completable;
return-object v1
.line 1082
:cond_b
return-object p0
.end method
.method public static onAssembly(Lio/reactivex/Flowable;)Lio/reactivex/Flowable;
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">(",
"Lio/reactivex/Flowable<",
"TT;>;)",
"Lio/reactivex/Flowable<",
"TT;>;"
}
.end annotation
.line 1000
.local p0, "source":Lio/reactivex/Flowable;, "Lio/reactivex/Flowable<TT;>;"
sget-object v0, Lio/reactivex/plugins/RxJavaPlugins;->onFlowableAssembly:Lio/reactivex/functions/Function;
.line 1001
.local v0, "f":Lio/reactivex/functions/Function;, "Lio/reactivex/functions/Function<-Lio/reactivex/Flowable;+Lio/reactivex/Flowable;>;"
if-eqz v0, :cond_b
.line 1002
invoke-static {v0, p0}, Lio/reactivex/plugins/RxJavaPlugins;->apply(Lio/reactivex/functions/Function;Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v1
check-cast v1, Lio/reactivex/Flowable;
return-object v1
.line 1004
:cond_b
return-object p0
.end method
.method public static onAssembly(Lio/reactivex/Maybe;)Lio/reactivex/Maybe;
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">(",
"Lio/reactivex/Maybe<",
"TT;>;)",
"Lio/reactivex/Maybe<",
"TT;>;"
}
.end annotation
.line 984
.local p0, "source":Lio/reactivex/Maybe;, "Lio/reactivex/Maybe<TT;>;"
sget-object v0, Lio/reactivex/plugins/RxJavaPlugins;->onMaybeAssembly:Lio/reactivex/functions/Function;
.line 985
.local v0, "f":Lio/reactivex/functions/Function;, "Lio/reactivex/functions/Function<-Lio/reactivex/Maybe;+Lio/reactivex/Maybe;>;"
if-eqz v0, :cond_b
.line 986
invoke-static {v0, p0}, Lio/reactivex/plugins/RxJavaPlugins;->apply(Lio/reactivex/functions/Function;Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v1
check-cast v1, Lio/reactivex/Maybe;
return-object v1
.line 988
:cond_b
return-object p0
.end method
.method public static onAssembly(Lio/reactivex/Observable;)Lio/reactivex/Observable;
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">(",
"Lio/reactivex/Observable<",
"TT;>;)",
"Lio/reactivex/Observable<",
"TT;>;"
}
.end annotation
.line 1032
.local p0, "source":Lio/reactivex/Observable;, "Lio/reactivex/Observable<TT;>;"
sget-object v0, Lio/reactivex/plugins/RxJavaPlugins;->onObservableAssembly:Lio/reactivex/functions/Function;
.line 1033
.local v0, "f":Lio/reactivex/functions/Function;, "Lio/reactivex/functions/Function<-Lio/reactivex/Observable;+Lio/reactivex/Observable;>;"
if-eqz v0, :cond_b
.line 1034
invoke-static {v0, p0}, Lio/reactivex/plugins/RxJavaPlugins;->apply(Lio/reactivex/functions/Function;Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v1
check-cast v1, Lio/reactivex/Observable;
return-object v1
.line 1036
:cond_b
return-object p0
.end method
.method public static onAssembly(Lio/reactivex/Single;)Lio/reactivex/Single;
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">(",
"Lio/reactivex/Single<",
"TT;>;)",
"Lio/reactivex/Single<",
"TT;>;"
}
.end annotation
.line 1064
.local p0, "source":Lio/reactivex/Single;, "Lio/reactivex/Single<TT;>;"
sget-object v0, Lio/reactivex/plugins/RxJavaPlugins;->onSingleAssembly:Lio/reactivex/functions/Function;
.line 1065
.local v0, "f":Lio/reactivex/functions/Function;, "Lio/reactivex/functions/Function<-Lio/reactivex/Single;+Lio/reactivex/Single;>;"
if-eqz v0, :cond_b
.line 1066
invoke-static {v0, p0}, Lio/reactivex/plugins/RxJavaPlugins;->apply(Lio/reactivex/functions/Function;Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v1
check-cast v1, Lio/reactivex/Single;
return-object v1
.line 1068
:cond_b
return-object p0
.end method
.method public static onAssembly(Lio/reactivex/flowables/ConnectableFlowable;)Lio/reactivex/flowables/ConnectableFlowable;
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">(",
"Lio/reactivex/flowables/ConnectableFlowable<",
"TT;>;)",
"Lio/reactivex/flowables/ConnectableFlowable<",
"TT;>;"
}
.end annotation
.line 1016
.local p0, "source":Lio/reactivex/flowables/ConnectableFlowable;, "Lio/reactivex/flowables/ConnectableFlowable<TT;>;"
sget-object v0, Lio/reactivex/plugins/RxJavaPlugins;->onConnectableFlowableAssembly:Lio/reactivex/functions/Function;
.line 1017
.local v0, "f":Lio/reactivex/functions/Function;, "Lio/reactivex/functions/Function<-Lio/reactivex/flowables/ConnectableFlowable;+Lio/reactivex/flowables/ConnectableFlowable;>;"
if-eqz v0, :cond_b
.line 1018
invoke-static {v0, p0}, Lio/reactivex/plugins/RxJavaPlugins;->apply(Lio/reactivex/functions/Function;Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v1
check-cast v1, Lio/reactivex/flowables/ConnectableFlowable;
return-object v1
.line 1020
:cond_b
return-object p0
.end method
.method public static onAssembly(Lio/reactivex/observables/ConnectableObservable;)Lio/reactivex/observables/ConnectableObservable;
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">(",
"Lio/reactivex/observables/ConnectableObservable<",
"TT;>;)",
"Lio/reactivex/observables/ConnectableObservable<",
"TT;>;"
}
.end annotation
.line 1048
.local p0, "source":Lio/reactivex/observables/ConnectableObservable;, "Lio/reactivex/observables/ConnectableObservable<TT;>;"
sget-object v0, Lio/reactivex/plugins/RxJavaPlugins;->onConnectableObservableAssembly:Lio/reactivex/functions/Function;
.line 1049
.local v0, "f":Lio/reactivex/functions/Function;, "Lio/reactivex/functions/Function<-Lio/reactivex/observables/ConnectableObservable;+Lio/reactivex/observables/ConnectableObservable;>;"
if-eqz v0, :cond_b
.line 1050
invoke-static {v0, p0}, Lio/reactivex/plugins/RxJavaPlugins;->apply(Lio/reactivex/functions/Function;Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v1
check-cast v1, Lio/reactivex/observables/ConnectableObservable;
return-object v1
.line 1052
:cond_b
return-object p0
.end method
.method public static onAssembly(Lio/reactivex/parallel/ParallelFlowable;)Lio/reactivex/parallel/ParallelFlowable;
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">(",
"Lio/reactivex/parallel/ParallelFlowable<",
"TT;>;)",
"Lio/reactivex/parallel/ParallelFlowable<",
"TT;>;"
}
.end annotation
.line 1125
.local p0, "source":Lio/reactivex/parallel/ParallelFlowable;, "Lio/reactivex/parallel/ParallelFlowable<TT;>;"
sget-object v0, Lio/reactivex/plugins/RxJavaPlugins;->onParallelAssembly:Lio/reactivex/functions/Function;
.line 1126
.local v0, "f":Lio/reactivex/functions/Function;, "Lio/reactivex/functions/Function<-Lio/reactivex/parallel/ParallelFlowable;+Lio/reactivex/parallel/ParallelFlowable;>;"
if-eqz v0, :cond_b
.line 1127
invoke-static {v0, p0}, Lio/reactivex/plugins/RxJavaPlugins;->apply(Lio/reactivex/functions/Function;Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v1
check-cast v1, Lio/reactivex/parallel/ParallelFlowable;
return-object v1
.line 1129
:cond_b
return-object p0
.end method
.method public static onBeforeBlocking()Z
.registers 3
.line 1143
sget-object v0, Lio/reactivex/plugins/RxJavaPlugins;->onBeforeBlocking:Lio/reactivex/functions/BooleanSupplier;
.line 1144
.local v0, "f":Lio/reactivex/functions/BooleanSupplier;
if-eqz v0, :cond_f
.line 1146
:try_start_4
invoke-interface {v0}, Lio/reactivex/functions/BooleanSupplier;->getAsBoolean()Z
move-result v1
:try_end_8
.catchall {:try_start_4 .. :try_end_8} :catchall_9
return v1
.line 1147
:catchall_9
move-exception v1
.line 1148
.local v1, "ex":Ljava/lang/Throwable;
invoke-static {v1}, Lio/reactivex/internal/util/ExceptionHelper;->wrapOrThrow(Ljava/lang/Throwable;)Ljava/lang/RuntimeException;
move-result-object v2
throw v2
.line 1151
.end local v1 # "ex":Ljava/lang/Throwable;
:cond_f
const/4 v1, 0x0
return v1
.end method
.method public static onComputationScheduler(Lio/reactivex/Scheduler;)Lio/reactivex/Scheduler;
.registers 3
.param p0, "defaultScheduler" # Lio/reactivex/Scheduler;
.line 331
sget-object v0, Lio/reactivex/plugins/RxJavaPlugins;->onComputationHandler:Lio/reactivex/functions/Function;
.line 332
.local v0, "f":Lio/reactivex/functions/Function;, "Lio/reactivex/functions/Function<-Lio/reactivex/Scheduler;+Lio/reactivex/Scheduler;>;"
if-nez v0, :cond_5
.line 333
return-object p0
.line 335
:cond_5
invoke-static {v0, p0}, Lio/reactivex/plugins/RxJavaPlugins;->apply(Lio/reactivex/functions/Function;Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v1
check-cast v1, Lio/reactivex/Scheduler;
return-object v1
.end method
.method public static onError(Ljava/lang/Throwable;)V
.registers 4
.param p0, "error" # Ljava/lang/Throwable;
.line 343
sget-object v0, Lio/reactivex/plugins/RxJavaPlugins;->errorHandler:Lio/reactivex/functions/Consumer;
.line 345
.local v0, "f":Lio/reactivex/functions/Consumer;, "Lio/reactivex/functions/Consumer<-Ljava/lang/Throwable;>;"
if-nez p0, :cond_d
.line 346
new-instance v1, Ljava/lang/NullPointerException;
const-string v2, "onError called with null. Null values are generally not allowed in 2.x operators and sources."
invoke-direct {v1, v2}, Ljava/lang/NullPointerException;-><init>(Ljava/lang/String;)V
move-object p0, v1
goto :goto_19
.line 348
:cond_d
invoke-static {p0}, Lio/reactivex/plugins/RxJavaPlugins;->isBug(Ljava/lang/Throwable;)Z
move-result v1
if-nez v1, :cond_19
.line 349
new-instance v1, Lio/reactivex/exceptions/UndeliverableException;
invoke-direct {v1, p0}, Lio/reactivex/exceptions/UndeliverableException;-><init>(Ljava/lang/Throwable;)V
move-object p0, v1
.line 353
:cond_19
:goto_19
if-eqz v0, :cond_26
.line 355
:try_start_1b
invoke-interface {v0, p0}, Lio/reactivex/functions/Consumer;->accept(Ljava/lang/Object;)V
:try_end_1e
.catchall {:try_start_1b .. :try_end_1e} :catchall_1f
.line 356
return-void
.line 357
:catchall_1f
move-exception v1
.line 359
.local v1, "e":Ljava/lang/Throwable;
invoke-virtual {v1}, Ljava/lang/Throwable;->printStackTrace()V
.line 360
invoke-static {v1}, Lio/reactivex/plugins/RxJavaPlugins;->uncaught(Ljava/lang/Throwable;)V
.line 364
.end local v1 # "e":Ljava/lang/Throwable;
:cond_26
invoke-virtual {p0}, Ljava/lang/Throwable;->printStackTrace()V
.line 365
invoke-static {p0}, Lio/reactivex/plugins/RxJavaPlugins;->uncaught(Ljava/lang/Throwable;)V
.line 366
return-void
.end method
.method public static onIoScheduler(Lio/reactivex/Scheduler;)Lio/reactivex/Scheduler;
.registers 3
.param p0, "defaultScheduler" # Lio/reactivex/Scheduler;
.line 421
sget-object v0, Lio/reactivex/plugins/RxJavaPlugins;->onIoHandler:Lio/reactivex/functions/Function;
.line 422
.local v0, "f":Lio/reactivex/functions/Function;, "Lio/reactivex/functions/Function<-Lio/reactivex/Scheduler;+Lio/reactivex/Scheduler;>;"
if-nez v0, :cond_5
.line 423
return-object p0
.line 425
:cond_5
invoke-static {v0, p0}, Lio/reactivex/plugins/RxJavaPlugins;->apply(Lio/reactivex/functions/Function;Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v1
check-cast v1, Lio/reactivex/Scheduler;
return-object v1
.end method
.method public static onNewThreadScheduler(Lio/reactivex/Scheduler;)Lio/reactivex/Scheduler;
.registers 3
.param p0, "defaultScheduler" # Lio/reactivex/Scheduler;
.line 435
sget-object v0, Lio/reactivex/plugins/RxJavaPlugins;->onNewThreadHandler:Lio/reactivex/functions/Function;
.line 436
.local v0, "f":Lio/reactivex/functions/Function;, "Lio/reactivex/functions/Function<-Lio/reactivex/Scheduler;+Lio/reactivex/Scheduler;>;"
if-nez v0, :cond_5
.line 437
return-object p0
.line 439
:cond_5
invoke-static {v0, p0}, Lio/reactivex/plugins/RxJavaPlugins;->apply(Lio/reactivex/functions/Function;Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v1
check-cast v1, Lio/reactivex/Scheduler;
return-object v1
.end method
.method public static onSchedule(Ljava/lang/Runnable;)Ljava/lang/Runnable;
.registers 3
.param p0, "run" # Ljava/lang/Runnable;
.line 449
sget-object v0, Lio/reactivex/plugins/RxJavaPlugins;->onScheduleHandler:Lio/reactivex/functions/Function;
.line 450
.local v0, "f":Lio/reactivex/functions/Function;, "Lio/reactivex/functions/Function<-Ljava/lang/Runnable;+Ljava/lang/Runnable;>;"
if-nez v0, :cond_5
.line 451
return-object p0
.line 453
:cond_5
invoke-static {v0, p0}, Lio/reactivex/plugins/RxJavaPlugins;->apply(Lio/reactivex/functions/Function;Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v1
check-cast v1, Ljava/lang/Runnable;
return-object v1
.end method
.method public static onSingleScheduler(Lio/reactivex/Scheduler;)Lio/reactivex/Scheduler;
.registers 3
.param p0, "defaultScheduler" # Lio/reactivex/Scheduler;
.line 463
sget-object v0, Lio/reactivex/plugins/RxJavaPlugins;->onSingleHandler:Lio/reactivex/functions/Function;
.line 464
.local v0, "f":Lio/reactivex/functions/Function;, "Lio/reactivex/functions/Function<-Lio/reactivex/Scheduler;+Lio/reactivex/Scheduler;>;"
if-nez v0, :cond_5
.line 465
return-object p0
.line 467
:cond_5
invoke-static {v0, p0}, Lio/reactivex/plugins/RxJavaPlugins;->apply(Lio/reactivex/functions/Function;Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v1
check-cast v1, Lio/reactivex/Scheduler;
return-object v1
.end method
.method public static onSubscribe(Lio/reactivex/Completable;Lio/reactivex/CompletableObserver;)Lio/reactivex/CompletableObserver;
.registers 4
.param p0, "source" # Lio/reactivex/Completable;
.param p1, "observer" # Lio/reactivex/CompletableObserver;
.line 951
sget-object v0, Lio/reactivex/plugins/RxJavaPlugins;->onCompletableSubscribe:Lio/reactivex/functions/BiFunction;
.line 952
.local v0, "f":Lio/reactivex/functions/BiFunction;, "Lio/reactivex/functions/BiFunction<-Lio/reactivex/Completable;-Lio/reactivex/CompletableObserver;+Lio/reactivex/CompletableObserver;>;"
if-eqz v0, :cond_b
.line 953
invoke-static {v0, p0, p1}, Lio/reactivex/plugins/RxJavaPlugins;->apply(Lio/reactivex/functions/BiFunction;Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v1
check-cast v1, Lio/reactivex/CompletableObserver;
return-object v1
.line 955
:cond_b
return-object p1
.end method
.method public static onSubscribe(Lio/reactivex/Maybe;Lio/reactivex/MaybeObserver;)Lio/reactivex/MaybeObserver;
.registers 4
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">(",
"Lio/reactivex/Maybe<",
"TT;>;",
"Lio/reactivex/MaybeObserver<",
"-TT;>;)",
"Lio/reactivex/MaybeObserver<",
"-TT;>;"
}
.end annotation
.line 968
.local p0, "source":Lio/reactivex/Maybe;, "Lio/reactivex/Maybe<TT;>;"
.local p1, "subscriber":Lio/reactivex/MaybeObserver;, "Lio/reactivex/MaybeObserver<-TT;>;"
sget-object v0, Lio/reactivex/plugins/RxJavaPlugins;->onMaybeSubscribe:Lio/reactivex/functions/BiFunction;
.line 969
.local v0, "f":Lio/reactivex/functions/BiFunction;, "Lio/reactivex/functions/BiFunction<-Lio/reactivex/Maybe;-Lio/reactivex/MaybeObserver;+Lio/reactivex/MaybeObserver;>;"
if-eqz v0, :cond_b
.line 970
invoke-static {v0, p0, p1}, Lio/reactivex/plugins/RxJavaPlugins;->apply(Lio/reactivex/functions/BiFunction;Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v1
check-cast v1, Lio/reactivex/MaybeObserver;
return-object v1
.line 972
:cond_b
return-object p1
.end method
.method public static onSubscribe(Lio/reactivex/Observable;Lio/reactivex/Observer;)Lio/reactivex/Observer;
.registers 4
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">(",
"Lio/reactivex/Observable<",
"TT;>;",
"Lio/reactivex/Observer<",
"-TT;>;)",
"Lio/reactivex/Observer<",
"-TT;>;"
}
.end annotation
.line 919
.local p0, "source":Lio/reactivex/Observable;, "Lio/reactivex/Observable<TT;>;"
.local p1, "observer":Lio/reactivex/Observer;, "Lio/reactivex/Observer<-TT;>;"
sget-object v0, Lio/reactivex/plugins/RxJavaPlugins;->onObservableSubscribe:Lio/reactivex/functions/BiFunction;
.line 920
.local v0, "f":Lio/reactivex/functions/BiFunction;, "Lio/reactivex/functions/BiFunction<-Lio/reactivex/Observable;-Lio/reactivex/Observer;+Lio/reactivex/Observer;>;"
if-eqz v0, :cond_b
.line 921
invoke-static {v0, p0, p1}, Lio/reactivex/plugins/RxJavaPlugins;->apply(Lio/reactivex/functions/BiFunction;Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v1
check-cast v1, Lio/reactivex/Observer;
return-object v1
.line 923
:cond_b
return-object p1
.end method
.method public static onSubscribe(Lio/reactivex/Single;Lio/reactivex/SingleObserver;)Lio/reactivex/SingleObserver;
.registers 4
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">(",
"Lio/reactivex/Single<",
"TT;>;",
"Lio/reactivex/SingleObserver<",
"-TT;>;)",
"Lio/reactivex/SingleObserver<",
"-TT;>;"
}
.end annotation
.line 936
.local p0, "source":Lio/reactivex/Single;, "Lio/reactivex/Single<TT;>;"
.local p1, "observer":Lio/reactivex/SingleObserver;, "Lio/reactivex/SingleObserver<-TT;>;"
sget-object v0, Lio/reactivex/plugins/RxJavaPlugins;->onSingleSubscribe:Lio/reactivex/functions/BiFunction;
.line 937
.local v0, "f":Lio/reactivex/functions/BiFunction;, "Lio/reactivex/functions/BiFunction<-Lio/reactivex/Single;-Lio/reactivex/SingleObserver;+Lio/reactivex/SingleObserver;>;"
if-eqz v0, :cond_b
.line 938
invoke-static {v0, p0, p1}, Lio/reactivex/plugins/RxJavaPlugins;->apply(Lio/reactivex/functions/BiFunction;Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v1
check-cast v1, Lio/reactivex/SingleObserver;
return-object v1
.line 940
:cond_b
return-object p1
.end method
.method public static onSubscribe(Lio/reactivex/Flowable;Lorg/reactivestreams/Subscriber;)Lorg/reactivestreams/Subscriber;
.registers 4
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">(",
"Lio/reactivex/Flowable<",
"TT;>;",
"Lorg/reactivestreams/Subscriber<",
"-TT;>;)",
"Lorg/reactivestreams/Subscriber<",
"-TT;>;"
}
.end annotation
.line 902
.local p0, "source":Lio/reactivex/Flowable;, "Lio/reactivex/Flowable<TT;>;"
.local p1, "subscriber":Lorg/reactivestreams/Subscriber;, "Lorg/reactivestreams/Subscriber<-TT;>;"
sget-object v0, Lio/reactivex/plugins/RxJavaPlugins;->onFlowableSubscribe:Lio/reactivex/functions/BiFunction;
.line 903
.local v0, "f":Lio/reactivex/functions/BiFunction;, "Lio/reactivex/functions/BiFunction<-Lio/reactivex/Flowable;-Lorg/reactivestreams/Subscriber;+Lorg/reactivestreams/Subscriber;>;"
if-eqz v0, :cond_b
.line 904
invoke-static {v0, p0, p1}, Lio/reactivex/plugins/RxJavaPlugins;->apply(Lio/reactivex/functions/BiFunction;Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v1
check-cast v1, Lorg/reactivestreams/Subscriber;
return-object v1
.line 906
:cond_b
return-object p1
.end method
.method public static reset()V
.registers 2
.line 474
const/4 v0, 0x0
invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->setErrorHandler(Lio/reactivex/functions/Consumer;)V
.line 475
invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->setScheduleHandler(Lio/reactivex/functions/Function;)V
.line 477
invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->setComputationSchedulerHandler(Lio/reactivex/functions/Function;)V
.line 478
invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->setInitComputationSchedulerHandler(Lio/reactivex/functions/Function;)V
.line 480
invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->setIoSchedulerHandler(Lio/reactivex/functions/Function;)V
.line 481
invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->setInitIoSchedulerHandler(Lio/reactivex/functions/Function;)V
.line 483
invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->setSingleSchedulerHandler(Lio/reactivex/functions/Function;)V
.line 484
invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->setInitSingleSchedulerHandler(Lio/reactivex/functions/Function;)V
.line 486
invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->setNewThreadSchedulerHandler(Lio/reactivex/functions/Function;)V
.line 487
invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->setInitNewThreadSchedulerHandler(Lio/reactivex/functions/Function;)V
.line 489
invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->setOnFlowableAssembly(Lio/reactivex/functions/Function;)V
.line 490
invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->setOnFlowableSubscribe(Lio/reactivex/functions/BiFunction;)V
.line 492
invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->setOnObservableAssembly(Lio/reactivex/functions/Function;)V
.line 493
invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->setOnObservableSubscribe(Lio/reactivex/functions/BiFunction;)V
.line 495
invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->setOnSingleAssembly(Lio/reactivex/functions/Function;)V
.line 496
invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->setOnSingleSubscribe(Lio/reactivex/functions/BiFunction;)V
.line 498
invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->setOnCompletableAssembly(Lio/reactivex/functions/Function;)V
.line 499
invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->setOnCompletableSubscribe(Lio/reactivex/functions/BiFunction;)V
.line 501
invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->setOnConnectableFlowableAssembly(Lio/reactivex/functions/Function;)V
.line 502
invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->setOnConnectableObservableAssembly(Lio/reactivex/functions/Function;)V
.line 504
invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->setOnMaybeAssembly(Lio/reactivex/functions/Function;)V
.line 505
invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->setOnMaybeSubscribe(Lio/reactivex/functions/BiFunction;)V
.line 507
invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->setOnParallelAssembly(Lio/reactivex/functions/Function;)V
.line 509
const/4 v1, 0x0
invoke-static {v1}, Lio/reactivex/plugins/RxJavaPlugins;->setFailOnNonBlockingScheduler(Z)V
.line 510
invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->setOnBeforeBlocking(Lio/reactivex/functions/BooleanSupplier;)V
.line 511
return-void
.end method
.method public static setComputationSchedulerHandler(Lio/reactivex/functions/Function;)V
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/functions/Function<",
"-",
"Lio/reactivex/Scheduler;",
"+",
"Lio/reactivex/Scheduler;",
">;)V"
}
.end annotation
.line 518
.local p0, "handler":Lio/reactivex/functions/Function;, "Lio/reactivex/functions/Function<-Lio/reactivex/Scheduler;+Lio/reactivex/Scheduler;>;"
sget-boolean v0, Lio/reactivex/plugins/RxJavaPlugins;->lockdown:Z
if-nez v0, :cond_7
.line 521
sput-object p0, Lio/reactivex/plugins/RxJavaPlugins;->onComputationHandler:Lio/reactivex/functions/Function;
.line 522
return-void
.line 519
:cond_7
new-instance v0, Ljava/lang/IllegalStateException;
const-string v1, "Plugins can\'t be changed anymore"
invoke-direct {v0, v1}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
throw v0
.end method
.method public static setErrorHandler(Lio/reactivex/functions/Consumer;)V
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/functions/Consumer<",
"-",
"Ljava/lang/Throwable;",
">;)V"
}
.end annotation
.line 529
.local p0, "handler":Lio/reactivex/functions/Consumer;, "Lio/reactivex/functions/Consumer<-Ljava/lang/Throwable;>;"
sget-boolean v0, Lio/reactivex/plugins/RxJavaPlugins;->lockdown:Z
if-nez v0, :cond_7
.line 532
sput-object p0, Lio/reactivex/plugins/RxJavaPlugins;->errorHandler:Lio/reactivex/functions/Consumer;
.line 533
return-void
.line 530
:cond_7
new-instance v0, Ljava/lang/IllegalStateException;
const-string v1, "Plugins can\'t be changed anymore"
invoke-direct {v0, v1}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
throw v0
.end method
.method public static setFailOnNonBlockingScheduler(Z)V
.registers 3
.param p0, "enable" # Z
.line 152
sget-boolean v0, Lio/reactivex/plugins/RxJavaPlugins;->lockdown:Z
if-nez v0, :cond_7
.line 155
sput-boolean p0, Lio/reactivex/plugins/RxJavaPlugins;->failNonBlockingScheduler:Z
.line 156
return-void
.line 153
:cond_7
new-instance v0, Ljava/lang/IllegalStateException;
const-string v1, "Plugins can\'t be changed anymore"
invoke-direct {v0, v1}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
throw v0
.end method
.method public static setInitComputationSchedulerHandler(Lio/reactivex/functions/Function;)V
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/functions/Function<",
"-",
"Ljava/util/concurrent/Callable<",
"Lio/reactivex/Scheduler;",
">;+",
"Lio/reactivex/Scheduler;",
">;)V"
}
.end annotation
.line 540
.local p0, "handler":Lio/reactivex/functions/Function;, "Lio/reactivex/functions/Function<-Ljava/util/concurrent/Callable<Lio/reactivex/Scheduler;>;+Lio/reactivex/Scheduler;>;"
sget-boolean v0, Lio/reactivex/plugins/RxJavaPlugins;->lockdown:Z
if-nez v0, :cond_7
.line 543
sput-object p0, Lio/reactivex/plugins/RxJavaPlugins;->onInitComputationHandler:Lio/reactivex/functions/Function;
.line 544
return-void
.line 541
:cond_7
new-instance v0, Ljava/lang/IllegalStateException;
const-string v1, "Plugins can\'t be changed anymore"
invoke-direct {v0, v1}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
throw v0
.end method
.method public static setInitIoSchedulerHandler(Lio/reactivex/functions/Function;)V
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/functions/Function<",
"-",
"Ljava/util/concurrent/Callable<",
"Lio/reactivex/Scheduler;",
">;+",
"Lio/reactivex/Scheduler;",
">;)V"
}
.end annotation
.line 551
.local p0, "handler":Lio/reactivex/functions/Function;, "Lio/reactivex/functions/Function<-Ljava/util/concurrent/Callable<Lio/reactivex/Scheduler;>;+Lio/reactivex/Scheduler;>;"
sget-boolean v0, Lio/reactivex/plugins/RxJavaPlugins;->lockdown:Z
if-nez v0, :cond_7
.line 554
sput-object p0, Lio/reactivex/plugins/RxJavaPlugins;->onInitIoHandler:Lio/reactivex/functions/Function;
.line 555
return-void
.line 552
:cond_7
new-instance v0, Ljava/lang/IllegalStateException;
const-string v1, "Plugins can\'t be changed anymore"
invoke-direct {v0, v1}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
throw v0
.end method
.method public static setInitNewThreadSchedulerHandler(Lio/reactivex/functions/Function;)V
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/functions/Function<",
"-",
"Ljava/util/concurrent/Callable<",
"Lio/reactivex/Scheduler;",
">;+",
"Lio/reactivex/Scheduler;",
">;)V"
}
.end annotation
.line 562
.local p0, "handler":Lio/reactivex/functions/Function;, "Lio/reactivex/functions/Function<-Ljava/util/concurrent/Callable<Lio/reactivex/Scheduler;>;+Lio/reactivex/Scheduler;>;"
sget-boolean v0, Lio/reactivex/plugins/RxJavaPlugins;->lockdown:Z
if-nez v0, :cond_7
.line 565
sput-object p0, Lio/reactivex/plugins/RxJavaPlugins;->onInitNewThreadHandler:Lio/reactivex/functions/Function;
.line 566
return-void
.line 563
:cond_7
new-instance v0, Ljava/lang/IllegalStateException;
const-string v1, "Plugins can\'t be changed anymore"
invoke-direct {v0, v1}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
throw v0
.end method
.method public static setInitSingleSchedulerHandler(Lio/reactivex/functions/Function;)V
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/functions/Function<",
"-",
"Ljava/util/concurrent/Callable<",
"Lio/reactivex/Scheduler;",
">;+",
"Lio/reactivex/Scheduler;",
">;)V"
}
.end annotation
.line 573
.local p0, "handler":Lio/reactivex/functions/Function;, "Lio/reactivex/functions/Function<-Ljava/util/concurrent/Callable<Lio/reactivex/Scheduler;>;+Lio/reactivex/Scheduler;>;"
sget-boolean v0, Lio/reactivex/plugins/RxJavaPlugins;->lockdown:Z
if-nez v0, :cond_7
.line 576
sput-object p0, Lio/reactivex/plugins/RxJavaPlugins;->onInitSingleHandler:Lio/reactivex/functions/Function;
.line 577
return-void
.line 574
:cond_7
new-instance v0, Ljava/lang/IllegalStateException;
const-string v1, "Plugins can\'t be changed anymore"
invoke-direct {v0, v1}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
throw v0
.end method
.method public static setIoSchedulerHandler(Lio/reactivex/functions/Function;)V
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/functions/Function<",
"-",
"Lio/reactivex/Scheduler;",
"+",
"Lio/reactivex/Scheduler;",
">;)V"
}
.end annotation
.line 584
.local p0, "handler":Lio/reactivex/functions/Function;, "Lio/reactivex/functions/Function<-Lio/reactivex/Scheduler;+Lio/reactivex/Scheduler;>;"
sget-boolean v0, Lio/reactivex/plugins/RxJavaPlugins;->lockdown:Z
if-nez v0, :cond_7
.line 587
sput-object p0, Lio/reactivex/plugins/RxJavaPlugins;->onIoHandler:Lio/reactivex/functions/Function;
.line 588
return-void
.line 585
:cond_7
new-instance v0, Ljava/lang/IllegalStateException;
const-string v1, "Plugins can\'t be changed anymore"
invoke-direct {v0, v1}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
throw v0
.end method
.method public static setNewThreadSchedulerHandler(Lio/reactivex/functions/Function;)V
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/functions/Function<",
"-",
"Lio/reactivex/Scheduler;",
"+",
"Lio/reactivex/Scheduler;",
">;)V"
}
.end annotation
.line 595
.local p0, "handler":Lio/reactivex/functions/Function;, "Lio/reactivex/functions/Function<-Lio/reactivex/Scheduler;+Lio/reactivex/Scheduler;>;"
sget-boolean v0, Lio/reactivex/plugins/RxJavaPlugins;->lockdown:Z
if-nez v0, :cond_7
.line 598
sput-object p0, Lio/reactivex/plugins/RxJavaPlugins;->onNewThreadHandler:Lio/reactivex/functions/Function;
.line 599
return-void
.line 596
:cond_7
new-instance v0, Ljava/lang/IllegalStateException;
const-string v1, "Plugins can\'t be changed anymore"
invoke-direct {v0, v1}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
throw v0
.end method
.method public static setOnBeforeBlocking(Lio/reactivex/functions/BooleanSupplier;)V
.registers 3
.param p0, "handler" # Lio/reactivex/functions/BooleanSupplier;
.line 1165
sget-boolean v0, Lio/reactivex/plugins/RxJavaPlugins;->lockdown:Z
if-nez v0, :cond_7
.line 1168
sput-object p0, Lio/reactivex/plugins/RxJavaPlugins;->onBeforeBlocking:Lio/reactivex/functions/BooleanSupplier;
.line 1169
return-void
.line 1166
:cond_7
new-instance v0, Ljava/lang/IllegalStateException;
const-string v1, "Plugins can\'t be changed anymore"
invoke-direct {v0, v1}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
throw v0
.end method
.method public static setOnCompletableAssembly(Lio/reactivex/functions/Function;)V
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/functions/Function<",
"-",
"Lio/reactivex/Completable;",
"+",
"Lio/reactivex/Completable;",
">;)V"
}
.end annotation
.line 753
.local p0, "onCompletableAssembly":Lio/reactivex/functions/Function;, "Lio/reactivex/functions/Function<-Lio/reactivex/Completable;+Lio/reactivex/Completable;>;"
sget-boolean v0, Lio/reactivex/plugins/RxJavaPlugins;->lockdown:Z
if-nez v0, :cond_7
.line 756
sput-object p0, Lio/reactivex/plugins/RxJavaPlugins;->onCompletableAssembly:Lio/reactivex/functions/Function;
.line 757
return-void
.line 754
:cond_7
new-instance v0, Ljava/lang/IllegalStateException;
const-string v1, "Plugins can\'t be changed anymore"
invoke-direct {v0, v1}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
throw v0
.end method
.method public static setOnCompletableSubscribe(Lio/reactivex/functions/BiFunction;)V
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/functions/BiFunction<",
"-",
"Lio/reactivex/Completable;",
"-",
"Lio/reactivex/CompletableObserver;",
"+",
"Lio/reactivex/CompletableObserver;",
">;)V"
}
.end annotation
.line 765
.local p0, "onCompletableSubscribe":Lio/reactivex/functions/BiFunction;, "Lio/reactivex/functions/BiFunction<-Lio/reactivex/Completable;-Lio/reactivex/CompletableObserver;+Lio/reactivex/CompletableObserver;>;"
sget-boolean v0, Lio/reactivex/plugins/RxJavaPlugins;->lockdown:Z
if-nez v0, :cond_7
.line 768
sput-object p0, Lio/reactivex/plugins/RxJavaPlugins;->onCompletableSubscribe:Lio/reactivex/functions/BiFunction;
.line 769
return-void
.line 766
:cond_7
new-instance v0, Ljava/lang/IllegalStateException;
const-string v1, "Plugins can\'t be changed anymore"
invoke-direct {v0, v1}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
throw v0
.end method
.method public static setOnConnectableFlowableAssembly(Lio/reactivex/functions/Function;)V
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/functions/Function<",
"-",
"Lio/reactivex/flowables/ConnectableFlowable;",
"+",
"Lio/reactivex/flowables/ConnectableFlowable;",
">;)V"
}
.end annotation
.line 801
.local p0, "onConnectableFlowableAssembly":Lio/reactivex/functions/Function;, "Lio/reactivex/functions/Function<-Lio/reactivex/flowables/ConnectableFlowable;+Lio/reactivex/flowables/ConnectableFlowable;>;"
sget-boolean v0, Lio/reactivex/plugins/RxJavaPlugins;->lockdown:Z
if-nez v0, :cond_7
.line 804
sput-object p0, Lio/reactivex/plugins/RxJavaPlugins;->onConnectableFlowableAssembly:Lio/reactivex/functions/Function;
.line 805
return-void
.line 802
:cond_7
new-instance v0, Ljava/lang/IllegalStateException;
const-string v1, "Plugins can\'t be changed anymore"
invoke-direct {v0, v1}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
throw v0
.end method
.method public static setOnConnectableObservableAssembly(Lio/reactivex/functions/Function;)V
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/functions/Function<",
"-",
"Lio/reactivex/observables/ConnectableObservable;",
"+",
"Lio/reactivex/observables/ConnectableObservable;",
">;)V"
}
.end annotation
.line 849
.local p0, "onConnectableObservableAssembly":Lio/reactivex/functions/Function;, "Lio/reactivex/functions/Function<-Lio/reactivex/observables/ConnectableObservable;+Lio/reactivex/observables/ConnectableObservable;>;"
sget-boolean v0, Lio/reactivex/plugins/RxJavaPlugins;->lockdown:Z
if-nez v0, :cond_7
.line 852
sput-object p0, Lio/reactivex/plugins/RxJavaPlugins;->onConnectableObservableAssembly:Lio/reactivex/functions/Function;
.line 853
return-void
.line 850
:cond_7
new-instance v0, Ljava/lang/IllegalStateException;
const-string v1, "Plugins can\'t be changed anymore"
invoke-direct {v0, v1}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
throw v0
.end method
.method public static setOnFlowableAssembly(Lio/reactivex/functions/Function;)V
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/functions/Function<",
"-",
"Lio/reactivex/Flowable;",
"+",
"Lio/reactivex/Flowable;",
">;)V"
}
.end annotation
.line 777
.local p0, "onFlowableAssembly":Lio/reactivex/functions/Function;, "Lio/reactivex/functions/Function<-Lio/reactivex/Flowable;+Lio/reactivex/Flowable;>;"
sget-boolean v0, Lio/reactivex/plugins/RxJavaPlugins;->lockdown:Z
if-nez v0, :cond_7
.line 780
sput-object p0, Lio/reactivex/plugins/RxJavaPlugins;->onFlowableAssembly:Lio/reactivex/functions/Function;
.line 781
return-void
.line 778
:cond_7
new-instance v0, Ljava/lang/IllegalStateException;
const-string v1, "Plugins can\'t be changed anymore"
invoke-direct {v0, v1}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
throw v0
.end method
.method public static setOnFlowableSubscribe(Lio/reactivex/functions/BiFunction;)V
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/functions/BiFunction<",
"-",
"Lio/reactivex/Flowable;",
"-",
"Lorg/reactivestreams/Subscriber;",
"+",
"Lorg/reactivestreams/Subscriber;",
">;)V"
}
.end annotation
.line 813
.local p0, "onFlowableSubscribe":Lio/reactivex/functions/BiFunction;, "Lio/reactivex/functions/BiFunction<-Lio/reactivex/Flowable;-Lorg/reactivestreams/Subscriber;+Lorg/reactivestreams/Subscriber;>;"
sget-boolean v0, Lio/reactivex/plugins/RxJavaPlugins;->lockdown:Z
if-nez v0, :cond_7
.line 816
sput-object p0, Lio/reactivex/plugins/RxJavaPlugins;->onFlowableSubscribe:Lio/reactivex/functions/BiFunction;
.line 817
return-void
.line 814
:cond_7
new-instance v0, Ljava/lang/IllegalStateException;
const-string v1, "Plugins can\'t be changed anymore"
invoke-direct {v0, v1}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
throw v0
.end method
.method public static setOnMaybeAssembly(Lio/reactivex/functions/Function;)V
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/functions/Function<",
"-",
"Lio/reactivex/Maybe;",
"+",
"Lio/reactivex/Maybe;",
">;)V"
}
.end annotation
.line 789
.local p0, "onMaybeAssembly":Lio/reactivex/functions/Function;, "Lio/reactivex/functions/Function<-Lio/reactivex/Maybe;+Lio/reactivex/Maybe;>;"
sget-boolean v0, Lio/reactivex/plugins/RxJavaPlugins;->lockdown:Z
if-nez v0, :cond_7
.line 792
sput-object p0, Lio/reactivex/plugins/RxJavaPlugins;->onMaybeAssembly:Lio/reactivex/functions/Function;
.line 793
return-void
.line 790
:cond_7
new-instance v0, Ljava/lang/IllegalStateException;
const-string v1, "Plugins can\'t be changed anymore"
invoke-direct {v0, v1}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
throw v0
.end method
.method public static setOnMaybeSubscribe(Lio/reactivex/functions/BiFunction;)V
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/functions/BiFunction<",
"-",
"Lio/reactivex/Maybe;",
"Lio/reactivex/MaybeObserver;",
"+",
"Lio/reactivex/MaybeObserver;",
">;)V"
}
.end annotation
.line 825
.local p0, "onMaybeSubscribe":Lio/reactivex/functions/BiFunction;, "Lio/reactivex/functions/BiFunction<-Lio/reactivex/Maybe;Lio/reactivex/MaybeObserver;+Lio/reactivex/MaybeObserver;>;"
sget-boolean v0, Lio/reactivex/plugins/RxJavaPlugins;->lockdown:Z
if-nez v0, :cond_7
.line 828
sput-object p0, Lio/reactivex/plugins/RxJavaPlugins;->onMaybeSubscribe:Lio/reactivex/functions/BiFunction;
.line 829
return-void
.line 826
:cond_7
new-instance v0, Ljava/lang/IllegalStateException;
const-string v1, "Plugins can\'t be changed anymore"
invoke-direct {v0, v1}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
throw v0
.end method
.method public static setOnObservableAssembly(Lio/reactivex/functions/Function;)V
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/functions/Function<",
"-",
"Lio/reactivex/Observable;",
"+",
"Lio/reactivex/Observable;",
">;)V"
}
.end annotation
.line 837
.local p0, "onObservableAssembly":Lio/reactivex/functions/Function;, "Lio/reactivex/functions/Function<-Lio/reactivex/Observable;+Lio/reactivex/Observable;>;"
sget-boolean v0, Lio/reactivex/plugins/RxJavaPlugins;->lockdown:Z
if-nez v0, :cond_7
.line 840
sput-object p0, Lio/reactivex/plugins/RxJavaPlugins;->onObservableAssembly:Lio/reactivex/functions/Function;
.line 841
return-void
.line 838
:cond_7
new-instance v0, Ljava/lang/IllegalStateException;
const-string v1, "Plugins can\'t be changed anymore"
invoke-direct {v0, v1}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
throw v0
.end method
.method public static setOnObservableSubscribe(Lio/reactivex/functions/BiFunction;)V
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/functions/BiFunction<",
"-",
"Lio/reactivex/Observable;",
"-",
"Lio/reactivex/Observer;",
"+",
"Lio/reactivex/Observer;",
">;)V"
}
.end annotation
.line 862
.local p0, "onObservableSubscribe":Lio/reactivex/functions/BiFunction;, "Lio/reactivex/functions/BiFunction<-Lio/reactivex/Observable;-Lio/reactivex/Observer;+Lio/reactivex/Observer;>;"
sget-boolean v0, Lio/reactivex/plugins/RxJavaPlugins;->lockdown:Z
if-nez v0, :cond_7
.line 865
sput-object p0, Lio/reactivex/plugins/RxJavaPlugins;->onObservableSubscribe:Lio/reactivex/functions/BiFunction;
.line 866
return-void
.line 863
:cond_7
new-instance v0, Ljava/lang/IllegalStateException;
const-string v1, "Plugins can\'t be changed anymore"
invoke-direct {v0, v1}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
throw v0
.end method
.method public static setOnParallelAssembly(Lio/reactivex/functions/Function;)V
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/functions/Function<",
"-",
"Lio/reactivex/parallel/ParallelFlowable;",
"+",
"Lio/reactivex/parallel/ParallelFlowable;",
">;)V"
}
.end annotation
.line 1094
.local p0, "handler":Lio/reactivex/functions/Function;, "Lio/reactivex/functions/Function<-Lio/reactivex/parallel/ParallelFlowable;+Lio/reactivex/parallel/ParallelFlowable;>;"
sget-boolean v0, Lio/reactivex/plugins/RxJavaPlugins;->lockdown:Z
if-nez v0, :cond_7
.line 1097
sput-object p0, Lio/reactivex/plugins/RxJavaPlugins;->onParallelAssembly:Lio/reactivex/functions/Function;
.line 1098
return-void
.line 1095
:cond_7
new-instance v0, Ljava/lang/IllegalStateException;
const-string v1, "Plugins can\'t be changed anymore"
invoke-direct {v0, v1}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
throw v0
.end method
.method public static setOnSingleAssembly(Lio/reactivex/functions/Function;)V
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/functions/Function<",
"-",
"Lio/reactivex/Single;",
"+",
"Lio/reactivex/Single;",
">;)V"
}
.end annotation
.line 874
.local p0, "onSingleAssembly":Lio/reactivex/functions/Function;, "Lio/reactivex/functions/Function<-Lio/reactivex/Single;+Lio/reactivex/Single;>;"
sget-boolean v0, Lio/reactivex/plugins/RxJavaPlugins;->lockdown:Z
if-nez v0, :cond_7
.line 877
sput-object p0, Lio/reactivex/plugins/RxJavaPlugins;->onSingleAssembly:Lio/reactivex/functions/Function;
.line 878
return-void
.line 875
:cond_7
new-instance v0, Ljava/lang/IllegalStateException;
const-string v1, "Plugins can\'t be changed anymore"
invoke-direct {v0, v1}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
throw v0
.end method
.method public static setOnSingleSubscribe(Lio/reactivex/functions/BiFunction;)V
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/functions/BiFunction<",
"-",
"Lio/reactivex/Single;",
"-",
"Lio/reactivex/SingleObserver;",
"+",
"Lio/reactivex/SingleObserver;",
">;)V"
}
.end annotation
.line 886
.local p0, "onSingleSubscribe":Lio/reactivex/functions/BiFunction;, "Lio/reactivex/functions/BiFunction<-Lio/reactivex/Single;-Lio/reactivex/SingleObserver;+Lio/reactivex/SingleObserver;>;"
sget-boolean v0, Lio/reactivex/plugins/RxJavaPlugins;->lockdown:Z
if-nez v0, :cond_7
.line 889
sput-object p0, Lio/reactivex/plugins/RxJavaPlugins;->onSingleSubscribe:Lio/reactivex/functions/BiFunction;
.line 890
return-void
.line 887
:cond_7
new-instance v0, Ljava/lang/IllegalStateException;
const-string v1, "Plugins can\'t be changed anymore"
invoke-direct {v0, v1}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
throw v0
.end method
.method public static setScheduleHandler(Lio/reactivex/functions/Function;)V
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/functions/Function<",
"-",
"Ljava/lang/Runnable;",
"+",
"Ljava/lang/Runnable;",
">;)V"
}
.end annotation
.line 606
.local p0, "handler":Lio/reactivex/functions/Function;, "Lio/reactivex/functions/Function<-Ljava/lang/Runnable;+Ljava/lang/Runnable;>;"
sget-boolean v0, Lio/reactivex/plugins/RxJavaPlugins;->lockdown:Z
if-nez v0, :cond_7
.line 609
sput-object p0, Lio/reactivex/plugins/RxJavaPlugins;->onScheduleHandler:Lio/reactivex/functions/Function;
.line 610
return-void
.line 607
:cond_7
new-instance v0, Ljava/lang/IllegalStateException;
const-string v1, "Plugins can\'t be changed anymore"
invoke-direct {v0, v1}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
throw v0
.end method
.method public static setSingleSchedulerHandler(Lio/reactivex/functions/Function;)V
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/functions/Function<",
"-",
"Lio/reactivex/Scheduler;",
"+",
"Lio/reactivex/Scheduler;",
">;)V"
}
.end annotation
.line 617
.local p0, "handler":Lio/reactivex/functions/Function;, "Lio/reactivex/functions/Function<-Lio/reactivex/Scheduler;+Lio/reactivex/Scheduler;>;"
sget-boolean v0, Lio/reactivex/plugins/RxJavaPlugins;->lockdown:Z
if-nez v0, :cond_7
.line 620
sput-object p0, Lio/reactivex/plugins/RxJavaPlugins;->onSingleHandler:Lio/reactivex/functions/Function;
.line 621
return-void
.line 618
:cond_7
new-instance v0, Ljava/lang/IllegalStateException;
const-string v1, "Plugins can\'t be changed anymore"
invoke-direct {v0, v1}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
throw v0
.end method
.method static uncaught(Ljava/lang/Throwable;)V
.registers 3
.param p0, "error" # Ljava/lang/Throwable;
.line 409
invoke-static {}, Ljava/lang/Thread;->currentThread()Ljava/lang/Thread;
move-result-object v0
.line 410
.local v0, "currentThread":Ljava/lang/Thread;
invoke-virtual {v0}, Ljava/lang/Thread;->getUncaughtExceptionHandler()Ljava/lang/Thread$UncaughtExceptionHandler;
move-result-object v1
.line 411
.local v1, "handler":Ljava/lang/Thread$UncaughtExceptionHandler;
invoke-interface {v1, v0, p0}, Ljava/lang/Thread$UncaughtExceptionHandler;->uncaughtException(Ljava/lang/Thread;Ljava/lang/Throwable;)V
.line 412
return-void
.end method
.method static unlock()V
.registers 1
.line 627
const/4 v0, 0x0
sput-boolean v0, Lio/reactivex/plugins/RxJavaPlugins;->lockdown:Z
.line 628
return-void
.end method