.class public abstract Lai/a; .super Ljava/lang/Object; .source "Completable.java" # interfaces .implements Lai/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/lang/Iterable;)Lai/a; .locals 1 .param p0 # Ljava/lang/Iterable; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "sources" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Iterable<", "+", "Lai/g;", ">;)", "Lai/a;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-static {p0}, Lai/m;->l3(Ljava/lang/Iterable;)Lai/m; move-result-object p0 invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->k()Lci/o; move-result-object v0 invoke-virtual {p0, v0}, Lai/m;->c1(Lci/o;)Lai/a; move-result-object p0 return-object p0 .end method .method public static A1(Lai/g;)Lai/a; .locals 1 .param p0 # Lai/g; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "source" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "source is null" .line 1 invoke-static {p0, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 instance-of v0, p0, Lai/a; if-eqz v0, :cond_0 .line 3 check-cast p0, Lai/a; invoke-static {p0}, Lji/a;->O(Lai/a;)Lai/a; move-result-object p0 return-object p0 .line 4 :cond_0 new-instance v0, Lio/reactivex/rxjava3/internal/operators/completable/p; invoke-direct {v0, p0}, Lio/reactivex/rxjava3/internal/operators/completable/p;->(Lai/g;)V invoke-static {v0}, Lji/a;->O(Lai/a;)Lai/a; move-result-object p0 return-object p0 .end method .method public static B(Lok/c;)Lai/a; .locals 1 .param p0 # Lok/c; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "sources" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lok/c<", "+", "Lai/g;", ">;)", "Lai/a;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->FULL:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const/4 v0, 0x2 .line 1 invoke-static {p0, v0}, Lai/a;->C(Lok/c;I)Lai/a; move-result-object p0 return-object p0 .end method .method public static C(Lok/c;I)Lai/a; .locals 2 .param p0 # Lok/c; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0 } names = { "sources", "prefetch" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lok/c<", "+", "Lai/g;", ">;I)", "Lai/a;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->FULL:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-static {p0}, Lai/m;->p3(Lok/c;)Lai/m; move-result-object p0 invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->k()Lci/o; move-result-object v0 const/4 v1, 0x1 invoke-virtual {p0, v0, v1, p1}, Lai/m;->e1(Lci/o;ZI)Lai/a; move-result-object p0 return-object p0 .end method .method public static E(Lai/e;)Lai/a; .locals 1 .param p0 # Lai/e; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "source" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "source is null" .line 1 invoke-static {p0, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/rxjava3/internal/operators/completable/CompletableCreate; invoke-direct {v0, p0}, Lio/reactivex/rxjava3/internal/operators/completable/CompletableCreate;->(Lai/e;)V invoke-static {v0}, Lji/a;->O(Lai/a;)Lai/a; move-result-object p0 return-object p0 .end method .method public static F(Lci/s;)Lai/a; .locals 1 .param p0 # Lci/s; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "supplier" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/s<", "+", "Lai/g;", ">;)", "Lai/a;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "supplier is null" .line 1 invoke-static {p0, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/rxjava3/internal/operators/completable/b; invoke-direct {v0, p0}, Lio/reactivex/rxjava3/internal/operators/completable/b;->(Lci/s;)V invoke-static {v0}, Lji/a;->O(Lai/a;)Lai/a; move-result-object p0 return-object p0 .end method .method public static P0(Lai/g;Lai/g;)Lai/p0; .locals 2 .param p0 # Lai/g; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p1 # Lai/g; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0 } names = { "source1", "source2" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lai/g;", "Lai/g;", ")", "Lai/p0<", "Ljava/lang/Boolean;", ">;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "source1 is null" .line 1 invoke-static {p0, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source2 is null" .line 2 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const/4 v0, 0x2 new-array v0, v0, [Lai/g; const/4 v1, 0x0 aput-object p0, v0, v1 const/4 p0, 0x1 aput-object p1, v0, p0 .line 3 invoke-static {v0}, Lai/a;->p0([Lai/g;)Lai/a; move-result-object p0 sget-object p1, Ljava/lang/Boolean;->TRUE:Ljava/lang/Boolean; invoke-static {p1}, Lai/p0;->N0(Ljava/lang/Object;)Lai/p0; move-result-object p1 invoke-virtual {p0, p1}, Lai/a;->l(Lai/v0;)Lai/p0; move-result-object p0 return-object p0 .end method .method public static V(Lci/s;)Lai/a; .locals 1 .param p0 # Lci/s; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "supplier" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/s<", "+", "Ljava/lang/Throwable;", ">;)", "Lai/a;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "supplier is null" .line 1 invoke-static {p0, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/rxjava3/internal/operators/completable/h; invoke-direct {v0, p0}, Lio/reactivex/rxjava3/internal/operators/completable/h;->(Lci/s;)V invoke-static {v0}, Lji/a;->O(Lai/a;)Lai/a; move-result-object p0 return-object p0 .end method .method public static W(Ljava/lang/Throwable;)Lai/a; .locals 1 .param p0 # Ljava/lang/Throwable; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "throwable" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "throwable is null" .line 1 invoke-static {p0, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/rxjava3/internal/operators/completable/g; invoke-direct {v0, p0}, Lio/reactivex/rxjava3/internal/operators/completable/g;->(Ljava/lang/Throwable;)V invoke-static {v0}, Lji/a;->O(Lai/a;)Lai/a; move-result-object p0 return-object p0 .end method .method public static X(Lci/a;)Lai/a; .locals 1 .param p0 # Lci/a; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "action" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "action is null" .line 1 invoke-static {p0, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/rxjava3/internal/operators/completable/i; invoke-direct {v0, p0}, Lio/reactivex/rxjava3/internal/operators/completable/i;->(Lci/a;)V invoke-static {v0}, Lji/a;->O(Lai/a;)Lai/a; move-result-object p0 return-object p0 .end method .method public static Y(Ljava/util/concurrent/Callable;)Lai/a; .locals 1 .param p0 # Ljava/util/concurrent/Callable; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "callable" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/Callable<", "*>;)", "Lai/a;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "callable is null" .line 1 invoke-static {p0, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/rxjava3/internal/operators/completable/j; invoke-direct {v0, p0}, Lio/reactivex/rxjava3/internal/operators/completable/j;->(Ljava/util/concurrent/Callable;)V invoke-static {v0}, Lji/a;->O(Lai/a;)Lai/a; move-result-object p0 return-object p0 .end method .method public static Z(Ljava/util/concurrent/CompletionStage;)Lai/a; .locals 1 .param p0 # Ljava/util/concurrent/CompletionStage; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "stage" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/CompletionStage<", "*>;)", "Lai/a;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "stage is null" .line 1 invoke-static {p0, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/rxjava3/internal/jdk8/a; invoke-direct {v0, p0}, Lio/reactivex/rxjava3/internal/jdk8/a;->(Ljava/util/concurrent/CompletionStage;)V invoke-static {v0}, Lji/a;->O(Lai/a;)Lai/a; move-result-object p0 return-object p0 .end method .method public static a0(Ljava/util/concurrent/Future;)Lai/a; .locals 1 .param p0 # Ljava/util/concurrent/Future; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "future" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/Future<", "*>;)", "Lai/a;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "future is null" .line 1 invoke-static {p0, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 invoke-static {p0}, Lio/reactivex/rxjava3/internal/functions/Functions;->j(Ljava/util/concurrent/Future;)Lci/a; move-result-object p0 invoke-static {p0}, Lai/a;->X(Lci/a;)Lai/a; move-result-object p0 return-object p0 .end method .method public static b0(Lai/b0;)Lai/a; .locals 1 .param p0 # Lai/b0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "maybe" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lai/b0<", "TT;>;)", "Lai/a;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "maybe is null" .line 1 invoke-static {p0, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/rxjava3/internal/operators/maybe/a0; invoke-direct {v0, p0}, Lio/reactivex/rxjava3/internal/operators/maybe/a0;->(Lai/b0;)V invoke-static {v0}, Lji/a;->O(Lai/a;)Lai/a; move-result-object p0 return-object p0 .end method .method public static b1(Lok/c;)Lai/a; .locals 3 .param p0 # Lok/c; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "sources" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lok/c<", "+", "Lai/g;", ">;)", "Lai/a;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->UNBOUNDED_IN:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "sources is null" .line 1 invoke-static {p0, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/rxjava3/internal/operators/mixed/c; invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->k()Lci/o; move-result-object v1 const/4 v2, 0x0 invoke-direct {v0, p0, v1, v2}, Lio/reactivex/rxjava3/internal/operators/mixed/c;->(Lok/c;Lci/o;Z)V invoke-static {v0}, Lji/a;->O(Lai/a;)Lai/a; move-result-object p0 return-object p0 .end method .method public static c0(Lai/l0;)Lai/a; .locals 1 .param p0 # Lai/l0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "observable" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lai/l0<", "TT;>;)", "Lai/a;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "observable is null" .line 1 invoke-static {p0, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/rxjava3/internal/operators/completable/k; invoke-direct {v0, p0}, Lio/reactivex/rxjava3/internal/operators/completable/k;->(Lai/l0;)V invoke-static {v0}, Lji/a;->O(Lai/a;)Lai/a; move-result-object p0 return-object p0 .end method .method public static c1(Lok/c;)Lai/a; .locals 3 .param p0 # Lok/c; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "sources" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lok/c<", "+", "Lai/g;", ">;)", "Lai/a;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->UNBOUNDED_IN:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "sources is null" .line 1 invoke-static {p0, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/rxjava3/internal/operators/mixed/c; invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->k()Lci/o; move-result-object v1 const/4 v2, 0x1 invoke-direct {v0, p0, v1, v2}, Lio/reactivex/rxjava3/internal/operators/mixed/c;->(Lok/c;Lci/o;Z)V invoke-static {v0}, Lji/a;->O(Lai/a;)Lai/a; move-result-object p0 return-object p0 .end method .method public static d0(Lok/c;)Lai/a; .locals 1 .param p0 # Lok/c; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "publisher" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lok/c<", "TT;>;)", "Lai/a;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->UNBOUNDED_IN:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "publisher is null" .line 1 invoke-static {p0, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/rxjava3/internal/operators/completable/l; invoke-direct {v0, p0}, Lio/reactivex/rxjava3/internal/operators/completable/l;->(Lok/c;)V invoke-static {v0}, Lji/a;->O(Lai/a;)Lai/a; move-result-object p0 return-object p0 .end method .method public static e(Ljava/lang/Iterable;)Lai/a; .locals 2 .param p0 # Ljava/lang/Iterable; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "sources" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Iterable<", "+", "Lai/g;", ">;)", "Lai/a;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "sources is null" .line 1 invoke-static {p0, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/rxjava3/internal/operators/completable/a; const/4 v1, 0x0 invoke-direct {v0, v1, p0}, Lio/reactivex/rxjava3/internal/operators/completable/a;->([Lai/g;Ljava/lang/Iterable;)V invoke-static {v0}, Lji/a;->O(Lai/a;)Lai/a; move-result-object p0 return-object p0 .end method .method public static e0(Ljava/lang/Runnable;)Lai/a; .locals 1 .param p0 # Ljava/lang/Runnable; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "run" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "run is null" .line 1 invoke-static {p0, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/rxjava3/internal/operators/completable/m; invoke-direct {v0, p0}, Lio/reactivex/rxjava3/internal/operators/completable/m;->(Ljava/lang/Runnable;)V invoke-static {v0}, Lji/a;->O(Lai/a;)Lai/a; move-result-object p0 return-object p0 .end method .method public static varargs f([Lai/g;)Lai/a; .locals 2 .param p0 # [Lai/g; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "sources" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation .annotation runtime Ljava/lang/SafeVarargs; .end annotation const-string v0, "sources is null" .line 1 invoke-static {p0, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 array-length v0, p0 if-nez v0, :cond_0 .line 3 invoke-static {}, Lai/a;->t()Lai/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}, Lai/a;->A1(Lai/g;)Lai/a; move-result-object p0 return-object p0 .line 6 :cond_1 new-instance v0, Lio/reactivex/rxjava3/internal/operators/completable/a; const/4 v1, 0x0 invoke-direct {v0, p0, v1}, Lio/reactivex/rxjava3/internal/operators/completable/a;->([Lai/g;Ljava/lang/Iterable;)V invoke-static {v0}, Lji/a;->O(Lai/a;)Lai/a; move-result-object p0 return-object p0 .end method .method public static f0(Lai/v0;)Lai/a; .locals 1 .param p0 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "single" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lai/v0<", "TT;>;)", "Lai/a;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "single is null" .line 1 invoke-static {p0, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/rxjava3/internal/operators/completable/n; invoke-direct {v0, p0}, Lio/reactivex/rxjava3/internal/operators/completable/n;->(Lai/v0;)V invoke-static {v0}, Lji/a;->O(Lai/a;)Lai/a; move-result-object p0 return-object p0 .end method .method public static g0(Lci/s;)Lai/a; .locals 1 .param p0 # Lci/s; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "supplier" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/s<", "*>;)", "Lai/a;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "supplier is null" .line 1 invoke-static {p0, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/rxjava3/internal/operators/completable/o; invoke-direct {v0, p0}, Lio/reactivex/rxjava3/internal/operators/completable/o;->(Lci/s;)V invoke-static {v0}, Lji/a;->O(Lai/a;)Lai/a; move-result-object p0 return-object p0 .end method .method public static k0(Ljava/lang/Iterable;)Lai/a; .locals 1 .param p0 # Ljava/lang/Iterable; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "sources" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Iterable<", "+", "Lai/g;", ">;)", "Lai/a;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "sources is null" .line 1 invoke-static {p0, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/rxjava3/internal/operators/completable/CompletableMergeIterable; invoke-direct {v0, p0}, Lio/reactivex/rxjava3/internal/operators/completable/CompletableMergeIterable;->(Ljava/lang/Iterable;)V invoke-static {v0}, Lji/a;->O(Lai/a;)Lai/a; move-result-object p0 return-object p0 .end method .method public static l0(Lok/c;)Lai/a; .locals 2 .param p0 # Lok/c; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "sources" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lok/c<", "+", "Lai/g;", ">;)", "Lai/a;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->UNBOUNDED_IN:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const v0, 0x7fffffff const/4 v1, 0x0 .line 1 invoke-static {p0, v0, v1}, Lai/a;->n0(Lok/c;IZ)Lai/a; move-result-object p0 return-object p0 .end method .method public static l1(JLjava/util/concurrent/TimeUnit;)Lai/a; .locals 1 .param p2 # Ljava/util/concurrent/TimeUnit; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0 } names = { "delay", "unit" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "io.reactivex:computation" .end annotation .line 1 invoke-static {}, Lki/b;->a()Lai/o0; move-result-object v0 invoke-static {p0, p1, p2, v0}, Lai/a;->m1(JLjava/util/concurrent/TimeUnit;Lai/o0;)Lai/a; move-result-object p0 return-object p0 .end method .method public static m0(Lok/c;I)Lai/a; .locals 1 .param p0 # Lok/c; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0 } names = { "sources", "maxConcurrency" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lok/c<", "+", "Lai/g;", ">;I)", "Lai/a;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->FULL:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const/4 v0, 0x0 .line 1 invoke-static {p0, p1, v0}, Lai/a;->n0(Lok/c;IZ)Lai/a; move-result-object p0 return-object p0 .end method .method public static m1(JLjava/util/concurrent/TimeUnit;Lai/o0;)Lai/a; .locals 1 .param p2 # Ljava/util/concurrent/TimeUnit; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p3 # Lai/o0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0, 0x0 } names = { "delay", "unit", "scheduler" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "custom" .end annotation const-string v0, "unit is null" .line 1 invoke-static {p2, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "scheduler is null" .line 2 invoke-static {p3, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 3 new-instance v0, Lio/reactivex/rxjava3/internal/operators/completable/CompletableTimer; invoke-direct {v0, p0, p1, p2, p3}, Lio/reactivex/rxjava3/internal/operators/completable/CompletableTimer;->(JLjava/util/concurrent/TimeUnit;Lai/o0;)V invoke-static {v0}, Lji/a;->O(Lai/a;)Lai/a; move-result-object p0 return-object p0 .end method .method public static n0(Lok/c;IZ)Lai/a; .locals 1 .param p0 # Lok/c; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0, 0x0 } names = { "sources", "maxConcurrency", "delayErrors" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lok/c<", "+", "Lai/g;", ">;IZ)", "Lai/a;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->FULL:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "sources is null" .line 1 invoke-static {p0, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "maxConcurrency" .line 2 invoke-static {p1, v0}, Lio/reactivex/rxjava3/internal/functions/a;->b(ILjava/lang/String;)I .line 3 new-instance v0, Lio/reactivex/rxjava3/internal/operators/completable/CompletableMerge; invoke-direct {v0, p0, p1, p2}, Lio/reactivex/rxjava3/internal/operators/completable/CompletableMerge;->(Lok/c;IZ)V invoke-static {v0}, Lji/a;->O(Lai/a;)Lai/a; move-result-object p0 return-object p0 .end method .method public static varargs o0([Lai/g;)Lai/a; .locals 2 .param p0 # [Lai/g; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "sources" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation .annotation runtime Ljava/lang/SafeVarargs; .end annotation const-string v0, "sources is null" .line 1 invoke-static {p0, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 array-length v0, p0 if-nez v0, :cond_0 .line 3 invoke-static {}, Lai/a;->t()Lai/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}, Lai/a;->A1(Lai/g;)Lai/a; move-result-object p0 return-object p0 .line 6 :cond_1 new-instance v0, Lio/reactivex/rxjava3/internal/operators/completable/CompletableMergeArray; invoke-direct {v0, p0}, Lio/reactivex/rxjava3/internal/operators/completable/CompletableMergeArray;->([Lai/g;)V invoke-static {v0}, Lji/a;->O(Lai/a;)Lai/a; move-result-object p0 return-object p0 .end method .method public static varargs p0([Lai/g;)Lai/a; .locals 1 .param p0 # [Lai/g; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "sources" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation .annotation runtime Ljava/lang/SafeVarargs; .end annotation const-string v0, "sources is null" .line 1 invoke-static {p0, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/rxjava3/internal/operators/completable/t; invoke-direct {v0, p0}, Lio/reactivex/rxjava3/internal/operators/completable/t;->([Lai/g;)V invoke-static {v0}, Lji/a;->O(Lai/a;)Lai/a; move-result-object p0 return-object p0 .end method .method public static q0(Ljava/lang/Iterable;)Lai/a; .locals 1 .param p0 # Ljava/lang/Iterable; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "sources" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Iterable<", "+", "Lai/g;", ">;)", "Lai/a;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "sources is null" .line 1 invoke-static {p0, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/rxjava3/internal/operators/completable/u; invoke-direct {v0, p0}, Lio/reactivex/rxjava3/internal/operators/completable/u;->(Ljava/lang/Iterable;)V invoke-static {v0}, Lji/a;->O(Lai/a;)Lai/a; move-result-object p0 return-object p0 .end method .method public static r0(Lok/c;)Lai/a; .locals 2 .param p0 # Lok/c; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "sources" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lok/c<", "+", "Lai/g;", ">;)", "Lai/a;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->UNBOUNDED_IN:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const v0, 0x7fffffff const/4 v1, 0x1 .line 1 invoke-static {p0, v0, v1}, Lai/a;->n0(Lok/c;IZ)Lai/a; move-result-object p0 return-object p0 .end method .method public static s0(Lok/c;I)Lai/a; .locals 1 .param p0 # Lok/c; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0 } names = { "sources", "maxConcurrency" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lok/c<", "+", "Lai/g;", ">;I)", "Lai/a;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->FULL:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const/4 v0, 0x1 .line 1 invoke-static {p0, p1, v0}, Lai/a;->n0(Lok/c;IZ)Lai/a; move-result-object p0 return-object p0 .end method .method public static s1(Ljava/lang/Throwable;)Ljava/lang/NullPointerException; .locals 2 .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "ex" } .end annotation .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 t()Lai/a; .locals 1 .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation .line 1 sget-object v0, Lio/reactivex/rxjava3/internal/operators/completable/f;->a:Lai/a; invoke-static {v0}, Lji/a;->O(Lai/a;)Lai/a; move-result-object v0 return-object v0 .end method .method public static u0()Lai/a; .locals 1 .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation .line 1 sget-object v0, Lio/reactivex/rxjava3/internal/operators/completable/v;->a:Lai/a; invoke-static {v0}, Lji/a;->O(Lai/a;)Lai/a; move-result-object v0 return-object v0 .end method .method public static v(Ljava/lang/Iterable;)Lai/a; .locals 1 .param p0 # Ljava/lang/Iterable; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "sources" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Iterable<", "+", "Lai/g;", ">;)", "Lai/a;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "sources is null" .line 1 invoke-static {p0, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/rxjava3/internal/operators/completable/CompletableConcatIterable; invoke-direct {v0, p0}, Lio/reactivex/rxjava3/internal/operators/completable/CompletableConcatIterable;->(Ljava/lang/Iterable;)V invoke-static {v0}, Lji/a;->O(Lai/a;)Lai/a; move-result-object p0 return-object p0 .end method .method public static w(Lok/c;)Lai/a; .locals 1 .param p0 # Lok/c; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "sources" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lok/c<", "+", "Lai/g;", ">;)", "Lai/a;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->FULL:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const/4 v0, 0x2 .line 1 invoke-static {p0, v0}, Lai/a;->x(Lok/c;I)Lai/a; move-result-object p0 return-object p0 .end method .method public static w1(Lai/g;)Lai/a; .locals 1 .param p0 # Lai/g; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "onSubscribe" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "onSubscribe is null" .line 1 invoke-static {p0, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 instance-of v0, p0, Lai/a; if-nez v0, :cond_0 .line 3 new-instance v0, Lio/reactivex/rxjava3/internal/operators/completable/p; invoke-direct {v0, p0}, Lio/reactivex/rxjava3/internal/operators/completable/p;->(Lai/g;)V invoke-static {v0}, Lji/a;->O(Lai/a;)Lai/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 x(Lok/c;I)Lai/a; .locals 1 .param p0 # Lok/c; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0 } names = { "sources", "prefetch" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lok/c<", "+", "Lai/g;", ">;I)", "Lai/a;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->FULL:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "sources is null" .line 1 invoke-static {p0, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "prefetch" .line 2 invoke-static {p1, v0}, Lio/reactivex/rxjava3/internal/functions/a;->b(ILjava/lang/String;)I .line 3 new-instance v0, Lio/reactivex/rxjava3/internal/operators/completable/CompletableConcat; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/operators/completable/CompletableConcat;->(Lok/c;I)V invoke-static {v0}, Lji/a;->O(Lai/a;)Lai/a; move-result-object p0 return-object p0 .end method .method public static varargs y([Lai/g;)Lai/a; .locals 2 .param p0 # [Lai/g; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "sources" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation .annotation runtime Ljava/lang/SafeVarargs; .end annotation const-string v0, "sources is null" .line 1 invoke-static {p0, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 array-length v0, p0 if-nez v0, :cond_0 .line 3 invoke-static {}, Lai/a;->t()Lai/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}, Lai/a;->A1(Lai/g;)Lai/a; move-result-object p0 return-object p0 .line 6 :cond_1 new-instance v0, Lio/reactivex/rxjava3/internal/operators/completable/CompletableConcatArray; invoke-direct {v0, p0}, Lio/reactivex/rxjava3/internal/operators/completable/CompletableConcatArray;->([Lai/g;)V invoke-static {v0}, Lji/a;->O(Lai/a;)Lai/a; move-result-object p0 return-object p0 .end method .method public static y1(Lci/s;Lci/o;Lci/g;)Lai/a; .locals 1 .param p0 # Lci/s; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p1 # Lci/o; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p2 # Lci/g; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0, 0x0 } names = { "resourceSupplier", "sourceSupplier", "resourceCleanup" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/s<", "TR;>;", "Lci/o<", "-TR;+", "Lai/g;", ">;", "Lci/g<", "-TR;>;)", "Lai/a;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const/4 v0, 0x1 .line 1 invoke-static {p0, p1, p2, v0}, Lai/a;->z1(Lci/s;Lci/o;Lci/g;Z)Lai/a; move-result-object p0 return-object p0 .end method .method public static varargs z([Lai/g;)Lai/a; .locals 3 .param p0 # [Lai/g; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "sources" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation .annotation runtime Ljava/lang/SafeVarargs; .end annotation .line 1 invoke-static {p0}, Lai/m;->f3([Ljava/lang/Object;)Lai/m; move-result-object p0 invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->k()Lci/o; move-result-object v0 const/4 v1, 0x1 const/4 v2, 0x2 invoke-virtual {p0, v0, v1, v2}, Lai/m;->e1(Lci/o;ZI)Lai/a; move-result-object p0 return-object p0 .end method .method public static z1(Lci/s;Lci/o;Lci/g;Z)Lai/a; .locals 1 .param p0 # Lci/s; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p1 # Lci/o; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p2 # Lci/g; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0, 0x0, 0x0 } names = { "resourceSupplier", "sourceSupplier", "resourceCleanup", "eager" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/s<", "TR;>;", "Lci/o<", "-TR;+", "Lai/g;", ">;", "Lci/g<", "-TR;>;Z)", "Lai/a;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "resourceSupplier is null" .line 1 invoke-static {p0, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "sourceSupplier is null" .line 2 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "resourceCleanup is null" .line 3 invoke-static {p2, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 4 new-instance v0, Lio/reactivex/rxjava3/internal/operators/completable/CompletableUsing; invoke-direct {v0, p0, p1, p2, p3}, Lio/reactivex/rxjava3/internal/operators/completable/CompletableUsing;->(Lci/s;Lci/o;Lci/g;Z)V invoke-static {v0}, Lji/a;->O(Lai/a;)Lai/a; move-result-object p0 return-object p0 .end method # virtual methods .method public final A0(Lci/o;)Lai/v; .locals 1 .param p1 # Lci/o; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "itemSupplier" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/o<", "-", "Ljava/lang/Throwable;", "+TT;>;)", "Lai/v<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "itemSupplier is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/rxjava3/internal/operators/completable/x; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/operators/completable/x;->(Lai/g;Lci/o;)V invoke-static {v0}, Lji/a;->Q(Lai/v;)Lai/v; move-result-object p1 return-object p1 .end method .method public final B0(Ljava/lang/Object;)Lai/v; .locals 1 .param p1 # Ljava/lang/Object; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "item" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(TT;)", "Lai/v<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "item is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 invoke-static {p1}, Lio/reactivex/rxjava3/internal/functions/Functions;->n(Ljava/lang/Object;)Lci/o; move-result-object p1 invoke-virtual {p0, p1}, Lai/a;->A0(Lci/o;)Lai/v; move-result-object p1 return-object p1 .end method .method public final C0()Lai/a; .locals 1 .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation .line 1 new-instance v0, Lio/reactivex/rxjava3/internal/operators/completable/c; invoke-direct {v0, p0}, Lio/reactivex/rxjava3/internal/operators/completable/c;->(Lai/g;)V invoke-static {v0}, Lji/a;->O(Lai/a;)Lai/a; move-result-object v0 return-object v0 .end method .method public final D(Lai/g;)Lai/a; .locals 1 .param p1 # Lai/g; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "other" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "other is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/rxjava3/internal/operators/completable/CompletableAndThenCompletable; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/operators/completable/CompletableAndThenCompletable;->(Lai/g;Lai/g;)V invoke-static {v0}, Lji/a;->O(Lai/a;)Lai/a; move-result-object p1 return-object p1 .end method .method public final D0()Lai/a; .locals 1 .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-virtual {p0}, Lai/a;->p1()Lai/m; move-result-object v0 invoke-virtual {v0}, Lai/m;->r5()Lai/m; move-result-object v0 invoke-static {v0}, Lai/a;->d0(Lok/c;)Lai/a; move-result-object v0 return-object v0 .end method .method public final E0(J)Lai/a; .locals 1 .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "times" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-virtual {p0}, Lai/a;->p1()Lai/m; move-result-object v0 invoke-virtual {v0, p1, p2}, Lai/m;->s5(J)Lai/m; move-result-object p1 invoke-static {p1}, Lai/a;->d0(Lok/c;)Lai/a; move-result-object p1 return-object p1 .end method .method public final F0(Lci/e;)Lai/a; .locals 1 .param p1 # Lci/e; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "stop" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-virtual {p0}, Lai/a;->p1()Lai/m; move-result-object v0 invoke-virtual {v0, p1}, Lai/m;->t5(Lci/e;)Lai/m; move-result-object p1 invoke-static {p1}, Lai/a;->d0(Lok/c;)Lai/a; move-result-object p1 return-object p1 .end method .method public final G(JLjava/util/concurrent/TimeUnit;)Lai/a; .locals 6 .param p3 # Ljava/util/concurrent/TimeUnit; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0 } names = { "time", "unit" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "io.reactivex:computation" .end annotation .line 1 invoke-static {}, Lki/b;->a()Lai/o0; 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}, Lai/a;->I(JLjava/util/concurrent/TimeUnit;Lai/o0;Z)Lai/a; move-result-object p1 return-object p1 .end method .method public final G0(Lci/o;)Lai/a; .locals 1 .param p1 # Lci/o; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "handler" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/o<", "-", "Lai/m<", "Ljava/lang/Object;", ">;+", "Lok/c<", "*>;>;)", "Lai/a;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-virtual {p0}, Lai/a;->p1()Lai/m; move-result-object v0 invoke-virtual {v0, p1}, Lai/m;->u5(Lci/o;)Lai/m; move-result-object p1 invoke-static {p1}, Lai/a;->d0(Lok/c;)Lai/a; move-result-object p1 return-object p1 .end method .method public final H(JLjava/util/concurrent/TimeUnit;Lai/o0;)Lai/a; .locals 6 .param p3 # Ljava/util/concurrent/TimeUnit; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p4 # Lai/o0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0, 0x0 } names = { "time", "unit", "scheduler" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/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}, Lai/a;->I(JLjava/util/concurrent/TimeUnit;Lai/o0;Z)Lai/a; move-result-object p1 return-object p1 .end method .method public final H0()Lai/a; .locals 1 .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-virtual {p0}, Lai/a;->p1()Lai/m; move-result-object v0 invoke-virtual {v0}, Lai/m;->N5()Lai/m; move-result-object v0 invoke-static {v0}, Lai/a;->d0(Lok/c;)Lai/a; move-result-object v0 return-object v0 .end method .method public final I(JLjava/util/concurrent/TimeUnit;Lai/o0;Z)Lai/a; .locals 8 .param p3 # Ljava/util/concurrent/TimeUnit; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p4 # Lai/o0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0, 0x0, 0x0 } names = { "time", "unit", "scheduler", "delayError" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "custom" .end annotation const-string v0, "unit is null" .line 1 invoke-static {p3, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "scheduler is null" .line 2 invoke-static {p4, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 3 new-instance v0, Lio/reactivex/rxjava3/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/rxjava3/internal/operators/completable/CompletableDelay;->(Lai/g;JLjava/util/concurrent/TimeUnit;Lai/o0;Z)V invoke-static {v0}, Lji/a;->O(Lai/a;)Lai/a; move-result-object p1 return-object p1 .end method .method public final I0(J)Lai/a; .locals 1 .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "times" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-virtual {p0}, Lai/a;->p1()Lai/m; move-result-object v0 invoke-virtual {v0, p1, p2}, Lai/m;->O5(J)Lai/m; move-result-object p1 invoke-static {p1}, Lai/a;->d0(Lok/c;)Lai/a; move-result-object p1 return-object p1 .end method .method public final J(JLjava/util/concurrent/TimeUnit;)Lai/a; .locals 1 .param p3 # Ljava/util/concurrent/TimeUnit; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0 } names = { "time", "unit" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "io.reactivex:computation" .end annotation .line 1 invoke-static {}, Lki/b;->a()Lai/o0; move-result-object v0 invoke-virtual {p0, p1, p2, p3, v0}, Lai/a;->K(JLjava/util/concurrent/TimeUnit;Lai/o0;)Lai/a; move-result-object p1 return-object p1 .end method .method public final J0(JLci/r;)Lai/a; .locals 1 .param p3 # Lci/r; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0 } names = { "times", "predicate" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(J", "Lci/r<", "-", "Ljava/lang/Throwable;", ">;)", "Lai/a;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-virtual {p0}, Lai/a;->p1()Lai/m; move-result-object v0 invoke-virtual {v0, p1, p2, p3}, Lai/m;->P5(JLci/r;)Lai/m; move-result-object p1 invoke-static {p1}, Lai/a;->d0(Lok/c;)Lai/a; move-result-object p1 return-object p1 .end method .method public final K(JLjava/util/concurrent/TimeUnit;Lai/o0;)Lai/a; .locals 0 .param p3 # Ljava/util/concurrent/TimeUnit; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p4 # Lai/o0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0, 0x0 } names = { "time", "unit", "scheduler" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "custom" .end annotation .line 1 invoke-static {p1, p2, p3, p4}, Lai/a;->m1(JLjava/util/concurrent/TimeUnit;Lai/o0;)Lai/a; move-result-object p1 invoke-virtual {p1, p0}, Lai/a;->h(Lai/g;)Lai/a; move-result-object p1 return-object p1 .end method .method public final K0(Lci/d;)Lai/a; .locals 1 .param p1 # Lci/d; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "predicate" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/d<", "-", "Ljava/lang/Integer;", "-", "Ljava/lang/Throwable;", ">;)", "Lai/a;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-virtual {p0}, Lai/a;->p1()Lai/m; move-result-object v0 invoke-virtual {v0, p1}, Lai/m;->Q5(Lci/d;)Lai/m; move-result-object p1 invoke-static {p1}, Lai/a;->d0(Lok/c;)Lai/a; move-result-object p1 return-object p1 .end method .method public final L(Lci/a;)Lai/a; .locals 7 .param p1 # Lci/a; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "onAfterTerminate" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->h()Lci/g; move-result-object v1 .line 2 invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->h()Lci/g; move-result-object v2 sget-object v6, Lio/reactivex/rxjava3/internal/functions/Functions;->c:Lci/a; move-object v0, p0 move-object v3, v6 move-object v4, v6 move-object v5, p1 .line 3 invoke-virtual/range {v0 .. v6}, Lai/a;->S(Lci/g;Lci/g;Lci/a;Lci/a;Lci/a;Lci/a;)Lai/a; move-result-object p1 return-object p1 .end method .method public final L0(Lci/r;)Lai/a; .locals 1 .param p1 # Lci/r; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "predicate" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/r<", "-", "Ljava/lang/Throwable;", ">;)", "Lai/a;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-virtual {p0}, Lai/a;->p1()Lai/m; move-result-object v0 invoke-virtual {v0, p1}, Lai/m;->R5(Lci/r;)Lai/m; move-result-object p1 invoke-static {p1}, Lai/a;->d0(Lok/c;)Lai/a; move-result-object p1 return-object p1 .end method .method public final M(Lci/a;)Lai/a; .locals 1 .param p1 # Lci/a; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "onFinally" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "onFinally is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/rxjava3/internal/operators/completable/CompletableDoFinally; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/operators/completable/CompletableDoFinally;->(Lai/g;Lci/a;)V invoke-static {v0}, Lji/a;->O(Lai/a;)Lai/a; move-result-object p1 return-object p1 .end method .method public final M0(Lci/e;)Lai/a; .locals 2 .param p1 # Lci/e; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "stop" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "stop is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 invoke-static {p1}, Lio/reactivex/rxjava3/internal/functions/Functions;->v(Lci/e;)Lci/r; move-result-object p1 const-wide v0, 0x7fffffffffffffffL invoke-virtual {p0, v0, v1, p1}, Lai/a;->J0(JLci/r;)Lai/a; move-result-object p1 return-object p1 .end method .method public final N(Lci/a;)Lai/a; .locals 7 .param p1 # Lci/a; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "onComplete" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->h()Lci/g; move-result-object v1 invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->h()Lci/g; move-result-object v2 sget-object v6, Lio/reactivex/rxjava3/internal/functions/Functions;->c:Lci/a; move-object v0, p0 move-object v3, p1 move-object v4, v6 move-object v5, v6 invoke-virtual/range {v0 .. v6}, Lai/a;->S(Lci/g;Lci/g;Lci/a;Lci/a;Lci/a;Lci/a;)Lai/a; move-result-object p1 return-object p1 .end method .method public final N0(Lci/o;)Lai/a; .locals 1 .param p1 # Lci/o; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "handler" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/o<", "-", "Lai/m<", "Ljava/lang/Throwable;", ">;+", "Lok/c<", "*>;>;)", "Lai/a;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-virtual {p0}, Lai/a;->p1()Lai/m; move-result-object v0 invoke-virtual {v0, p1}, Lai/m;->T5(Lci/o;)Lai/m; move-result-object p1 invoke-static {p1}, Lai/a;->d0(Lok/c;)Lai/a; move-result-object p1 return-object p1 .end method .method public final O(Lci/a;)Lai/a; .locals 7 .param p1 # Lci/a; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "onDispose" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->h()Lci/g; move-result-object v1 invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->h()Lci/g; move-result-object v2 sget-object v5, Lio/reactivex/rxjava3/internal/functions/Functions;->c:Lci/a; move-object v0, p0 move-object v3, v5 move-object v4, v5 move-object v6, p1 invoke-virtual/range {v0 .. v6}, Lai/a;->S(Lci/g;Lci/g;Lci/a;Lci/a;Lci/a;Lci/a;)Lai/a; move-result-object p1 return-object p1 .end method .method public final O0(Lai/d;)V .locals 1 .param p1 # Lai/d; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "observer" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "observer is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lfi/q; invoke-direct {v0, p1}, Lfi/q;->(Lai/d;)V invoke-virtual {p0, v0}, Lai/a;->d(Lai/d;)V return-void .end method .method public final P(Lci/g;)Lai/a; .locals 7 .param p1 # Lci/g; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "onError" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/g<", "-", "Ljava/lang/Throwable;", ">;)", "Lai/a;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->h()Lci/g; move-result-object v1 sget-object v6, Lio/reactivex/rxjava3/internal/functions/Functions;->c:Lci/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}, Lai/a;->S(Lci/g;Lci/g;Lci/a;Lci/a;Lci/a;Lci/a;)Lai/a; move-result-object p1 return-object p1 .end method .method public final Q(Lci/g;)Lai/a; .locals 1 .param p1 # Lci/g; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "onEvent" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/g<", "-", "Ljava/lang/Throwable;", ">;)", "Lai/a;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "onEvent is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/rxjava3/internal/operators/completable/e; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/operators/completable/e;->(Lai/g;Lci/g;)V invoke-static {v0}, Lji/a;->O(Lai/a;)Lai/a; move-result-object p1 return-object p1 .end method .method public final Q0(Lai/g;)Lai/a; .locals 2 .param p1 # Lai/g; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "other" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "other is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const/4 v0, 0x2 new-array v0, v0, [Lai/g; const/4 v1, 0x0 aput-object p1, v0, v1 const/4 p1, 0x1 aput-object p0, v0, p1 .line 2 invoke-static {v0}, Lai/a;->y([Lai/g;)Lai/a; move-result-object p1 return-object p1 .end method .method public final R(Lci/g;Lci/a;)Lai/a; .locals 7 .param p1 # Lci/g; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p2 # Lci/a; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0 } names = { "onSubscribe", "onDispose" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/g<", "-", "Lio/reactivex/rxjava3/disposables/c;", ">;", "Lci/a;", ")", "Lai/a;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->h()Lci/g; move-result-object v2 sget-object v5, Lio/reactivex/rxjava3/internal/functions/Functions;->c:Lci/a; move-object v0, p0 move-object v1, p1 move-object v3, v5 move-object v4, v5 move-object v6, p2 invoke-virtual/range {v0 .. v6}, Lai/a;->S(Lci/g;Lci/g;Lci/a;Lci/a;Lci/a;Lci/a;)Lai/a; move-result-object p1 return-object p1 .end method .method public final R0(Lai/b0;)Lai/m; .locals 1 .param p1 # Lai/b0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "other" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lai/b0<", "TT;>;)", "Lai/m<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->FULL:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "other is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 invoke-static {p1}, Lai/v;->I2(Lai/b0;)Lai/v; move-result-object p1 invoke-virtual {p1}, Lai/v;->A2()Lai/m; move-result-object p1 invoke-virtual {p0}, Lai/a;->p1()Lai/m; move-result-object v0 invoke-static {p1, v0}, Lai/m;->D0(Lok/c;Lok/c;)Lai/m; move-result-object p1 return-object p1 .end method .method public final S(Lci/g;Lci/g;Lci/a;Lci/a;Lci/a;Lci/a;)Lai/a; .locals 9 .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x10, 0x10, 0x10, 0x10, 0x10, 0x10 } names = { "onSubscribe", "onError", "onComplete", "onTerminate", "onAfterTerminate", "onDispose" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/g<", "-", "Lio/reactivex/rxjava3/disposables/c;", ">;", "Lci/g<", "-", "Ljava/lang/Throwable;", ">;", "Lci/a;", "Lci/a;", "Lci/a;", "Lci/a;", ")", "Lai/a;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "onSubscribe is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "onError is null" .line 2 invoke-static {p2, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "onComplete is null" .line 3 invoke-static {p3, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "onTerminate is null" .line 4 invoke-static {p4, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "onAfterTerminate is null" .line 5 invoke-static {p5, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "onDispose is null" .line 6 invoke-static {p6, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 7 new-instance v0, Lio/reactivex/rxjava3/internal/operators/completable/y; 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/rxjava3/internal/operators/completable/y;->(Lai/g;Lci/g;Lci/g;Lci/a;Lci/a;Lci/a;Lci/a;)V invoke-static {v0}, Lji/a;->O(Lai/a;)Lai/a; move-result-object p1 return-object p1 .end method .method public final S0(Lai/v0;)Lai/m; .locals 1 .param p1 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "other" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lai/v0<", "TT;>;)", "Lai/m<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->FULL:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "other is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 invoke-static {p1}, Lai/p0;->w2(Lai/v0;)Lai/p0; move-result-object p1 invoke-virtual {p1}, Lai/p0;->n2()Lai/m; move-result-object p1 invoke-virtual {p0}, Lai/a;->p1()Lai/m; move-result-object v0 invoke-static {p1, v0}, Lai/m;->D0(Lok/c;Lok/c;)Lai/m; move-result-object p1 return-object p1 .end method .method public final T(Lci/g;)Lai/a; .locals 7 .param p1 # Lci/g; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "onSubscribe" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/g<", "-", "Lio/reactivex/rxjava3/disposables/c;", ">;)", "Lai/a;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->h()Lci/g; move-result-object v2 sget-object v6, Lio/reactivex/rxjava3/internal/functions/Functions;->c:Lci/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}, Lai/a;->S(Lci/g;Lci/g;Lci/a;Lci/a;Lci/a;Lci/a;)Lai/a; move-result-object p1 return-object p1 .end method .method public final T0(Lok/c;)Lai/m; .locals 1 .param p1 # Lok/c; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "other" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lok/c<", "TT;>;)", "Lai/m<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->FULL:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "other is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 invoke-virtual {p0}, Lai/a;->p1()Lai/m; move-result-object v0 invoke-virtual {v0, p1}, Lai/m;->F6(Lok/c;)Lai/m; move-result-object p1 return-object p1 .end method .method public final U(Lci/a;)Lai/a; .locals 7 .param p1 # Lci/a; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "onTerminate" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->h()Lci/g; move-result-object v1 invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->h()Lci/g; move-result-object v2 sget-object v6, Lio/reactivex/rxjava3/internal/functions/Functions;->c:Lci/a; move-object v0, p0 move-object v3, v6 move-object v4, p1 move-object v5, v6 invoke-virtual/range {v0 .. v6}, Lai/a;->S(Lci/g;Lci/g;Lci/a;Lci/a;Lci/a;Lci/a;)Lai/a; move-result-object p1 return-object p1 .end method .method public final U0(Lai/l0;)Lai/g0; .locals 1 .param p1 # Lai/l0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "other" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lai/l0<", "TT;>;)", "Lai/g0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "other is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 invoke-static {p1}, Lai/g0;->q8(Lai/l0;)Lai/g0; move-result-object p1 invoke-virtual {p0}, Lai/a;->t1()Lai/g0; move-result-object v0 invoke-virtual {p1, v0}, Lai/g0;->x1(Lai/l0;)Lai/g0; move-result-object p1 return-object p1 .end method .method public final V0()Lio/reactivex/rxjava3/disposables/c; .locals 1 .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation .line 1 new-instance v0, Lio/reactivex/rxjava3/internal/observers/EmptyCompletableObserver; invoke-direct {v0}, Lio/reactivex/rxjava3/internal/observers/EmptyCompletableObserver;->()V .line 2 invoke-virtual {p0, v0}, Lai/a;->d(Lai/d;)V return-object v0 .end method .method public final W0(Lci/a;)Lio/reactivex/rxjava3/disposables/c; .locals 1 .param p1 # Lci/a; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "onComplete" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "onComplete is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/rxjava3/internal/observers/CallbackCompletableObserver; invoke-direct {v0, p1}, Lio/reactivex/rxjava3/internal/observers/CallbackCompletableObserver;->(Lci/a;)V .line 3 invoke-virtual {p0, v0}, Lai/a;->d(Lai/d;)V return-object v0 .end method .method public final X0(Lci/a;Lci/g;)Lio/reactivex/rxjava3/disposables/c; .locals 1 .param p1 # Lci/a; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p2 # Lci/g; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0 } names = { "onComplete", "onError" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/a;", "Lci/g<", "-", "Ljava/lang/Throwable;", ">;)", "Lio/reactivex/rxjava3/disposables/c;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "onError is null" .line 1 invoke-static {p2, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "onComplete is null" .line 2 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 3 new-instance v0, Lio/reactivex/rxjava3/internal/observers/CallbackCompletableObserver; invoke-direct {v0, p2, p1}, Lio/reactivex/rxjava3/internal/observers/CallbackCompletableObserver;->(Lci/g;Lci/a;)V .line 4 invoke-virtual {p0, v0}, Lai/a;->d(Lai/d;)V return-object v0 .end method .method public abstract Y0(Lai/d;)V .param p1 # Lai/d; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "observer" } .end annotation .end method .method public final Z0(Lai/o0;)Lai/a; .locals 1 .param p1 # Lai/o0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "scheduler" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "custom" .end annotation const-string v0, "scheduler is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/rxjava3/internal/operators/completable/CompletableSubscribeOn; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/operators/completable/CompletableSubscribeOn;->(Lai/g;Lai/o0;)V invoke-static {v0}, Lji/a;->O(Lai/a;)Lai/a; move-result-object p1 return-object p1 .end method .method public final a1(Lai/d;)Lai/d; .locals 0 .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "observer" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(TE;)TE;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-virtual {p0, p1}, Lai/a;->d(Lai/d;)V return-object p1 .end method .method public final d(Lai/d;)V .locals 1 .param p1 # Lai/d; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "observer" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "observer is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 :try_start_0 invoke-static {p0, p1}, Lji/a;->d0(Lai/a;Lai/d;)Lai/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}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 4 invoke-virtual {p0, p1}, Lai/a;->Y0(Lai/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/rxjava3/exceptions/a;->b(Ljava/lang/Throwable;)V .line 6 invoke-static {p1}, Lji/a;->Y(Ljava/lang/Throwable;)V .line 7 invoke-static {p1}, Lai/a;->s1(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(Lai/g;)Lai/a; .locals 1 .param p1 # Lai/g; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "other" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "other is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/rxjava3/internal/operators/completable/CompletableTakeUntilCompletable; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/operators/completable/CompletableTakeUntilCompletable;->(Lai/a;Lai/g;)V invoke-static {v0}, Lji/a;->O(Lai/a;)Lai/a; move-result-object p1 return-object p1 .end method .method public final e1()Lio/reactivex/rxjava3/observers/TestObserver; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Lio/reactivex/rxjava3/observers/TestObserver<", "Ljava/lang/Void;", ">;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation .line 1 new-instance v0, Lio/reactivex/rxjava3/observers/TestObserver; invoke-direct {v0}, Lio/reactivex/rxjava3/observers/TestObserver;->()V .line 2 invoke-virtual {p0, v0}, Lai/a;->d(Lai/d;)V return-object v0 .end method .method public final f1(Z)Lio/reactivex/rxjava3/observers/TestObserver; .locals 1 .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "dispose" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(Z)", "Lio/reactivex/rxjava3/observers/TestObserver<", "Ljava/lang/Void;", ">;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation .line 1 new-instance v0, Lio/reactivex/rxjava3/observers/TestObserver; invoke-direct {v0}, Lio/reactivex/rxjava3/observers/TestObserver;->()V if-eqz p1, :cond_0 .line 2 invoke-virtual {v0}, Lio/reactivex/rxjava3/observers/TestObserver;->dispose()V .line 3 :cond_0 invoke-virtual {p0, v0}, Lai/a;->d(Lai/d;)V return-object v0 .end method .method public final g(Lai/g;)Lai/a; .locals 2 .param p1 # Lai/g; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "other" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "other is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const/4 v0, 0x2 new-array v0, v0, [Lai/g; const/4 v1, 0x0 aput-object p0, v0, v1 const/4 v1, 0x1 aput-object p1, v0, v1 .line 2 invoke-static {v0}, Lai/a;->f([Lai/g;)Lai/a; move-result-object p1 return-object p1 .end method .method public final g1(JLjava/util/concurrent/TimeUnit;)Lai/a; .locals 6 .param p3 # Ljava/util/concurrent/TimeUnit; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0 } names = { "timeout", "unit" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "io.reactivex:computation" .end annotation .line 1 invoke-static {}, Lki/b;->a()Lai/o0; 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}, Lai/a;->k1(JLjava/util/concurrent/TimeUnit;Lai/o0;Lai/g;)Lai/a; move-result-object p1 return-object p1 .end method .method public final h(Lai/g;)Lai/a; .locals 1 .param p1 # Lai/g; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "next" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "next is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/rxjava3/internal/operators/completable/CompletableAndThenCompletable; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/operators/completable/CompletableAndThenCompletable;->(Lai/g;Lai/g;)V invoke-static {v0}, Lji/a;->O(Lai/a;)Lai/a; move-result-object p1 return-object p1 .end method .method public final h0()Lai/a; .locals 1 .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation .line 1 new-instance v0, Lio/reactivex/rxjava3/internal/operators/completable/q; invoke-direct {v0, p0}, Lio/reactivex/rxjava3/internal/operators/completable/q;->(Lai/g;)V invoke-static {v0}, Lji/a;->O(Lai/a;)Lai/a; move-result-object v0 return-object v0 .end method .method public final h1(JLjava/util/concurrent/TimeUnit;Lai/g;)Lai/a; .locals 7 .param p3 # Ljava/util/concurrent/TimeUnit; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p4 # Lai/g; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0, 0x0 } names = { "timeout", "unit", "fallback" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "io.reactivex:computation" .end annotation const-string v0, "fallback is null" .line 1 invoke-static {p4, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 invoke-static {}, Lki/b;->a()Lai/o0; 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}, Lai/a;->k1(JLjava/util/concurrent/TimeUnit;Lai/o0;Lai/g;)Lai/a; move-result-object p1 return-object p1 .end method .method public final i(Lok/c;)Lai/m; .locals 1 .param p1 # Lok/c; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "next" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lok/c<", "TT;>;)", "Lai/m<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->FULL:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "next is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/rxjava3/internal/operators/mixed/CompletableAndThenPublisher; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/operators/mixed/CompletableAndThenPublisher;->(Lai/g;Lok/c;)V invoke-static {v0}, Lji/a;->P(Lai/m;)Lai/m; move-result-object p1 return-object p1 .end method .method public final i0(Lai/f;)Lai/a; .locals 1 .param p1 # Lai/f; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "onLift" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "onLift is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/rxjava3/internal/operators/completable/r; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/operators/completable/r;->(Lai/g;Lai/f;)V invoke-static {v0}, Lji/a;->O(Lai/a;)Lai/a; move-result-object p1 return-object p1 .end method .method public final i1(JLjava/util/concurrent/TimeUnit;Lai/o0;)Lai/a; .locals 6 .param p3 # Ljava/util/concurrent/TimeUnit; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p4 # Lai/o0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0, 0x0 } names = { "timeout", "unit", "scheduler" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/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}, Lai/a;->k1(JLjava/util/concurrent/TimeUnit;Lai/o0;Lai/g;)Lai/a; move-result-object p1 return-object p1 .end method .method public final j(Lai/b0;)Lai/v; .locals 1 .param p1 # Lai/b0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "next" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lai/b0<", "TT;>;)", "Lai/v<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "next is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/rxjava3/internal/operators/maybe/MaybeDelayWithCompletable; invoke-direct {v0, p1, p0}, Lio/reactivex/rxjava3/internal/operators/maybe/MaybeDelayWithCompletable;->(Lai/b0;Lai/g;)V invoke-static {v0}, Lji/a;->Q(Lai/v;)Lai/v; move-result-object p1 return-object p1 .end method .method public final j0()Lai/p0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Lai/p0<", "Lai/d0<", "TT;>;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation .line 1 new-instance v0, Lio/reactivex/rxjava3/internal/operators/completable/s; invoke-direct {v0, p0}, Lio/reactivex/rxjava3/internal/operators/completable/s;->(Lai/a;)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object v0 return-object v0 .end method .method public final j1(JLjava/util/concurrent/TimeUnit;Lai/o0;Lai/g;)Lai/a; .locals 1 .param p3 # Ljava/util/concurrent/TimeUnit; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p4 # Lai/o0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p5 # Lai/g; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0, 0x0, 0x0 } names = { "timeout", "unit", "scheduler", "fallback" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "custom" .end annotation const-string v0, "fallback is null" .line 1 invoke-static {p5, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 invoke-virtual/range {p0 .. p5}, Lai/a;->k1(JLjava/util/concurrent/TimeUnit;Lai/o0;Lai/g;)Lai/a; move-result-object p1 return-object p1 .end method .method public final k(Lai/l0;)Lai/g0; .locals 1 .param p1 # Lai/l0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "next" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lai/l0<", "TT;>;)", "Lai/g0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "next is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/rxjava3/internal/operators/mixed/CompletableAndThenObservable; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/operators/mixed/CompletableAndThenObservable;->(Lai/g;Lai/l0;)V invoke-static {v0}, Lji/a;->R(Lai/g0;)Lai/g0; move-result-object p1 return-object p1 .end method .method public final k1(JLjava/util/concurrent/TimeUnit;Lai/o0;Lai/g;)Lai/a; .locals 8 .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0, 0x0, 0x0 } names = { "timeout", "unit", "scheduler", "fallback" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "custom" .end annotation const-string v0, "unit is null" .line 1 invoke-static {p3, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "scheduler is null" .line 2 invoke-static {p4, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 3 new-instance v0, Lio/reactivex/rxjava3/internal/operators/completable/z; 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/rxjava3/internal/operators/completable/z;->(Lai/g;JLjava/util/concurrent/TimeUnit;Lai/o0;Lai/g;)V invoke-static {v0}, Lji/a;->O(Lai/a;)Lai/a; move-result-object p1 return-object p1 .end method .method public final l(Lai/v0;)Lai/p0; .locals 1 .param p1 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "next" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lai/v0<", "TT;>;)", "Lai/p0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "next is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/rxjava3/internal/operators/single/SingleDelayWithCompletable; invoke-direct {v0, p1, p0}, Lio/reactivex/rxjava3/internal/operators/single/SingleDelayWithCompletable;->(Lai/v0;Lai/g;)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object p1 return-object p1 .end method .method public final m()V .locals 1 .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation .line 1 new-instance v0, Lfi/g; invoke-direct {v0}, Lfi/g;->()V .line 2 invoke-virtual {p0, v0}, Lai/a;->d(Lai/d;)V .line 3 invoke-virtual {v0}, Lfi/g;->c()Ljava/lang/Object; return-void .end method .method public final n(JLjava/util/concurrent/TimeUnit;)Z .locals 1 .param p3 # Ljava/util/concurrent/TimeUnit; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0 } names = { "timeout", "unit" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "unit is null" .line 1 invoke-static {p3, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lfi/g; invoke-direct {v0}, Lfi/g;->()V .line 3 invoke-virtual {p0, v0}, Lai/a;->d(Lai/d;)V .line 4 invoke-virtual {v0, p1, p2, p3}, Lfi/g;->a(JLjava/util/concurrent/TimeUnit;)Z move-result p1 return p1 .end method .method public final n1(Lai/b;)Ljava/lang/Object; .locals 1 .param p1 # Lai/b; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "converter" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lai/b<", "+TR;>;)TR;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "converter is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; check-cast p1, Lai/b; invoke-interface {p1, p0}, Lai/b;->a(Lai/a;)Ljava/lang/Object; move-result-object p1 return-object p1 .end method .method public final o()V .locals 2 .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation .line 1 sget-object v0, Lio/reactivex/rxjava3/internal/functions/Functions;->c:Lci/a; sget-object v1, Lio/reactivex/rxjava3/internal/functions/Functions;->e:Lci/g; invoke-virtual {p0, v0, v1}, Lai/a;->r(Lci/a;Lci/g;)V return-void .end method .method public final o1(Ljava/lang/Object;)Ljava/util/concurrent/CompletionStage; .locals 2 .param p1 # Ljava/lang/Object; .annotation build Lio/reactivex/rxjava3/annotations/Nullable; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "defaultItem" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(TT;)", "Ljava/util/concurrent/CompletionStage<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation .line 1 new-instance v0, Lio/reactivex/rxjava3/internal/jdk8/b; const/4 v1, 0x1 invoke-direct {v0, v1, p1}, Lio/reactivex/rxjava3/internal/jdk8/b;->(ZLjava/lang/Object;)V invoke-virtual {p0, v0}, Lai/a;->a1(Lai/d;)Lai/d; move-result-object p1 check-cast p1, Ljava/util/concurrent/CompletionStage; return-object p1 .end method .method public final p(Lai/d;)V .locals 1 .param p1 # Lai/d; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "observer" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "observer is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lfi/d; invoke-direct {v0}, Lfi/d;->()V .line 3 invoke-interface {p1, v0}, Lai/d;->onSubscribe(Lio/reactivex/rxjava3/disposables/c;)V .line 4 invoke-virtual {p0, v0}, Lai/a;->d(Lai/d;)V .line 5 invoke-virtual {v0, p1}, Lfi/d;->a(Lai/d;)V return-void .end method .method public final p1()Lai/m; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Lai/m<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->FULL:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation .line 1 instance-of v0, p0, Lei/d; if-eqz v0, :cond_0 .line 2 move-object v0, p0 check-cast v0, Lei/d; invoke-interface {v0}, Lei/d;->c()Lai/m; move-result-object v0 return-object v0 .line 3 :cond_0 new-instance v0, Lio/reactivex/rxjava3/internal/operators/completable/a0; invoke-direct {v0, p0}, Lio/reactivex/rxjava3/internal/operators/completable/a0;->(Lai/g;)V invoke-static {v0}, Lji/a;->P(Lai/m;)Lai/m; move-result-object v0 return-object v0 .end method .method public final q(Lci/a;)V .locals 1 .param p1 # Lci/a; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "onComplete" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation .line 1 sget-object v0, Lio/reactivex/rxjava3/internal/functions/Functions;->e:Lci/g; invoke-virtual {p0, p1, v0}, Lai/a;->r(Lci/a;Lci/g;)V return-void .end method .method public final q1()Ljava/util/concurrent/Future; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Ljava/util/concurrent/Future<", "Ljava/lang/Void;", ">;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation .line 1 new-instance v0, Lfi/i; invoke-direct {v0}, Lfi/i;->()V invoke-virtual {p0, v0}, Lai/a;->a1(Lai/d;)Lai/d; move-result-object v0 check-cast v0, Ljava/util/concurrent/Future; return-object v0 .end method .method public final r(Lci/a;Lci/g;)V .locals 2 .param p1 # Lci/a; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p2 # Lci/g; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0 } names = { "onComplete", "onError" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/a;", "Lci/g<", "-", "Ljava/lang/Throwable;", ">;)V" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "onComplete is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "onError is null" .line 2 invoke-static {p2, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 3 new-instance v0, Lfi/g; invoke-direct {v0}, Lfi/g;->()V .line 4 invoke-virtual {p0, v0}, Lai/a;->d(Lai/d;)V .line 5 invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->h()Lci/g; move-result-object v1 invoke-virtual {v0, v1, p2, p1}, Lfi/g;->b(Lci/g;Lci/g;Lci/a;)V return-void .end method .method public final r1()Lai/v; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Lai/v<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation .line 1 instance-of v0, p0, Lei/e; if-eqz v0, :cond_0 .line 2 move-object v0, p0 check-cast v0, Lei/e; invoke-interface {v0}, Lei/e;->b()Lai/v; move-result-object v0 return-object v0 .line 3 :cond_0 new-instance v0, Lio/reactivex/rxjava3/internal/operators/maybe/t; invoke-direct {v0, p0}, Lio/reactivex/rxjava3/internal/operators/maybe/t;->(Lai/g;)V invoke-static {v0}, Lji/a;->Q(Lai/v;)Lai/v; move-result-object v0 return-object v0 .end method .method public final s()Lai/a; .locals 1 .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation .line 1 new-instance v0, Lio/reactivex/rxjava3/internal/operators/completable/CompletableCache; invoke-direct {v0, p0}, Lio/reactivex/rxjava3/internal/operators/completable/CompletableCache;->(Lai/g;)V invoke-static {v0}, Lji/a;->O(Lai/a;)Lai/a; move-result-object v0 return-object v0 .end method .method public final t0(Lai/g;)Lai/a; .locals 2 .param p1 # Lai/g; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "other" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "other is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const/4 v0, 0x2 new-array v0, v0, [Lai/g; const/4 v1, 0x0 aput-object p0, v0, v1 const/4 v1, 0x1 aput-object p1, v0, v1 .line 2 invoke-static {v0}, Lai/a;->o0([Lai/g;)Lai/a; move-result-object p1 return-object p1 .end method .method public final t1()Lai/g0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Lai/g0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation .line 1 instance-of v0, p0, Lei/f; if-eqz v0, :cond_0 .line 2 move-object v0, p0 check-cast v0, Lei/f; invoke-interface {v0}, Lei/f;->a()Lai/g0; move-result-object v0 return-object v0 .line 3 :cond_0 new-instance v0, Lio/reactivex/rxjava3/internal/operators/completable/b0; invoke-direct {v0, p0}, Lio/reactivex/rxjava3/internal/operators/completable/b0;->(Lai/g;)V invoke-static {v0}, Lji/a;->R(Lai/g0;)Lai/g0; move-result-object v0 return-object v0 .end method .method public final u(Lai/h;)Lai/a; .locals 1 .param p1 # Lai/h; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "transformer" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "transformer is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; check-cast p1, Lai/h; invoke-interface {p1, p0}, Lai/h;->a(Lai/a;)Lai/g; move-result-object p1 invoke-static {p1}, Lai/a;->A1(Lai/g;)Lai/a; move-result-object p1 return-object p1 .end method .method public final u1(Lci/s;)Lai/p0; .locals 2 .param p1 # Lci/s; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "completionValueSupplier" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/s<", "+TT;>;)", "Lai/p0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "completionValueSupplier is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/rxjava3/internal/operators/completable/c0; const/4 v1, 0x0 invoke-direct {v0, p0, p1, v1}, Lio/reactivex/rxjava3/internal/operators/completable/c0;->(Lai/g;Lci/s;Ljava/lang/Object;)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object p1 return-object p1 .end method .method public final v0(Lai/o0;)Lai/a; .locals 1 .param p1 # Lai/o0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "scheduler" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "custom" .end annotation const-string v0, "scheduler is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/rxjava3/internal/operators/completable/CompletableObserveOn; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/operators/completable/CompletableObserveOn;->(Lai/g;Lai/o0;)V invoke-static {v0}, Lji/a;->O(Lai/a;)Lai/a; move-result-object p1 return-object p1 .end method .method public final v1(Ljava/lang/Object;)Lai/p0; .locals 2 .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "completionValue" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(TT;)", "Lai/p0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "completionValue is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/rxjava3/internal/operators/completable/c0; const/4 v1, 0x0 invoke-direct {v0, p0, v1, p1}, Lio/reactivex/rxjava3/internal/operators/completable/c0;->(Lai/g;Lci/s;Ljava/lang/Object;)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object p1 return-object p1 .end method .method public final w0()Lai/a; .locals 1 .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->c()Lci/r; move-result-object v0 invoke-virtual {p0, v0}, Lai/a;->x0(Lci/r;)Lai/a; move-result-object v0 return-object v0 .end method .method public final x0(Lci/r;)Lai/a; .locals 1 .param p1 # Lci/r; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "predicate" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/r<", "-", "Ljava/lang/Throwable;", ">;)", "Lai/a;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "predicate is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/rxjava3/internal/operators/completable/w; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/operators/completable/w;->(Lai/g;Lci/r;)V invoke-static {v0}, Lji/a;->O(Lai/a;)Lai/a; move-result-object p1 return-object p1 .end method .method public final x1(Lai/o0;)Lai/a; .locals 1 .param p1 # Lai/o0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "scheduler" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "custom" .end annotation const-string v0, "scheduler is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/rxjava3/internal/operators/completable/d; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/operators/completable/d;->(Lai/g;Lai/o0;)V invoke-static {v0}, Lji/a;->O(Lai/a;)Lai/a; move-result-object p1 return-object p1 .end method .method public final y0(Lci/o;)Lai/a; .locals 1 .param p1 # Lci/o; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "fallbackSupplier" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/o<", "-", "Ljava/lang/Throwable;", "+", "Lai/g;", ">;)", "Lai/a;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "fallbackSupplier is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/rxjava3/internal/operators/completable/CompletableResumeNext; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/operators/completable/CompletableResumeNext;->(Lai/g;Lci/o;)V invoke-static {v0}, Lji/a;->O(Lai/a;)Lai/a; move-result-object p1 return-object p1 .end method .method public final z0(Lai/g;)Lai/a; .locals 1 .param p1 # Lai/g; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "fallback" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "fallback is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 invoke-static {p1}, Lio/reactivex/rxjava3/internal/functions/Functions;->n(Ljava/lang/Object;)Lci/o; move-result-object p1 invoke-virtual {p0, p1}, Lai/a;->y0(Lci/o;)Lai/a; move-result-object p1 return-object p1 .end method