.class public abstract Lkh/a; .super Ljava/lang/Object; .source "Completable.java" # interfaces .implements Lkh/g; # direct methods .method public constructor ()V .locals 0 .line 1 invoke-direct {p0}, Ljava/lang/Object;->()V return-void .end method .method public static A(Ljava/util/concurrent/Callable;)Lkh/a; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/Callable<", "+", "Lkh/g;", ">;)", "Lkh/a;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "completableSupplier" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/completable/b; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/completable/b;->(Ljava/util/concurrent/Callable;)V invoke-static {v0}, Lwh/a;->O(Lkh/a;)Lkh/a; move-result-object p0 return-object p0 .end method .method public static P(Ljava/lang/Throwable;)Lkh/a; .locals 1 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "error is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/completable/g; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/completable/g;->(Ljava/lang/Throwable;)V invoke-static {v0}, Lwh/a;->O(Lkh/a;)Lkh/a; move-result-object p0 return-object p0 .end method .method public static Q(Ljava/util/concurrent/Callable;)Lkh/a; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/Callable<", "+", "Ljava/lang/Throwable;", ">;)", "Lkh/a;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "errorSupplier is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/completable/h; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/completable/h;->(Ljava/util/concurrent/Callable;)V invoke-static {v0}, Lwh/a;->O(Lkh/a;)Lkh/a; move-result-object p0 return-object p0 .end method .method public static R(Lph/a;)Lkh/a; .locals 1 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "run is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/completable/i; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/completable/i;->(Lph/a;)V invoke-static {v0}, Lwh/a;->O(Lkh/a;)Lkh/a; move-result-object p0 return-object p0 .end method .method public static S(Ljava/util/concurrent/Callable;)Lkh/a; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/Callable<", "*>;)", "Lkh/a;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "callable is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/completable/j; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/completable/j;->(Ljava/util/concurrent/Callable;)V invoke-static {v0}, Lwh/a;->O(Lkh/a;)Lkh/a; move-result-object p0 return-object p0 .end method .method public static T(Ljava/util/concurrent/Future;)Lkh/a; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/Future<", "*>;)", "Lkh/a;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "future is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 invoke-static {p0}, Lio/reactivex/internal/functions/Functions;->j(Ljava/util/concurrent/Future;)Lph/a; move-result-object p0 invoke-static {p0}, Lkh/a;->R(Lph/a;)Lkh/a; move-result-object p0 return-object p0 .end method .method public static T0(JLjava/util/concurrent/TimeUnit;)Lkh/a; .locals 1 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "io.reactivex:computation" .end annotation .line 1 invoke-static {}, Lli/b;->a()Lkh/h0; move-result-object v0 invoke-static {p0, p1, p2, v0}, Lkh/a;->U0(JLjava/util/concurrent/TimeUnit;Lkh/h0;)Lkh/a; move-result-object p0 return-object p0 .end method .method public static U(Lkh/w;)Lkh/a; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/w<", "TT;>;)", "Lkh/a;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "maybe is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/maybe/w; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/w;->(Lkh/w;)V invoke-static {v0}, Lwh/a;->O(Lkh/a;)Lkh/a; move-result-object p0 return-object p0 .end method .method public static U0(JLjava/util/concurrent/TimeUnit;Lkh/h0;)Lkh/a; .locals 1 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "custom" .end annotation const-string v0, "unit is null" .line 1 invoke-static {p2, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "scheduler is null" .line 2 invoke-static {p3, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 3 new-instance v0, Lio/reactivex/internal/operators/completable/CompletableTimer; invoke-direct {v0, p0, p1, p2, p3}, Lio/reactivex/internal/operators/completable/CompletableTimer;->(JLjava/util/concurrent/TimeUnit;Lkh/h0;)V invoke-static {v0}, Lwh/a;->O(Lkh/a;)Lkh/a; move-result-object p0 return-object p0 .end method .method public static V(Lkh/e0;)Lkh/a; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/e0<", "TT;>;)", "Lkh/a;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "observable is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/completable/k; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/completable/k;->(Lkh/e0;)V invoke-static {v0}, Lwh/a;->O(Lkh/a;)Lkh/a; move-result-object p0 return-object p0 .end method .method public static W(Lok/c;)Lkh/a; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lok/c<", "TT;>;)", "Lkh/a;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->UNBOUNDED_IN:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "publisher is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/completable/l; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/completable/l;->(Lok/c;)V invoke-static {v0}, Lwh/a;->O(Lkh/a;)Lkh/a; move-result-object p0 return-object p0 .end method .method public static X(Ljava/lang/Runnable;)Lkh/a; .locals 1 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "run is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/completable/m; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/completable/m;->(Ljava/lang/Runnable;)V invoke-static {v0}, Lwh/a;->O(Lkh/a;)Lkh/a; move-result-object p0 return-object p0 .end method .method public static Y(Lkh/o0;)Lkh/a; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/o0<", "TT;>;)", "Lkh/a;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "single is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/completable/n; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/completable/n;->(Lkh/o0;)V invoke-static {v0}, Lwh/a;->O(Lkh/a;)Lkh/a; move-result-object p0 return-object p0 .end method .method public static Y0(Ljava/lang/Throwable;)Ljava/lang/NullPointerException; .locals 2 .line 1 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;->(Ljava/lang/String;)V .line 2 invoke-virtual {v0, p0}, Ljava/lang/NullPointerException;->initCause(Ljava/lang/Throwable;)Ljava/lang/Throwable; return-object v0 .end method .method public static c0(Ljava/lang/Iterable;)Lkh/a; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Iterable<", "+", "Lkh/g;", ">;)", "Lkh/a;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "sources is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/completable/CompletableMergeIterable; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/completable/CompletableMergeIterable;->(Ljava/lang/Iterable;)V invoke-static {v0}, Lwh/a;->O(Lkh/a;)Lkh/a; move-result-object p0 return-object p0 .end method .method public static c1(Lkh/g;)Lkh/a; .locals 1 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "source is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 instance-of v0, p0, Lkh/a; if-nez v0, :cond_0 .line 3 new-instance v0, Lio/reactivex/internal/operators/completable/o; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/completable/o;->(Lkh/g;)V invoke-static {v0}, Lwh/a;->O(Lkh/a;)Lkh/a; move-result-object p0 return-object p0 .line 4 :cond_0 new-instance p0, Ljava/lang/IllegalArgumentException; const-string v0, "Use of unsafeCreate(Completable)!" invoke-direct {p0, v0}, Ljava/lang/IllegalArgumentException;->(Ljava/lang/String;)V throw p0 .end method .method public static d0(Lok/c;)Lkh/a; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lok/c<", "+", "Lkh/g;", ">;)", "Lkh/a;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->UNBOUNDED_IN:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const v0, 0x7fffffff const/4 v1, 0x0 .line 1 invoke-static {p0, v0, v1}, Lkh/a;->f0(Lok/c;IZ)Lkh/a; move-result-object p0 return-object p0 .end method .method public static e(Ljava/lang/Iterable;)Lkh/a; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Iterable<", "+", "Lkh/g;", ">;)", "Lkh/a;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "sources is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/completable/a; const/4 v1, 0x0 invoke-direct {v0, v1, p0}, Lio/reactivex/internal/operators/completable/a;->([Lkh/g;Ljava/lang/Iterable;)V invoke-static {v0}, Lwh/a;->O(Lkh/a;)Lkh/a; move-result-object p0 return-object p0 .end method .method public static e0(Lok/c;I)Lkh/a; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lok/c<", "+", "Lkh/g;", ">;I)", "Lkh/a;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const/4 v0, 0x0 .line 1 invoke-static {p0, p1, v0}, Lkh/a;->f0(Lok/c;IZ)Lkh/a; move-result-object p0 return-object p0 .end method .method public static e1(Ljava/util/concurrent/Callable;Lph/o;Lph/g;)Lkh/a; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/Callable<", "TR;>;", "Lph/o<", "-TR;+", "Lkh/g;", ">;", "Lph/g<", "-TR;>;)", "Lkh/a;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const/4 v0, 0x1 .line 1 invoke-static {p0, p1, p2, v0}, Lkh/a;->f1(Ljava/util/concurrent/Callable;Lph/o;Lph/g;Z)Lkh/a; move-result-object p0 return-object p0 .end method .method public static varargs f([Lkh/g;)Lkh/a; .locals 2 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "sources is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 array-length v0, p0 if-nez v0, :cond_0 .line 3 invoke-static {}, Lkh/a;->s()Lkh/a; move-result-object p0 return-object p0 .line 4 :cond_0 array-length v0, p0 const/4 v1, 0x1 if-ne v0, v1, :cond_1 const/4 v0, 0x0 .line 5 aget-object p0, p0, v0 invoke-static {p0}, Lkh/a;->g1(Lkh/g;)Lkh/a; move-result-object p0 return-object p0 .line 6 :cond_1 new-instance v0, Lio/reactivex/internal/operators/completable/a; const/4 v1, 0x0 invoke-direct {v0, p0, v1}, Lio/reactivex/internal/operators/completable/a;->([Lkh/g;Ljava/lang/Iterable;)V invoke-static {v0}, Lwh/a;->O(Lkh/a;)Lkh/a; move-result-object p0 return-object p0 .end method .method public static f0(Lok/c;IZ)Lkh/a; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lok/c<", "+", "Lkh/g;", ">;IZ)", "Lkh/a;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "sources is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "maxConcurrency" .line 2 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->h(ILjava/lang/String;)I .line 3 new-instance v0, Lio/reactivex/internal/operators/completable/CompletableMerge; invoke-direct {v0, p0, p1, p2}, Lio/reactivex/internal/operators/completable/CompletableMerge;->(Lok/c;IZ)V invoke-static {v0}, Lwh/a;->O(Lkh/a;)Lkh/a; move-result-object p0 return-object p0 .end method .method public static f1(Ljava/util/concurrent/Callable;Lph/o;Lph/g;Z)Lkh/a; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/Callable<", "TR;>;", "Lph/o<", "-TR;+", "Lkh/g;", ">;", "Lph/g<", "-TR;>;Z)", "Lkh/a;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "resourceSupplier is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "completableFunction is null" .line 2 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "disposer is null" .line 3 invoke-static {p2, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 4 new-instance v0, Lio/reactivex/internal/operators/completable/CompletableUsing; invoke-direct {v0, p0, p1, p2, p3}, Lio/reactivex/internal/operators/completable/CompletableUsing;->(Ljava/util/concurrent/Callable;Lph/o;Lph/g;Z)V invoke-static {v0}, Lwh/a;->O(Lkh/a;)Lkh/a; move-result-object p0 return-object p0 .end method .method public static varargs g0([Lkh/g;)Lkh/a; .locals 2 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "sources is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 array-length v0, p0 if-nez v0, :cond_0 .line 3 invoke-static {}, Lkh/a;->s()Lkh/a; move-result-object p0 return-object p0 .line 4 :cond_0 array-length v0, p0 const/4 v1, 0x1 if-ne v0, v1, :cond_1 const/4 v0, 0x0 .line 5 aget-object p0, p0, v0 invoke-static {p0}, Lkh/a;->g1(Lkh/g;)Lkh/a; move-result-object p0 return-object p0 .line 6 :cond_1 new-instance v0, Lio/reactivex/internal/operators/completable/CompletableMergeArray; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/completable/CompletableMergeArray;->([Lkh/g;)V invoke-static {v0}, Lwh/a;->O(Lkh/a;)Lkh/a; move-result-object p0 return-object p0 .end method .method public static g1(Lkh/g;)Lkh/a; .locals 1 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "source is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 instance-of v0, p0, Lkh/a; if-eqz v0, :cond_0 .line 3 check-cast p0, Lkh/a; invoke-static {p0}, Lwh/a;->O(Lkh/a;)Lkh/a; move-result-object p0 return-object p0 .line 4 :cond_0 new-instance v0, Lio/reactivex/internal/operators/completable/o; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/completable/o;->(Lkh/g;)V invoke-static {v0}, Lwh/a;->O(Lkh/a;)Lkh/a; move-result-object p0 return-object p0 .end method .method public static varargs h0([Lkh/g;)Lkh/a; .locals 1 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "sources is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/completable/s; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/completable/s;->([Lkh/g;)V invoke-static {v0}, Lwh/a;->O(Lkh/a;)Lkh/a; move-result-object p0 return-object p0 .end method .method public static i0(Ljava/lang/Iterable;)Lkh/a; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Iterable<", "+", "Lkh/g;", ">;)", "Lkh/a;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "sources is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/completable/t; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/completable/t;->(Ljava/lang/Iterable;)V invoke-static {v0}, Lwh/a;->O(Lkh/a;)Lkh/a; move-result-object p0 return-object p0 .end method .method public static j0(Lok/c;)Lkh/a; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lok/c<", "+", "Lkh/g;", ">;)", "Lkh/a;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->UNBOUNDED_IN:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const v0, 0x7fffffff const/4 v1, 0x1 .line 1 invoke-static {p0, v0, v1}, Lkh/a;->f0(Lok/c;IZ)Lkh/a; move-result-object p0 return-object p0 .end method .method public static k0(Lok/c;I)Lkh/a; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lok/c<", "+", "Lkh/g;", ">;I)", "Lkh/a;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const/4 v0, 0x1 .line 1 invoke-static {p0, p1, v0}, Lkh/a;->f0(Lok/c;IZ)Lkh/a; move-result-object p0 return-object p0 .end method .method public static m0()Lkh/a; .locals 1 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 sget-object v0, Lio/reactivex/internal/operators/completable/u;->a:Lkh/a; invoke-static {v0}, Lwh/a;->O(Lkh/a;)Lkh/a; move-result-object v0 return-object v0 .end method .method public static s()Lkh/a; .locals 1 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 sget-object v0, Lio/reactivex/internal/operators/completable/f;->a:Lkh/a; invoke-static {v0}, Lwh/a;->O(Lkh/a;)Lkh/a; move-result-object v0 return-object v0 .end method .method public static u(Ljava/lang/Iterable;)Lkh/a; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Iterable<", "+", "Lkh/g;", ">;)", "Lkh/a;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "sources is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/completable/CompletableConcatIterable; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/completable/CompletableConcatIterable;->(Ljava/lang/Iterable;)V invoke-static {v0}, Lwh/a;->O(Lkh/a;)Lkh/a; move-result-object p0 return-object p0 .end method .method public static v(Lok/c;)Lkh/a; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lok/c<", "+", "Lkh/g;", ">;)", "Lkh/a;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const/4 v0, 0x2 .line 1 invoke-static {p0, v0}, Lkh/a;->w(Lok/c;I)Lkh/a; move-result-object p0 return-object p0 .end method .method public static w(Lok/c;I)Lkh/a; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lok/c<", "+", "Lkh/g;", ">;I)", "Lkh/a;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "sources is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "prefetch" .line 2 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->h(ILjava/lang/String;)I .line 3 new-instance v0, Lio/reactivex/internal/operators/completable/CompletableConcat; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/completable/CompletableConcat;->(Lok/c;I)V invoke-static {v0}, Lwh/a;->O(Lkh/a;)Lkh/a; move-result-object p0 return-object p0 .end method .method public static varargs x([Lkh/g;)Lkh/a; .locals 2 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "sources is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 array-length v0, p0 if-nez v0, :cond_0 .line 3 invoke-static {}, Lkh/a;->s()Lkh/a; move-result-object p0 return-object p0 .line 4 :cond_0 array-length v0, p0 const/4 v1, 0x1 if-ne v0, v1, :cond_1 const/4 v0, 0x0 .line 5 aget-object p0, p0, v0 invoke-static {p0}, Lkh/a;->g1(Lkh/g;)Lkh/a; move-result-object p0 return-object p0 .line 6 :cond_1 new-instance v0, Lio/reactivex/internal/operators/completable/CompletableConcatArray; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/completable/CompletableConcatArray;->([Lkh/g;)V invoke-static {v0}, Lwh/a;->O(Lkh/a;)Lkh/a; move-result-object p0 return-object p0 .end method .method public static z(Lkh/e;)Lkh/a; .locals 1 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "source is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/completable/CompletableCreate; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/completable/CompletableCreate;->(Lkh/e;)V invoke-static {v0}, Lwh/a;->O(Lkh/a;)Lkh/a; move-result-object p0 return-object p0 .end method # virtual methods .method public final A0(Lph/r;)Lkh/a; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/r<", "-", "Ljava/lang/Throwable;", ">;)", "Lkh/a;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-virtual {p0}, Lkh/a;->W0()Lkh/j; move-result-object v0 invoke-virtual {v0, p1}, Lkh/j;->n5(Lph/r;)Lkh/j; move-result-object p1 invoke-static {p1}, Lkh/a;->W(Lok/c;)Lkh/a; move-result-object p1 return-object p1 .end method .method public final B(JLjava/util/concurrent/TimeUnit;)Lkh/a; .locals 6 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "io.reactivex:computation" .end annotation .line 1 invoke-static {}, Lli/b;->a()Lkh/h0; move-result-object v4 const/4 v5, 0x0 move-object v0, p0 move-wide v1, p1 move-object v3, p3 invoke-virtual/range {v0 .. v5}, Lkh/a;->D(JLjava/util/concurrent/TimeUnit;Lkh/h0;Z)Lkh/a; move-result-object p1 return-object p1 .end method .method public final B0(Lph/o;)Lkh/a; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/o<", "-", "Lkh/j<", "Ljava/lang/Throwable;", ">;+", "Lok/c<", "*>;>;)", "Lkh/a;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-virtual {p0}, Lkh/a;->W0()Lkh/j; move-result-object v0 invoke-virtual {v0, p1}, Lkh/j;->p5(Lph/o;)Lkh/j; move-result-object p1 invoke-static {p1}, Lkh/a;->W(Lok/c;)Lkh/a; move-result-object p1 return-object p1 .end method .method public final C(JLjava/util/concurrent/TimeUnit;Lkh/h0;)Lkh/a; .locals 6 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "custom" .end annotation const/4 v5, 0x0 move-object v0, p0 move-wide v1, p1 move-object v3, p3 move-object v4, p4 .line 1 invoke-virtual/range {v0 .. v5}, Lkh/a;->D(JLjava/util/concurrent/TimeUnit;Lkh/h0;Z)Lkh/a; move-result-object p1 return-object p1 .end method .method public final C0(Lkh/g;)Lkh/a; .locals 2 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "other is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const/4 v0, 0x2 new-array v0, v0, [Lkh/g; const/4 v1, 0x0 aput-object p1, v0, v1 const/4 p1, 0x1 aput-object p0, v0, p1 .line 2 invoke-static {v0}, Lkh/a;->x([Lkh/g;)Lkh/a; move-result-object p1 return-object p1 .end method .method public final D(JLjava/util/concurrent/TimeUnit;Lkh/h0;Z)Lkh/a; .locals 8 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "custom" .end annotation const-string v0, "unit is null" .line 1 invoke-static {p3, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "scheduler is null" .line 2 invoke-static {p4, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 3 new-instance v0, Lio/reactivex/internal/operators/completable/CompletableDelay; move-object v1, v0 move-object v2, p0 move-wide v3, p1 move-object v5, p3 move-object v6, p4 move v7, p5 invoke-direct/range {v1 .. v7}, Lio/reactivex/internal/operators/completable/CompletableDelay;->(Lkh/g;JLjava/util/concurrent/TimeUnit;Lkh/h0;Z)V invoke-static {v0}, Lwh/a;->O(Lkh/a;)Lkh/a; move-result-object p1 return-object p1 .end method .method public final D0(Lok/c;)Lkh/j; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lok/c<", "TT;>;)", "Lkh/j<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "other is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 invoke-virtual {p0}, Lkh/a;->W0()Lkh/j; move-result-object v0 invoke-virtual {v0, p1}, Lkh/j;->Y5(Lok/c;)Lkh/j; move-result-object p1 return-object p1 .end method .method public final E(JLjava/util/concurrent/TimeUnit;)Lkh/a; .locals 1 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/Experimental; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "io.reactivex:computation" .end annotation .line 1 invoke-static {}, Lli/b;->a()Lkh/h0; move-result-object v0 invoke-virtual {p0, p1, p2, p3, v0}, Lkh/a;->F(JLjava/util/concurrent/TimeUnit;Lkh/h0;)Lkh/a; move-result-object p1 return-object p1 .end method .method public final E0(Lkh/z;)Lkh/z; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/z<", "TT;>;)", "Lkh/z<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "other is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 invoke-virtual {p0}, Lkh/a;->Z0()Lkh/z; move-result-object v0 invoke-virtual {p1, v0}, Lkh/z;->concatWith(Lkh/e0;)Lkh/z; move-result-object p1 return-object p1 .end method .method public final F(JLjava/util/concurrent/TimeUnit;Lkh/h0;)Lkh/a; .locals 0 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/Experimental; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "custom" .end annotation .line 1 invoke-static {p1, p2, p3, p4}, Lkh/a;->U0(JLjava/util/concurrent/TimeUnit;Lkh/h0;)Lkh/a; move-result-object p1 invoke-virtual {p1, p0}, Lkh/a;->h(Lkh/g;)Lkh/a; move-result-object p1 return-object p1 .end method .method public final F0()Lio/reactivex/disposables/b; .locals 1 .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 new-instance v0, Lio/reactivex/internal/observers/EmptyCompletableObserver; invoke-direct {v0}, Lio/reactivex/internal/observers/EmptyCompletableObserver;->()V .line 2 invoke-virtual {p0, v0}, Lkh/a;->d(Lkh/d;)V return-object v0 .end method .method public final G(Lph/a;)Lkh/a; .locals 7 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-static {}, Lio/reactivex/internal/functions/Functions;->h()Lph/g; move-result-object v1 .line 2 invoke-static {}, Lio/reactivex/internal/functions/Functions;->h()Lph/g; move-result-object v2 sget-object v6, Lio/reactivex/internal/functions/Functions;->c:Lph/a; move-object v0, p0 move-object v3, v6 move-object v4, v6 move-object v5, p1 .line 3 invoke-virtual/range {v0 .. v6}, Lkh/a;->M(Lph/g;Lph/g;Lph/a;Lph/a;Lph/a;Lph/a;)Lkh/a; move-result-object p1 return-object p1 .end method .method public final G0(Lph/a;)Lio/reactivex/disposables/b; .locals 1 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "onComplete is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/observers/CallbackCompletableObserver; invoke-direct {v0, p1}, Lio/reactivex/internal/observers/CallbackCompletableObserver;->(Lph/a;)V .line 3 invoke-virtual {p0, v0}, Lkh/a;->d(Lkh/d;)V return-object v0 .end method .method public final H(Lph/a;)Lkh/a; .locals 1 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "onFinally is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/completable/CompletableDoFinally; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/completable/CompletableDoFinally;->(Lkh/g;Lph/a;)V invoke-static {v0}, Lwh/a;->O(Lkh/a;)Lkh/a; move-result-object p1 return-object p1 .end method .method public final H0(Lph/a;Lph/g;)Lio/reactivex/disposables/b; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/a;", "Lph/g<", "-", "Ljava/lang/Throwable;", ">;)", "Lio/reactivex/disposables/b;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "onError is null" .line 1 invoke-static {p2, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "onComplete is null" .line 2 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 3 new-instance v0, Lio/reactivex/internal/observers/CallbackCompletableObserver; invoke-direct {v0, p2, p1}, Lio/reactivex/internal/observers/CallbackCompletableObserver;->(Lph/g;Lph/a;)V .line 4 invoke-virtual {p0, v0}, Lkh/a;->d(Lkh/d;)V return-object v0 .end method .method public final I(Lph/a;)Lkh/a; .locals 7 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-static {}, Lio/reactivex/internal/functions/Functions;->h()Lph/g; move-result-object v1 invoke-static {}, Lio/reactivex/internal/functions/Functions;->h()Lph/g; move-result-object v2 sget-object v6, Lio/reactivex/internal/functions/Functions;->c:Lph/a; move-object v0, p0 move-object v3, p1 move-object v4, v6 move-object v5, v6 invoke-virtual/range {v0 .. v6}, Lkh/a;->M(Lph/g;Lph/g;Lph/a;Lph/a;Lph/a;Lph/a;)Lkh/a; move-result-object p1 return-object p1 .end method .method public abstract I0(Lkh/d;)V .end method .method public final J(Lph/a;)Lkh/a; .locals 7 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-static {}, Lio/reactivex/internal/functions/Functions;->h()Lph/g; move-result-object v1 invoke-static {}, Lio/reactivex/internal/functions/Functions;->h()Lph/g; move-result-object v2 sget-object v5, Lio/reactivex/internal/functions/Functions;->c:Lph/a; move-object v0, p0 move-object v3, v5 move-object v4, v5 move-object v6, p1 invoke-virtual/range {v0 .. v6}, Lkh/a;->M(Lph/g;Lph/g;Lph/a;Lph/a;Lph/a;Lph/a;)Lkh/a; move-result-object p1 return-object p1 .end method .method public final J0(Lkh/h0;)Lkh/a; .locals 1 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "custom" .end annotation const-string v0, "scheduler is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/completable/CompletableSubscribeOn; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/completable/CompletableSubscribeOn;->(Lkh/g;Lkh/h0;)V invoke-static {v0}, Lwh/a;->O(Lkh/a;)Lkh/a; move-result-object p1 return-object p1 .end method .method public final K(Lph/g;)Lkh/a; .locals 7 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/g<", "-", "Ljava/lang/Throwable;", ">;)", "Lkh/a;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-static {}, Lio/reactivex/internal/functions/Functions;->h()Lph/g; move-result-object v1 sget-object v6, Lio/reactivex/internal/functions/Functions;->c:Lph/a; move-object v0, p0 move-object v2, p1 move-object v3, v6 move-object v4, v6 move-object v5, v6 invoke-virtual/range {v0 .. v6}, Lkh/a;->M(Lph/g;Lph/g;Lph/a;Lph/a;Lph/a;Lph/a;)Lkh/a; move-result-object p1 return-object p1 .end method .method public final K0(Lkh/d;)Lkh/d; .locals 0 .annotation system Ldalvik/annotation/Signature; value = { "(TE;)TE;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-virtual {p0, p1}, Lkh/a;->d(Lkh/d;)V return-object p1 .end method .method public final L(Lph/g;)Lkh/a; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/g<", "-", "Ljava/lang/Throwable;", ">;)", "Lkh/a;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "onEvent is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/completable/e; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/completable/e;->(Lkh/g;Lph/g;)V invoke-static {v0}, Lwh/a;->O(Lkh/a;)Lkh/a; move-result-object p1 return-object p1 .end method .method public final L0(Lkh/g;)Lkh/a; .locals 1 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "other is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/completable/CompletableTakeUntilCompletable; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/completable/CompletableTakeUntilCompletable;->(Lkh/a;Lkh/g;)V invoke-static {v0}, Lwh/a;->O(Lkh/a;)Lkh/a; move-result-object p1 return-object p1 .end method .method public final M(Lph/g;Lph/g;Lph/a;Lph/a;Lph/a;Lph/a;)Lkh/a; .locals 9 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/g<", "-", "Lio/reactivex/disposables/b;", ">;", "Lph/g<", "-", "Ljava/lang/Throwable;", ">;", "Lph/a;", "Lph/a;", "Lph/a;", "Lph/a;", ")", "Lkh/a;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "onSubscribe is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "onError is null" .line 2 invoke-static {p2, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "onComplete is null" .line 3 invoke-static {p3, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "onTerminate is null" .line 4 invoke-static {p4, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "onAfterTerminate is null" .line 5 invoke-static {p5, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "onDispose is null" .line 6 invoke-static {p6, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 7 new-instance v0, Lio/reactivex/internal/operators/completable/w; move-object v1, v0 move-object v2, p0 move-object v3, p1 move-object v4, p2 move-object v5, p3 move-object v6, p4 move-object v7, p5 move-object v8, p6 invoke-direct/range {v1 .. v8}, Lio/reactivex/internal/operators/completable/w;->(Lkh/g;Lph/g;Lph/g;Lph/a;Lph/a;Lph/a;Lph/a;)V invoke-static {v0}, Lwh/a;->O(Lkh/a;)Lkh/a; move-result-object p1 return-object p1 .end method .method public final M0()Lio/reactivex/observers/TestObserver; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Lio/reactivex/observers/TestObserver<", "Ljava/lang/Void;", ">;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 new-instance v0, Lio/reactivex/observers/TestObserver; invoke-direct {v0}, Lio/reactivex/observers/TestObserver;->()V .line 2 invoke-virtual {p0, v0}, Lkh/a;->d(Lkh/d;)V return-object v0 .end method .method public final N(Lph/g;)Lkh/a; .locals 7 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/g<", "-", "Lio/reactivex/disposables/b;", ">;)", "Lkh/a;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-static {}, Lio/reactivex/internal/functions/Functions;->h()Lph/g; move-result-object v2 sget-object v6, Lio/reactivex/internal/functions/Functions;->c:Lph/a; move-object v0, p0 move-object v1, p1 move-object v3, v6 move-object v4, v6 move-object v5, v6 invoke-virtual/range {v0 .. v6}, Lkh/a;->M(Lph/g;Lph/g;Lph/a;Lph/a;Lph/a;Lph/a;)Lkh/a; move-result-object p1 return-object p1 .end method .method public final N0(Z)Lio/reactivex/observers/TestObserver; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(Z)", "Lio/reactivex/observers/TestObserver<", "Ljava/lang/Void;", ">;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 new-instance v0, Lio/reactivex/observers/TestObserver; invoke-direct {v0}, Lio/reactivex/observers/TestObserver;->()V if-eqz p1, :cond_0 .line 2 invoke-virtual {v0}, Lio/reactivex/observers/TestObserver;->cancel()V .line 3 :cond_0 invoke-virtual {p0, v0}, Lkh/a;->d(Lkh/d;)V return-object v0 .end method .method public final O(Lph/a;)Lkh/a; .locals 7 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-static {}, Lio/reactivex/internal/functions/Functions;->h()Lph/g; move-result-object v1 invoke-static {}, Lio/reactivex/internal/functions/Functions;->h()Lph/g; move-result-object v2 sget-object v6, Lio/reactivex/internal/functions/Functions;->c:Lph/a; move-object v0, p0 move-object v3, v6 move-object v4, p1 move-object v5, v6 invoke-virtual/range {v0 .. v6}, Lkh/a;->M(Lph/g;Lph/g;Lph/a;Lph/a;Lph/a;Lph/a;)Lkh/a; move-result-object p1 return-object p1 .end method .method public final O0(JLjava/util/concurrent/TimeUnit;)Lkh/a; .locals 6 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "io.reactivex:computation" .end annotation .line 1 invoke-static {}, Lli/b;->a()Lkh/h0; move-result-object v4 const/4 v5, 0x0 move-object v0, p0 move-wide v1, p1 move-object v3, p3 invoke-virtual/range {v0 .. v5}, Lkh/a;->S0(JLjava/util/concurrent/TimeUnit;Lkh/h0;Lkh/g;)Lkh/a; move-result-object p1 return-object p1 .end method .method public final P0(JLjava/util/concurrent/TimeUnit;Lkh/g;)Lkh/a; .locals 7 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "io.reactivex:computation" .end annotation const-string v0, "other is null" .line 1 invoke-static {p4, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 invoke-static {}, Lli/b;->a()Lkh/h0; move-result-object v5 move-object v1, p0 move-wide v2, p1 move-object v4, p3 move-object v6, p4 invoke-virtual/range {v1 .. v6}, Lkh/a;->S0(JLjava/util/concurrent/TimeUnit;Lkh/h0;Lkh/g;)Lkh/a; move-result-object p1 return-object p1 .end method .method public final Q0(JLjava/util/concurrent/TimeUnit;Lkh/h0;)Lkh/a; .locals 6 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "custom" .end annotation const/4 v5, 0x0 move-object v0, p0 move-wide v1, p1 move-object v3, p3 move-object v4, p4 .line 1 invoke-virtual/range {v0 .. v5}, Lkh/a;->S0(JLjava/util/concurrent/TimeUnit;Lkh/h0;Lkh/g;)Lkh/a; move-result-object p1 return-object p1 .end method .method public final R0(JLjava/util/concurrent/TimeUnit;Lkh/h0;Lkh/g;)Lkh/a; .locals 1 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "custom" .end annotation const-string v0, "other is null" .line 1 invoke-static {p5, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 invoke-virtual/range {p0 .. p5}, Lkh/a;->S0(JLjava/util/concurrent/TimeUnit;Lkh/h0;Lkh/g;)Lkh/a; move-result-object p1 return-object p1 .end method .method public final S0(JLjava/util/concurrent/TimeUnit;Lkh/h0;Lkh/g;)Lkh/a; .locals 8 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "custom" .end annotation const-string v0, "unit is null" .line 1 invoke-static {p3, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "scheduler is null" .line 2 invoke-static {p4, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 3 new-instance v0, Lio/reactivex/internal/operators/completable/x; move-object v1, v0 move-object v2, p0 move-wide v3, p1 move-object v5, p3 move-object v6, p4 move-object v7, p5 invoke-direct/range {v1 .. v7}, Lio/reactivex/internal/operators/completable/x;->(Lkh/g;JLjava/util/concurrent/TimeUnit;Lkh/h0;Lkh/g;)V invoke-static {v0}, Lwh/a;->O(Lkh/a;)Lkh/a; move-result-object p1 return-object p1 .end method .method public final V0(Lph/o;)Ljava/lang/Object; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/o<", "-", "Lkh/a;", "TU;>;)TU;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation :try_start_0 const-string v0, "converter is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; move-result-object p1 check-cast p1, Lph/o; invoke-interface {p1, p0}, Lph/o;->apply(Ljava/lang/Object;)Ljava/lang/Object; move-result-object p1 :try_end_0 .catchall {:try_start_0 .. :try_end_0} :catchall_0 return-object p1 :catchall_0 move-exception p1 .line 2 invoke-static {p1}, Lio/reactivex/exceptions/a;->b(Ljava/lang/Throwable;)V .line 3 invoke-static {p1}, Lio/reactivex/internal/util/ExceptionHelper;->f(Ljava/lang/Throwable;)Ljava/lang/RuntimeException; move-result-object p1 throw p1 .end method .method public final W0()Lkh/j; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Lkh/j<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 instance-of v0, p0, Lrh/b; if-eqz v0, :cond_0 .line 2 move-object v0, p0 check-cast v0, Lrh/b; invoke-interface {v0}, Lrh/b;->c()Lkh/j; move-result-object v0 return-object v0 .line 3 :cond_0 new-instance v0, Lio/reactivex/internal/operators/completable/y; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/completable/y;->(Lkh/g;)V invoke-static {v0}, Lwh/a;->P(Lkh/j;)Lkh/j; move-result-object v0 return-object v0 .end method .method public final X0()Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Lkh/q<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 instance-of v0, p0, Lrh/c; if-eqz v0, :cond_0 .line 2 move-object v0, p0 check-cast v0, Lrh/c; invoke-interface {v0}, Lrh/c;->b()Lkh/q; move-result-object v0 return-object v0 .line 3 :cond_0 new-instance v0, Lio/reactivex/internal/operators/maybe/q; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/q;->(Lkh/g;)V invoke-static {v0}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object v0 return-object v0 .end method .method public final Z()Lkh/a; .locals 1 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 new-instance v0, Lio/reactivex/internal/operators/completable/p; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/completable/p;->(Lkh/g;)V invoke-static {v0}, Lwh/a;->O(Lkh/a;)Lkh/a; move-result-object v0 return-object v0 .end method .method public final Z0()Lkh/z; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Lkh/z<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 instance-of v0, p0, Lrh/d; if-eqz v0, :cond_0 .line 2 move-object v0, p0 check-cast v0, Lrh/d; invoke-interface {v0}, Lrh/d;->a()Lkh/z; move-result-object v0 return-object v0 .line 3 :cond_0 new-instance v0, Lio/reactivex/internal/operators/completable/z; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/completable/z;->(Lkh/g;)V invoke-static {v0}, Lwh/a;->R(Lkh/z;)Lkh/z; move-result-object v0 return-object v0 .end method .method public final a0(Lkh/f;)Lkh/a; .locals 1 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "onLift is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/completable/q; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/completable/q;->(Lkh/g;Lkh/f;)V invoke-static {v0}, Lwh/a;->O(Lkh/a;)Lkh/a; move-result-object p1 return-object p1 .end method .method public final a1(Ljava/util/concurrent/Callable;)Lkh/i0; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/Callable<", "+TT;>;)", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "completionValueSupplier is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/completable/a0; const/4 v1, 0x0 invoke-direct {v0, p0, p1, v1}, Lio/reactivex/internal/operators/completable/a0;->(Lkh/g;Ljava/util/concurrent/Callable;Ljava/lang/Object;)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object p1 return-object p1 .end method .method public final b0()Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Lkh/i0<", "Lkh/y<", "TT;>;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/Experimental; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 new-instance v0, Lio/reactivex/internal/operators/completable/r; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/completable/r;->(Lkh/a;)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object v0 return-object v0 .end method .method public final b1(Ljava/lang/Object;)Lkh/i0; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(TT;)", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "completionValue is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/completable/a0; const/4 v1, 0x0 invoke-direct {v0, p0, v1, p1}, Lio/reactivex/internal/operators/completable/a0;->(Lkh/g;Ljava/util/concurrent/Callable;Ljava/lang/Object;)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object p1 return-object p1 .end method .method public final d(Lkh/d;)V .locals 1 .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "s is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 :try_start_0 invoke-static {p0, p1}, Lwh/a;->d0(Lkh/a;Lkh/d;)Lkh/d; move-result-object p1 const-string v0, "The RxJavaPlugins.onSubscribe hook returned a null CompletableObserver. Please check the handler provided to RxJavaPlugins.setOnCompletableSubscribe for invalid null returns. Further reading: https://github.com/ReactiveX/RxJava/wiki/Plugins" .line 3 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 4 invoke-virtual {p0, p1}, Lkh/a;->I0(Lkh/d;)V :try_end_0 .catch Ljava/lang/NullPointerException; {:try_start_0 .. :try_end_0} :catch_0 .catchall {:try_start_0 .. :try_end_0} :catchall_0 return-void :catchall_0 move-exception p1 .line 5 invoke-static {p1}, Lio/reactivex/exceptions/a;->b(Ljava/lang/Throwable;)V .line 6 invoke-static {p1}, Lwh/a;->Y(Ljava/lang/Throwable;)V .line 7 invoke-static {p1}, Lkh/a;->Y0(Ljava/lang/Throwable;)Ljava/lang/NullPointerException; move-result-object p1 throw p1 :catch_0 move-exception p1 .line 8 throw p1 .end method .method public final d1(Lkh/h0;)Lkh/a; .locals 1 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "custom" .end annotation const-string v0, "scheduler is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/completable/d; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/completable/d;->(Lkh/g;Lkh/h0;)V invoke-static {v0}, Lwh/a;->O(Lkh/a;)Lkh/a; move-result-object p1 return-object p1 .end method .method public final g(Lkh/g;)Lkh/a; .locals 2 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "other is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const/4 v0, 0x2 new-array v0, v0, [Lkh/g; const/4 v1, 0x0 aput-object p0, v0, v1 const/4 v1, 0x1 aput-object p1, v0, v1 .line 2 invoke-static {v0}, Lkh/a;->f([Lkh/g;)Lkh/a; move-result-object p1 return-object p1 .end method .method public final h(Lkh/g;)Lkh/a; .locals 1 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "next is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/completable/CompletableAndThenCompletable; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/completable/CompletableAndThenCompletable;->(Lkh/g;Lkh/g;)V invoke-static {v0}, Lwh/a;->O(Lkh/a;)Lkh/a; move-result-object p1 return-object p1 .end method .method public final i(Lok/c;)Lkh/j; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lok/c<", "TT;>;)", "Lkh/j<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "next is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/mixed/CompletableAndThenPublisher; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/mixed/CompletableAndThenPublisher;->(Lkh/g;Lok/c;)V invoke-static {v0}, Lwh/a;->P(Lkh/j;)Lkh/j; move-result-object p1 return-object p1 .end method .method public final j(Lkh/w;)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/w<", "TT;>;)", "Lkh/q<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "next is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeDelayWithCompletable; invoke-direct {v0, p1, p0}, Lio/reactivex/internal/operators/maybe/MaybeDelayWithCompletable;->(Lkh/w;Lkh/g;)V invoke-static {v0}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object p1 return-object p1 .end method .method public final k(Lkh/e0;)Lkh/z; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/e0<", "TT;>;)", "Lkh/z<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "next is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/mixed/CompletableAndThenObservable; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/mixed/CompletableAndThenObservable;->(Lkh/g;Lkh/e0;)V invoke-static {v0}, Lwh/a;->R(Lkh/z;)Lkh/z; move-result-object p1 return-object p1 .end method .method public final l(Lkh/o0;)Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/o0<", "TT;>;)", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "next is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/single/SingleDelayWithCompletable; invoke-direct {v0, p1, p0}, Lio/reactivex/internal/operators/single/SingleDelayWithCompletable;->(Lkh/o0;Lkh/g;)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object p1 return-object p1 .end method .method public final l0(Lkh/g;)Lkh/a; .locals 2 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "other is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const/4 v0, 0x2 new-array v0, v0, [Lkh/g; const/4 v1, 0x0 aput-object p0, v0, v1 const/4 v1, 0x1 aput-object p1, v0, v1 .line 2 invoke-static {v0}, Lkh/a;->g0([Lkh/g;)Lkh/a; move-result-object p1 return-object p1 .end method .method public final m(Lkh/b;)Ljava/lang/Object; .locals 1 .param p1 # Lkh/b; .annotation build Lio/reactivex/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/b<", "+TR;>;)TR;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "converter is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; move-result-object p1 check-cast p1, Lkh/b; invoke-interface {p1, p0}, Lkh/b;->a(Lkh/a;)Ljava/lang/Object; move-result-object p1 return-object p1 .end method .method public final n()V .locals 1 .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 new-instance v0, Lsh/f; invoke-direct {v0}, Lsh/f;->()V .line 2 invoke-virtual {p0, v0}, Lkh/a;->d(Lkh/d;)V .line 3 invoke-virtual {v0}, Lsh/f;->b()Ljava/lang/Object; return-void .end method .method public final n0(Lkh/h0;)Lkh/a; .locals 1 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "custom" .end annotation const-string v0, "scheduler is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/completable/CompletableObserveOn; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/completable/CompletableObserveOn;->(Lkh/g;Lkh/h0;)V invoke-static {v0}, Lwh/a;->O(Lkh/a;)Lkh/a; move-result-object p1 return-object p1 .end method .method public final o(JLjava/util/concurrent/TimeUnit;)Z .locals 1 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "unit is null" .line 1 invoke-static {p3, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lsh/f; invoke-direct {v0}, Lsh/f;->()V .line 3 invoke-virtual {p0, v0}, Lkh/a;->d(Lkh/d;)V .line 4 invoke-virtual {v0, p1, p2, p3}, Lsh/f;->a(JLjava/util/concurrent/TimeUnit;)Z move-result p1 return p1 .end method .method public final o0()Lkh/a; .locals 1 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-static {}, Lio/reactivex/internal/functions/Functions;->c()Lph/r; move-result-object v0 invoke-virtual {p0, v0}, Lkh/a;->p0(Lph/r;)Lkh/a; move-result-object v0 return-object v0 .end method .method public final p()Ljava/lang/Throwable; .locals 1 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/Nullable; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 new-instance v0, Lsh/f; invoke-direct {v0}, Lsh/f;->()V .line 2 invoke-virtual {p0, v0}, Lkh/a;->d(Lkh/d;)V .line 3 invoke-virtual {v0}, Lsh/f;->d()Ljava/lang/Throwable; move-result-object v0 return-object v0 .end method .method public final p0(Lph/r;)Lkh/a; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/r<", "-", "Ljava/lang/Throwable;", ">;)", "Lkh/a;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "predicate is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/completable/v; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/completable/v;->(Lkh/g;Lph/r;)V invoke-static {v0}, Lwh/a;->O(Lkh/a;)Lkh/a; move-result-object p1 return-object p1 .end method .method public final q(JLjava/util/concurrent/TimeUnit;)Ljava/lang/Throwable; .locals 1 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/Nullable; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "unit is null" .line 1 invoke-static {p3, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lsh/f; invoke-direct {v0}, Lsh/f;->()V .line 3 invoke-virtual {p0, v0}, Lkh/a;->d(Lkh/d;)V .line 4 invoke-virtual {v0, p1, p2, p3}, Lsh/f;->e(JLjava/util/concurrent/TimeUnit;)Ljava/lang/Throwable; move-result-object p1 return-object p1 .end method .method public final q0(Lph/o;)Lkh/a; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/o<", "-", "Ljava/lang/Throwable;", "+", "Lkh/g;", ">;)", "Lkh/a;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "errorMapper is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/completable/CompletableResumeNext; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/completable/CompletableResumeNext;->(Lkh/g;Lph/o;)V invoke-static {v0}, Lwh/a;->O(Lkh/a;)Lkh/a; move-result-object p1 return-object p1 .end method .method public final r()Lkh/a; .locals 1 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 new-instance v0, Lio/reactivex/internal/operators/completable/CompletableCache; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/completable/CompletableCache;->(Lkh/g;)V invoke-static {v0}, Lwh/a;->O(Lkh/a;)Lkh/a; move-result-object v0 return-object v0 .end method .method public final r0()Lkh/a; .locals 1 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 new-instance v0, Lio/reactivex/internal/operators/completable/c; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/completable/c;->(Lkh/g;)V invoke-static {v0}, Lwh/a;->O(Lkh/a;)Lkh/a; move-result-object v0 return-object v0 .end method .method public final s0()Lkh/a; .locals 1 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-virtual {p0}, Lkh/a;->W0()Lkh/j; move-result-object v0 invoke-virtual {v0}, Lkh/j;->P4()Lkh/j; move-result-object v0 invoke-static {v0}, Lkh/a;->W(Lok/c;)Lkh/a; move-result-object v0 return-object v0 .end method .method public final t(Lkh/h;)Lkh/a; .locals 1 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "transformer is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; move-result-object p1 check-cast p1, Lkh/h; invoke-interface {p1, p0}, Lkh/h;->a(Lkh/a;)Lkh/g; move-result-object p1 invoke-static {p1}, Lkh/a;->g1(Lkh/g;)Lkh/a; move-result-object p1 return-object p1 .end method .method public final t0(J)Lkh/a; .locals 1 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-virtual {p0}, Lkh/a;->W0()Lkh/j; move-result-object v0 invoke-virtual {v0, p1, p2}, Lkh/j;->Q4(J)Lkh/j; move-result-object p1 invoke-static {p1}, Lkh/a;->W(Lok/c;)Lkh/a; move-result-object p1 return-object p1 .end method .method public final u0(Lph/e;)Lkh/a; .locals 1 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-virtual {p0}, Lkh/a;->W0()Lkh/j; move-result-object v0 invoke-virtual {v0, p1}, Lkh/j;->R4(Lph/e;)Lkh/j; move-result-object p1 invoke-static {p1}, Lkh/a;->W(Lok/c;)Lkh/a; move-result-object p1 return-object p1 .end method .method public final v0(Lph/o;)Lkh/a; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/o<", "-", "Lkh/j<", "Ljava/lang/Object;", ">;+", "Lok/c<", "*>;>;)", "Lkh/a;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-virtual {p0}, Lkh/a;->W0()Lkh/j; move-result-object v0 invoke-virtual {v0, p1}, Lkh/j;->S4(Lph/o;)Lkh/j; move-result-object p1 invoke-static {p1}, Lkh/a;->W(Lok/c;)Lkh/a; move-result-object p1 return-object p1 .end method .method public final w0()Lkh/a; .locals 1 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-virtual {p0}, Lkh/a;->W0()Lkh/j; move-result-object v0 invoke-virtual {v0}, Lkh/j;->j5()Lkh/j; move-result-object v0 invoke-static {v0}, Lkh/a;->W(Lok/c;)Lkh/a; move-result-object v0 return-object v0 .end method .method public final x0(J)Lkh/a; .locals 1 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-virtual {p0}, Lkh/a;->W0()Lkh/j; move-result-object v0 invoke-virtual {v0, p1, p2}, Lkh/j;->k5(J)Lkh/j; move-result-object p1 invoke-static {p1}, Lkh/a;->W(Lok/c;)Lkh/a; move-result-object p1 return-object p1 .end method .method public final y(Lkh/g;)Lkh/a; .locals 1 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "other is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/completable/CompletableAndThenCompletable; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/completable/CompletableAndThenCompletable;->(Lkh/g;Lkh/g;)V invoke-static {v0}, Lwh/a;->O(Lkh/a;)Lkh/a; move-result-object p1 return-object p1 .end method .method public final y0(JLph/r;)Lkh/a; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(J", "Lph/r<", "-", "Ljava/lang/Throwable;", ">;)", "Lkh/a;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-virtual {p0}, Lkh/a;->W0()Lkh/j; move-result-object v0 invoke-virtual {v0, p1, p2, p3}, Lkh/j;->l5(JLph/r;)Lkh/j; move-result-object p1 invoke-static {p1}, Lkh/a;->W(Lok/c;)Lkh/a; move-result-object p1 return-object p1 .end method .method public final z0(Lph/d;)Lkh/a; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/d<", "-", "Ljava/lang/Integer;", "-", "Ljava/lang/Throwable;", ">;)", "Lkh/a;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-virtual {p0}, Lkh/a;->W0()Lkh/j; move-result-object v0 invoke-virtual {v0, p1}, Lkh/j;->m5(Lph/d;)Lkh/j; move-result-object p1 invoke-static {p1}, Lkh/a;->W(Lok/c;)Lkh/a; move-result-object p1 return-object p1 .end method