.class public abstract Lai/p0; .super Ljava/lang/Object; .source "Single.java" # interfaces .implements Lai/v0; # annotations .annotation system Ldalvik/annotation/Signature; value = { "", "Ljava/lang/Object;", "Lai/v0<", "TT;>;" } .end annotation # 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/m; .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/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 .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;->v1(Lci/o;)Lai/m; move-result-object p0 return-object p0 .end method .method public static A2(Lai/v0;Lai/v0;Lai/v0;Lai/v0;Lai/v0;Lai/v0;Lci/k;)Lai/p0; .locals 2 .param p0 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p1 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p2 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p3 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p4 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p5 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p6 # Lci/k; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0 } names = { "source1", "source2", "source3", "source4", "source5", "source6", "zipper" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lai/v0<", "+TT1;>;", "Lai/v0<", "+TT2;>;", "Lai/v0<", "+TT3;>;", "Lai/v0<", "+TT4;>;", "Lai/v0<", "+TT5;>;", "Lai/v0<", "+TT6;>;", "Lci/k<", "-TT1;-TT2;-TT3;-TT4;-TT5;-TT6;+TR;>;)", "Lai/p0<", "TR;>;" } .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-string v0, "source3 is null" .line 3 invoke-static {p2, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source4 is null" .line 4 invoke-static {p3, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source5 is null" .line 5 invoke-static {p4, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source6 is null" .line 6 invoke-static {p5, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "zipper is null" .line 7 invoke-static {p6, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 8 invoke-static {p6}, Lio/reactivex/rxjava3/internal/functions/Functions;->B(Lci/k;)Lci/o; move-result-object p6 const/4 v0, 0x6 new-array v0, v0, [Lai/v0; const/4 v1, 0x0 aput-object p0, v0, v1 const/4 p0, 0x1 aput-object p1, v0, p0 const/4 p0, 0x2 aput-object p2, v0, p0 const/4 p0, 0x3 aput-object p3, v0, p0 const/4 p0, 0x4 aput-object p4, v0, p0 const/4 p0, 0x5 aput-object p5, v0, p0 invoke-static {p6, v0}, Lai/p0;->G2(Lci/o;[Lai/v0;)Lai/p0; move-result-object p0 return-object p0 .end method .method public static B(Lok/c;)Lai/m; .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/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 .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 invoke-virtual {p0, v0}, Lai/m;->v1(Lci/o;)Lai/m; move-result-object p0 return-object p0 .end method .method public static B2(Lai/v0;Lai/v0;Lai/v0;Lai/v0;Lai/v0;Lci/j;)Lai/p0; .locals 2 .param p0 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p1 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p2 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p3 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p4 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p5 # Lci/j; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0, 0x0, 0x0, 0x0, 0x0 } names = { "source1", "source2", "source3", "source4", "source5", "zipper" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lai/v0<", "+TT1;>;", "Lai/v0<", "+TT2;>;", "Lai/v0<", "+TT3;>;", "Lai/v0<", "+TT4;>;", "Lai/v0<", "+TT5;>;", "Lci/j<", "-TT1;-TT2;-TT3;-TT4;-TT5;+TR;>;)", "Lai/p0<", "TR;>;" } .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-string v0, "source3 is null" .line 3 invoke-static {p2, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source4 is null" .line 4 invoke-static {p3, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source5 is null" .line 5 invoke-static {p4, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "zipper is null" .line 6 invoke-static {p5, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 7 invoke-static {p5}, Lio/reactivex/rxjava3/internal/functions/Functions;->A(Lci/j;)Lci/o; move-result-object p5 const/4 v0, 0x5 new-array v0, v0, [Lai/v0; const/4 v1, 0x0 aput-object p0, v0, v1 const/4 p0, 0x1 aput-object p1, v0, p0 const/4 p0, 0x2 aput-object p2, v0, p0 const/4 p0, 0x3 aput-object p3, v0, p0 const/4 p0, 0x4 aput-object p4, v0, p0 invoke-static {p5, v0}, Lai/p0;->G2(Lci/o;[Lai/v0;)Lai/p0; move-result-object p0 return-object p0 .end method .method public static C(Lok/c;I)Lai/m; .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/v0<", "+TT;>;>;I)", "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 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;->x1(Lci/o;ZI)Lai/m; move-result-object p0 return-object p0 .end method .method public static C0(Ljava/util/concurrent/Callable;)Lai/p0; .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<", "+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, "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/single/q; invoke-direct {v0, p0}, Lio/reactivex/rxjava3/internal/operators/single/q;->(Ljava/util/concurrent/Callable;)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object p0 return-object p0 .end method .method public static C1(Lai/v0;Lai/v0;)Lai/p0; .locals 1 .param p0 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p1 # Lai/v0; .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/v0<", "+TT;>;", "Lai/v0<", "+TT;>;)", "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; .line 3 new-instance v0, Lio/reactivex/rxjava3/internal/operators/single/o; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/operators/single/o;->(Lai/v0;Lai/v0;)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object p0 return-object p0 .end method .method public static C2(Lai/v0;Lai/v0;Lai/v0;Lai/v0;Lci/i;)Lai/p0; .locals 2 .param p0 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p1 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p2 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p3 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p4 # Lci/i; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0, 0x0, 0x0, 0x0 } names = { "source1", "source2", "source3", "source4", "zipper" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lai/v0<", "+TT1;>;", "Lai/v0<", "+TT2;>;", "Lai/v0<", "+TT3;>;", "Lai/v0<", "+TT4;>;", "Lci/i<", "-TT1;-TT2;-TT3;-TT4;+TR;>;)", "Lai/p0<", "TR;>;" } .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-string v0, "source3 is null" .line 3 invoke-static {p2, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source4 is null" .line 4 invoke-static {p3, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "zipper is null" .line 5 invoke-static {p4, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 6 invoke-static {p4}, Lio/reactivex/rxjava3/internal/functions/Functions;->z(Lci/i;)Lci/o; move-result-object p4 const/4 v0, 0x4 new-array v0, v0, [Lai/v0; const/4 v1, 0x0 aput-object p0, v0, v1 const/4 p0, 0x1 aput-object p1, v0, p0 const/4 p0, 0x2 aput-object p2, v0, p0 const/4 p0, 0x3 aput-object p3, v0, p0 invoke-static {p4, v0}, Lai/p0;->G2(Lci/o;[Lai/v0;)Lai/p0; move-result-object p0 return-object p0 .end method .method public static D(Ljava/lang/Iterable;)Lai/m; .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/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 .line 1 invoke-static {p0}, Lai/m;->l3(Ljava/lang/Iterable;)Lai/m; move-result-object p0 invoke-static {}, Lio/reactivex/rxjava3/internal/operators/single/SingleInternalHelper;->c()Lci/o; move-result-object v0 const/4 v1, 0x0 invoke-virtual {p0, v0, v1}, Lai/m;->k1(Lci/o;Z)Lai/m; move-result-object p0 return-object p0 .end method .method public static D0(Ljava/util/concurrent/CompletionStage;)Lai/p0; .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<", "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, "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/w; invoke-direct {v0, p0}, Lio/reactivex/rxjava3/internal/jdk8/w;->(Ljava/util/concurrent/CompletionStage;)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object p0 return-object p0 .end method .method public static D2(Lai/v0;Lai/v0;Lai/v0;Lci/h;)Lai/p0; .locals 2 .param p0 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p1 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p2 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p3 # Lci/h; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0, 0x0, 0x0 } names = { "source1", "source2", "source3", "zipper" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lai/v0<", "+TT1;>;", "Lai/v0<", "+TT2;>;", "Lai/v0<", "+TT3;>;", "Lci/h<", "-TT1;-TT2;-TT3;+TR;>;)", "Lai/p0<", "TR;>;" } .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-string v0, "source3 is null" .line 3 invoke-static {p2, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "zipper is null" .line 4 invoke-static {p3, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 5 invoke-static {p3}, Lio/reactivex/rxjava3/internal/functions/Functions;->y(Lci/h;)Lci/o; move-result-object p3 const/4 v0, 0x3 new-array v0, v0, [Lai/v0; const/4 v1, 0x0 aput-object p0, v0, v1 const/4 p0, 0x1 aput-object p1, v0, p0 const/4 p0, 0x2 aput-object p2, v0, p0 invoke-static {p3, v0}, Lai/p0;->G2(Lci/o;[Lai/v0;)Lai/p0; move-result-object p0 return-object p0 .end method .method public static E(Ljava/lang/Iterable;I)Lai/m; .locals 3 .param p0 # Ljava/lang/Iterable; .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 = { "(", "Ljava/lang/Iterable<", "+", "Lai/v0<", "+TT;>;>;I)", "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 invoke-static {p0}, Lai/m;->l3(Ljava/lang/Iterable;)Lai/m; move-result-object p0 invoke-static {}, Lio/reactivex/rxjava3/internal/operators/single/SingleInternalHelper;->c()Lci/o; move-result-object v0 const/4 v1, 0x0 const/4 v2, 0x1 invoke-virtual {p0, v0, v1, p1, v2}, Lai/m;->l1(Lci/o;ZII)Lai/m; move-result-object p0 return-object p0 .end method .method public static E0(Ljava/util/concurrent/Future;)Lai/p0; .locals 0 .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<", "+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 .line 1 invoke-static {p0}, Lai/m;->j3(Ljava/util/concurrent/Future;)Lai/m; move-result-object p0 invoke-static {p0}, Lai/p0;->r2(Lai/m;)Lai/p0; move-result-object p0 return-object p0 .end method .method public static E2(Lai/v0;Lai/v0;Lci/c;)Lai/p0; .locals 2 .param p0 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p1 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p2 # Lci/c; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0, 0x0 } names = { "source1", "source2", "zipper" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lai/v0<", "+TT1;>;", "Lai/v0<", "+TT2;>;", "Lci/c<", "-TT1;-TT2;+TR;>;)", "Lai/p0<", "TR;>;" } .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-string v0, "zipper is null" .line 3 invoke-static {p2, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 4 invoke-static {p2}, Lio/reactivex/rxjava3/internal/functions/Functions;->x(Lci/c;)Lci/o; move-result-object p2 const/4 v0, 0x2 new-array v0, v0, [Lai/v0; const/4 v1, 0x0 aput-object p0, v0, v1 const/4 p0, 0x1 aput-object p1, v0, p0 invoke-static {p2, v0}, Lai/p0;->G2(Lci/o;[Lai/v0;)Lai/p0; move-result-object p0 return-object p0 .end method .method public static F(Lok/c;)Lai/m; .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/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 .line 1 invoke-static {p0}, Lai/m;->p3(Lok/c;)Lai/m; move-result-object p0 invoke-static {}, Lio/reactivex/rxjava3/internal/operators/single/SingleInternalHelper;->c()Lci/o; move-result-object v0 invoke-virtual {p0, v0}, Lai/m;->i1(Lci/o;)Lai/m; move-result-object p0 return-object p0 .end method .method public static F0(Ljava/util/concurrent/Future;JLjava/util/concurrent/TimeUnit;)Lai/p0; .locals 0 .param p0 # Ljava/util/concurrent/Future; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .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, 0x0 } names = { "future", "timeout", "unit" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/Future<", "+TT;>;J", "Ljava/util/concurrent/TimeUnit;", ")", "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 .line 1 invoke-static {p0, p1, p2, p3}, Lai/m;->k3(Ljava/util/concurrent/Future;JLjava/util/concurrent/TimeUnit;)Lai/m; move-result-object p0 invoke-static {p0}, Lai/p0;->r2(Lai/m;)Lai/p0; move-result-object p0 return-object p0 .end method .method public static F2(Ljava/lang/Iterable;Lci/o;)Lai/p0; .locals 1 .param p0 # Ljava/lang/Iterable; .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 .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0 } names = { "sources", "zipper" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Iterable<", "+", "Lai/v0<", "+TT;>;>;", "Lci/o<", "-[", "Ljava/lang/Object;", "+TR;>;)", "Lai/p0<", "TR;>;" } .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, "zipper is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "sources is null" .line 2 invoke-static {p0, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 3 new-instance v0, Lio/reactivex/rxjava3/internal/operators/single/d0; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/operators/single/d0;->(Ljava/lang/Iterable;Lci/o;)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object p0 return-object p0 .end method .method public static G(Lok/c;I)Lai/m; .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", "maxConcurrency" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lok/c<", "+", "Lai/v0<", "+TT;>;>;I)", "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 invoke-static {p0}, Lai/m;->p3(Lok/c;)Lai/m; move-result-object p0 invoke-static {}, Lio/reactivex/rxjava3/internal/operators/single/SingleInternalHelper;->c()Lci/o; move-result-object v0 const/4 v1, 0x1 invoke-virtual {p0, v0, p1, v1}, Lai/m;->j1(Lci/o;II)Lai/m; move-result-object p0 return-object p0 .end method .method public static G0(Lai/b0;)Lai/p0; .locals 2 .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/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, "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/m0; const/4 v1, 0x0 invoke-direct {v0, p0, v1}, Lio/reactivex/rxjava3/internal/operators/maybe/m0;->(Lai/b0;Ljava/lang/Object;)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object p0 return-object p0 .end method .method public static varargs G2(Lci/o;[Lai/v0;)Lai/p0; .locals 1 .param p0 # Lci/o; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p1 # [Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0 } names = { "zipper", "sources" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/o<", "-[", "Ljava/lang/Object;", "+TR;>;[", "Lai/v0<", "+TT;>;)", "Lai/p0<", "TR;>;" } .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, "zipper is null" .line 1 invoke-static {p0, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "sources is null" .line 2 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 3 array-length v0, p1 if-nez v0, :cond_0 .line 4 new-instance p0, Ljava/util/NoSuchElementException; invoke-direct {p0}, Ljava/util/NoSuchElementException;->()V invoke-static {p0}, Lai/p0;->p0(Ljava/lang/Throwable;)Lai/p0; move-result-object p0 return-object p0 .line 5 :cond_0 new-instance v0, Lio/reactivex/rxjava3/internal/operators/single/SingleZipArray; invoke-direct {v0, p1, p0}, Lio/reactivex/rxjava3/internal/operators/single/SingleZipArray;->([Lai/v0;Lci/o;)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object p0 return-object p0 .end method .method public static H(Ljava/lang/Iterable;)Lai/m; .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/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 .line 1 invoke-static {p0}, Lai/m;->l3(Ljava/lang/Iterable;)Lai/m; move-result-object p0 invoke-static {}, Lio/reactivex/rxjava3/internal/operators/single/SingleInternalHelper;->c()Lci/o; move-result-object v0 const/4 v1, 0x1 invoke-virtual {p0, v0, v1}, Lai/m;->k1(Lci/o;Z)Lai/m; move-result-object p0 return-object p0 .end method .method public static H0(Lai/b0;Ljava/lang/Object;)Lai/p0; .locals 1 .param p0 # Lai/b0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p1 # Ljava/lang/Object; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0 } names = { "maybe", "defaultItem" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lai/b0<", "TT;>;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, "maybe is null" .line 1 invoke-static {p0, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "defaultItem 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/operators/maybe/m0; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/operators/maybe/m0;->(Lai/b0;Ljava/lang/Object;)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object p0 return-object p0 .end method .method public static I(Ljava/lang/Iterable;I)Lai/m; .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, 0x0 } names = { "sources", "maxConcurrency" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Iterable<", "+", "Lai/v0<", "+TT;>;>;I)", "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 invoke-static {p0}, Lai/m;->l3(Ljava/lang/Iterable;)Lai/m; move-result-object p0 invoke-static {}, Lio/reactivex/rxjava3/internal/operators/single/SingleInternalHelper;->c()Lci/o; move-result-object v0 const/4 v1, 0x1 invoke-virtual {p0, v0, v1, p1, v1}, Lai/m;->l1(Lci/o;ZII)Lai/m; move-result-object p0 return-object p0 .end method .method public static I0(Lai/l0;)Lai/p0; .locals 2 .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/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, "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/observable/o1; const/4 v1, 0x0 invoke-direct {v0, p0, v1}, Lio/reactivex/rxjava3/internal/operators/observable/o1;->(Lai/l0;Ljava/lang/Object;)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object p0 return-object p0 .end method .method public static J(Lok/c;)Lai/m; .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/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 .line 1 invoke-static {p0}, Lai/m;->p3(Lok/c;)Lai/m; move-result-object p0 invoke-static {}, Lio/reactivex/rxjava3/internal/operators/single/SingleInternalHelper;->c()Lci/o; move-result-object v0 const/4 v1, 0x1 invoke-virtual {p0, v0, v1}, Lai/m;->k1(Lci/o;Z)Lai/m; move-result-object p0 return-object p0 .end method .method public static J0(Lok/c;)Lai/p0; .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/p0<", "TT;>;" } .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/single/r; invoke-direct {v0, p0}, Lio/reactivex/rxjava3/internal/operators/single/r;->(Lok/c;)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object p0 return-object p0 .end method .method public static K(Lok/c;I)Lai/m; .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", "maxConcurrency" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lok/c<", "+", "Lai/v0<", "+TT;>;>;I)", "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 invoke-static {p0}, Lai/m;->p3(Lok/c;)Lai/m; move-result-object p0 invoke-static {}, Lio/reactivex/rxjava3/internal/operators/single/SingleInternalHelper;->c()Lci/o; move-result-object v0 const/4 v1, 0x1 invoke-virtual {p0, v0, v1, p1, v1}, Lai/m;->l1(Lci/o;ZII)Lai/m; move-result-object p0 return-object p0 .end method .method public static K0(Lci/s;)Lai/p0; .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<", "+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, "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/single/s; invoke-direct {v0, p0}, Lio/reactivex/rxjava3/internal/operators/single/s;->(Lci/s;)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object p0 return-object p0 .end method .method public static N0(Ljava/lang/Object;)Lai/p0; .locals 1 .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "item" } .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, "item 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/single/v; invoke-direct {v0, p0}, Lio/reactivex/rxjava3/internal/operators/single/v;->(Ljava/lang/Object;)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object p0 return-object p0 .end method .method public static P1(Lok/c;)Lai/m; .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/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, "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/e; 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/e;->(Lok/c;Lci/o;Z)V invoke-static {v0}, Lji/a;->P(Lai/m;)Lai/m; move-result-object p0 return-object p0 .end method .method public static Q1(Lok/c;)Lai/m; .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/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, "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/e; 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/e;->(Lok/c;Lci/o;Z)V invoke-static {v0}, Lji/a;->P(Lai/m;)Lai/m; move-result-object p0 return-object p0 .end method .method public static R(Lai/t0;)Lai/p0; .locals 1 .param p0 # Lai/t0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "source" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lai/t0<", "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, "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/single/SingleCreate; invoke-direct {v0, p0}, Lio/reactivex/rxjava3/internal/operators/single/SingleCreate;->(Lai/t0;)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object p0 return-object p0 .end method .method public static S(Lci/s;)Lai/p0; .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/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, "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/single/c; invoke-direct {v0, p0}, Lio/reactivex/rxjava3/internal/operators/single/c;->(Lci/s;)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object p0 return-object p0 .end method .method public static S0(Lai/v0;Lai/v0;)Lai/m; .locals 2 .param p0 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p1 # Lai/v0; .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/v0<", "+TT;>;", "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, "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/v0; const/4 v1, 0x0 aput-object p0, v0, v1 const/4 p0, 0x1 aput-object p1, v0, p0 .line 3 invoke-static {v0}, 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 p1 const v0, 0x7fffffff invoke-virtual {p0, p1, v1, v0}, Lai/m;->X2(Lci/o;ZI)Lai/m; move-result-object p0 return-object p0 .end method .method public static T0(Lai/v0;Lai/v0;Lai/v0;)Lai/m; .locals 2 .param p0 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p1 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p2 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0, 0x0 } names = { "source1", "source2", "source3" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lai/v0<", "+TT;>;", "Lai/v0<", "+TT;>;", "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, "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-string v0, "source3 is null" .line 3 invoke-static {p2, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const/4 v0, 0x3 new-array v0, v0, [Lai/v0; const/4 v1, 0x0 aput-object p0, v0, v1 const/4 p0, 0x1 aput-object p1, v0, p0 const/4 p0, 0x2 aput-object p2, v0, p0 .line 4 invoke-static {v0}, 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 p1 const p2, 0x7fffffff invoke-virtual {p0, p1, v1, p2}, Lai/m;->X2(Lci/o;ZI)Lai/m; move-result-object p0 return-object p0 .end method .method public static U0(Lai/v0;Lai/v0;Lai/v0;Lai/v0;)Lai/m; .locals 2 .param p0 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p1 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p2 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p3 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0, 0x0, 0x0 } names = { "source1", "source2", "source3", "source4" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lai/v0<", "+TT;>;", "Lai/v0<", "+TT;>;", "Lai/v0<", "+TT;>;", "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, "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-string v0, "source3 is null" .line 3 invoke-static {p2, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source4 is null" .line 4 invoke-static {p3, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const/4 v0, 0x4 new-array v0, v0, [Lai/v0; const/4 v1, 0x0 aput-object p0, v0, v1 const/4 p0, 0x1 aput-object p1, v0, p0 const/4 p0, 0x2 aput-object p2, v0, p0 const/4 p0, 0x3 aput-object p3, v0, p0 .line 5 invoke-static {v0}, 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 p1 const p2, 0x7fffffff invoke-virtual {p0, p1, v1, p2}, Lai/m;->X2(Lci/o;ZI)Lai/m; move-result-object p0 return-object p0 .end method .method public static V0(Ljava/lang/Iterable;)Lai/m; .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/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 .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;->W2(Lci/o;)Lai/m; move-result-object p0 return-object p0 .end method .method public static W0(Lok/c;)Lai/m; .locals 4 .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/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, "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/flowable/d0; invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->k()Lci/o; move-result-object v1 const/4 v2, 0x0 const v3, 0x7fffffff invoke-direct {v0, p0, v1, v2, v3}, Lio/reactivex/rxjava3/internal/operators/flowable/d0;->(Lok/c;Lci/o;ZI)V invoke-static {v0}, Lji/a;->P(Lai/m;)Lai/m; move-result-object p0 return-object p0 .end method .method public static X0(Lai/v0;)Lai/p0; .locals 2 .param p0 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "source" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lai/v0<", "+", "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, "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/single/SingleFlatMap; invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->k()Lci/o; move-result-object v1 invoke-direct {v0, p0, v1}, Lio/reactivex/rxjava3/internal/operators/single/SingleFlatMap;->(Lai/v0;Lci/o;)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object p0 return-object p0 .end method .method public static varargs Y0([Lai/v0;)Lai/m; .locals 3 .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "sources" } .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 .annotation runtime Ljava/lang/SafeVarargs; .end annotation .line 1 invoke-static {p0}, Lai/m;->f3([Ljava/lang/Object;)Lai/m; move-result-object v0 invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->k()Lci/o; move-result-object v1 array-length p0, p0 const/4 v2, 0x1 invoke-static {v2, p0}, Ljava/lang/Math;->max(II)I move-result p0 const/4 v2, 0x0 invoke-virtual {v0, v1, v2, p0}, Lai/m;->X2(Lci/o;ZI)Lai/m; move-result-object p0 return-object p0 .end method .method public static varargs Z0([Lai/v0;)Lai/m; .locals 3 .param p0 # [Lai/v0; .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 = { "([", "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 .annotation runtime Ljava/lang/SafeVarargs; .end annotation .line 1 invoke-static {p0}, Lai/m;->f3([Ljava/lang/Object;)Lai/m; move-result-object v0 invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->k()Lci/o; move-result-object v1 array-length p0, p0 const/4 v2, 0x1 invoke-static {v2, p0}, Ljava/lang/Math;->max(II)I move-result p0 invoke-virtual {v0, v1, v2, p0}, Lai/m;->X2(Lci/o;ZI)Lai/m; move-result-object p0 return-object p0 .end method .method public static a1(Lai/v0;Lai/v0;)Lai/m; .locals 2 .param p0 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p1 # Lai/v0; .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/v0<", "+TT;>;", "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, "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/v0; const/4 v1, 0x0 aput-object p0, v0, v1 const/4 p0, 0x1 aput-object p1, v0, p0 .line 3 invoke-static {v0}, Lai/m;->f3([Ljava/lang/Object;)Lai/m; move-result-object p1 invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->k()Lci/o; move-result-object v0 const v1, 0x7fffffff invoke-virtual {p1, v0, p0, v1}, Lai/m;->X2(Lci/o;ZI)Lai/m; move-result-object p0 return-object p0 .end method .method public static b1(Lai/v0;Lai/v0;Lai/v0;)Lai/m; .locals 2 .param p0 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p1 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p2 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0, 0x0 } names = { "source1", "source2", "source3" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lai/v0<", "+TT;>;", "Lai/v0<", "+TT;>;", "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, "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-string v0, "source3 is null" .line 3 invoke-static {p2, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const/4 v0, 0x3 new-array v0, v0, [Lai/v0; const/4 v1, 0x0 aput-object p0, v0, v1 const/4 p0, 0x1 aput-object p1, v0, p0 const/4 p1, 0x2 aput-object p2, v0, p1 .line 4 invoke-static {v0}, Lai/m;->f3([Ljava/lang/Object;)Lai/m; move-result-object p1 invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->k()Lci/o; move-result-object p2 const v0, 0x7fffffff invoke-virtual {p1, p2, p0, v0}, Lai/m;->X2(Lci/o;ZI)Lai/m; move-result-object p0 return-object p0 .end method .method public static c1(Lai/v0;Lai/v0;Lai/v0;Lai/v0;)Lai/m; .locals 2 .param p0 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p1 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p2 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p3 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0, 0x0, 0x0 } names = { "source1", "source2", "source3", "source4" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lai/v0<", "+TT;>;", "Lai/v0<", "+TT;>;", "Lai/v0<", "+TT;>;", "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, "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-string v0, "source3 is null" .line 3 invoke-static {p2, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source4 is null" .line 4 invoke-static {p3, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const/4 v0, 0x4 new-array v0, v0, [Lai/v0; const/4 v1, 0x0 aput-object p0, v0, v1 const/4 p0, 0x1 aput-object p1, v0, p0 const/4 p1, 0x2 aput-object p2, v0, p1 const/4 p1, 0x3 aput-object p3, v0, p1 .line 5 invoke-static {v0}, Lai/m;->f3([Ljava/lang/Object;)Lai/m; move-result-object p1 invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->k()Lci/o; move-result-object p2 const p3, 0x7fffffff invoke-virtual {p1, p2, p0, p3}, Lai/m;->X2(Lci/o;ZI)Lai/m; move-result-object p0 return-object p0 .end method .method public static d1(Ljava/lang/Iterable;)Lai/m; .locals 3 .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/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 .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 const/4 v1, 0x1 const v2, 0x7fffffff invoke-virtual {p0, v0, v1, v2}, Lai/m;->X2(Lci/o;ZI)Lai/m; move-result-object p0 return-object p0 .end method .method public static e(Ljava/lang/Iterable;)Lai/p0; .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/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, "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/single/a; const/4 v1, 0x0 invoke-direct {v0, v1, p0}, Lio/reactivex/rxjava3/internal/operators/single/a;->([Lai/v0;Ljava/lang/Iterable;)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object p0 return-object p0 .end method .method public static e1(Lok/c;)Lai/m; .locals 4 .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/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, "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/flowable/d0; invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->k()Lci/o; move-result-object v1 const/4 v2, 0x1 const v3, 0x7fffffff invoke-direct {v0, p0, v1, v2, v3}, Lio/reactivex/rxjava3/internal/operators/flowable/d0;->(Lok/c;Lci/o;ZI)V invoke-static {v0}, Lji/a;->P(Lai/m;)Lai/m; move-result-object p0 return-object p0 .end method .method public static varargs f([Lai/v0;)Lai/p0; .locals 2 .param p0 # [Lai/v0; .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 = { "([", "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 .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 {}, Lio/reactivex/rxjava3/internal/operators/single/SingleInternalHelper;->a()Lci/s; move-result-object p0 invoke-static {p0}, Lai/p0;->o0(Lci/s;)Lai/p0; 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 .line 6 invoke-static {p0}, Lai/p0;->w2(Lai/v0;)Lai/p0; move-result-object p0 return-object p0 .line 7 :cond_1 new-instance v0, Lio/reactivex/rxjava3/internal/operators/single/a; const/4 v1, 0x0 invoke-direct {v0, p0, v1}, Lio/reactivex/rxjava3/internal/operators/single/a;->([Lai/v0;Ljava/lang/Iterable;)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object p0 return-object p0 .end method .method public static f2(JLjava/util/concurrent/TimeUnit;)Lai/p0; .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 system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", ")", "Lai/p0<", "Ljava/lang/Long;", ">;" } .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/p0;->g2(JLjava/util/concurrent/TimeUnit;Lai/o0;)Lai/p0; move-result-object p0 return-object p0 .end method .method public static g1()Lai/p0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "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 .line 1 sget-object v0, Lio/reactivex/rxjava3/internal/operators/single/z;->a:Lai/p0; invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object v0 return-object v0 .end method .method public static g2(JLjava/util/concurrent/TimeUnit;Lai/o0;)Lai/p0; .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 system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", "Lai/o0;", ")", "Lai/p0<", "Ljava/lang/Long;", ">;" } .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/single/SingleTimer; invoke-direct {v0, p0, p1, p2, p3}, Lio/reactivex/rxjava3/internal/operators/single/SingleTimer;->(JLjava/util/concurrent/TimeUnit;Lai/o0;)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object p0 return-object p0 .end method .method public static o0(Lci/s;)Lai/p0; .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/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, "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/single/p; invoke-direct {v0, p0}, Lio/reactivex/rxjava3/internal/operators/single/p;->(Lci/s;)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object p0 return-object p0 .end method .method public static p(Lai/v0;Lai/v0;)Lai/m; .locals 2 .param p0 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p1 # Lai/v0; .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/v0<", "+TT;>;", "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, "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/v0; const/4 v1, 0x0 aput-object p0, v0, v1 const/4 p0, 0x1 aput-object p1, v0, p0 .line 3 invoke-static {v0}, 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 p1 invoke-virtual {p0, p1, v1}, Lai/m;->w1(Lci/o;Z)Lai/m; move-result-object p0 return-object p0 .end method .method public static p0(Ljava/lang/Throwable;)Lai/p0; .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 system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Throwable;", ")", "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, "throwable 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;->o(Ljava/lang/Object;)Lci/s; move-result-object p0 invoke-static {p0}, Lai/p0;->o0(Lci/s;)Lai/p0; move-result-object p0 return-object p0 .end method .method public static q(Lai/v0;Lai/v0;Lai/v0;)Lai/m; .locals 2 .param p0 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p1 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p2 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0, 0x0 } names = { "source1", "source2", "source3" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lai/v0<", "+TT;>;", "Lai/v0<", "+TT;>;", "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, "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-string v0, "source3 is null" .line 3 invoke-static {p2, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const/4 v0, 0x3 new-array v0, v0, [Lai/v0; const/4 v1, 0x0 aput-object p0, v0, v1 const/4 p0, 0x1 aput-object p1, v0, p0 const/4 p0, 0x2 aput-object p2, v0, p0 .line 4 invoke-static {v0}, 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 p1 invoke-virtual {p0, p1, v1}, Lai/m;->w1(Lci/o;Z)Lai/m; move-result-object p0 return-object p0 .end method .method public static r(Lai/v0;Lai/v0;Lai/v0;Lai/v0;)Lai/m; .locals 2 .param p0 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p1 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p2 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p3 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0, 0x0, 0x0 } names = { "source1", "source2", "source3", "source4" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lai/v0<", "+TT;>;", "Lai/v0<", "+TT;>;", "Lai/v0<", "+TT;>;", "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, "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-string v0, "source3 is null" .line 3 invoke-static {p2, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source4 is null" .line 4 invoke-static {p3, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const/4 v0, 0x4 new-array v0, v0, [Lai/v0; const/4 v1, 0x0 aput-object p0, v0, v1 const/4 p0, 0x1 aput-object p1, v0, p0 const/4 p0, 0x2 aput-object p2, v0, p0 const/4 p0, 0x3 aput-object p3, v0, p0 .line 5 invoke-static {v0}, 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 p1 invoke-virtual {p0, p1, v1}, Lai/m;->w1(Lci/o;Z)Lai/m; move-result-object p0 return-object p0 .end method .method public static r2(Lai/m;)Lai/p0; .locals 2 .param p0 # Lai/m; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "source" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lai/m<", "TT;>;)", "Lai/p0<", "TT;>;" } .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .line 1 new-instance v0, Lio/reactivex/rxjava3/internal/operators/flowable/e1; const/4 v1, 0x0 invoke-direct {v0, p0, v1}, Lio/reactivex/rxjava3/internal/operators/flowable/e1;->(Lai/m;Ljava/lang/Object;)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object p0 return-object p0 .end method .method public static s(Ljava/lang/Iterable;)Lai/m; .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/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 .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 const/4 v1, 0x0 invoke-virtual {p0, v0, v1}, Lai/m;->w1(Lci/o;Z)Lai/m; move-result-object p0 return-object p0 .end method .method public static s2(Lai/v0;)Lai/p0; .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 = { "onSubscribe" } .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, "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/p0; if-nez v0, :cond_0 .line 3 new-instance v0, Lio/reactivex/rxjava3/internal/operators/single/t; invoke-direct {v0, p0}, Lio/reactivex/rxjava3/internal/operators/single/t;->(Lai/v0;)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object p0 return-object p0 .line 4 :cond_0 new-instance p0, Ljava/lang/IllegalArgumentException; const-string v0, "unsafeCreate(Single) should be upgraded" invoke-direct {p0, v0}, Ljava/lang/IllegalArgumentException;->(Ljava/lang/String;)V throw p0 .end method .method public static t(Lok/c;)Lai/m; .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/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/4 v0, 0x2 .line 1 invoke-static {p0, v0}, Lai/p0;->u(Lok/c;I)Lai/m; move-result-object p0 return-object p0 .end method .method public static u(Lok/c;I)Lai/m; .locals 3 .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/v0<", "+TT;>;>;I)", "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, "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/mixed/b; invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->k()Lci/o; move-result-object v1 sget-object v2, Lio/reactivex/rxjava3/internal/util/ErrorMode;->IMMEDIATE:Lio/reactivex/rxjava3/internal/util/ErrorMode; invoke-direct {v0, p0, v1, v2, p1}, Lio/reactivex/rxjava3/internal/operators/mixed/b;->(Lok/c;Lci/o;Lio/reactivex/rxjava3/internal/util/ErrorMode;I)V invoke-static {v0}, Lji/a;->P(Lai/m;)Lai/m; move-result-object p0 return-object p0 .end method .method public static u2(Lci/s;Lci/o;Lci/g;)Lai/p0; .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<", "TU;>;", "Lci/o<", "-TU;+", "Lai/v0<", "+TT;>;>;", "Lci/g<", "-TU;>;)", "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/4 v0, 0x1 .line 1 invoke-static {p0, p1, p2, v0}, Lai/p0;->v2(Lci/s;Lci/o;Lci/g;Z)Lai/p0; move-result-object p0 return-object p0 .end method .method public static v(Lai/l0;)Lai/g0; .locals 4 .param p0 # Lai/l0; .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 = { "(", "Lai/l0<", "+", "Lai/v0<", "+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, "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/ObservableConcatMapSingle; invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->k()Lci/o; move-result-object v1 sget-object v2, Lio/reactivex/rxjava3/internal/util/ErrorMode;->IMMEDIATE:Lio/reactivex/rxjava3/internal/util/ErrorMode; const/4 v3, 0x2 invoke-direct {v0, p0, v1, v2, v3}, Lio/reactivex/rxjava3/internal/operators/mixed/ObservableConcatMapSingle;->(Lai/l0;Lci/o;Lio/reactivex/rxjava3/internal/util/ErrorMode;I)V invoke-static {v0}, Lji/a;->R(Lai/g0;)Lai/g0; move-result-object p0 return-object p0 .end method .method public static v2(Lci/s;Lci/o;Lci/g;Z)Lai/p0; .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<", "TU;>;", "Lci/o<", "-TU;+", "Lai/v0<", "+TT;>;>;", "Lci/g<", "-TU;>;Z)", "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, "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/single/SingleUsing; invoke-direct {v0, p0, p1, p2, p3}, Lio/reactivex/rxjava3/internal/operators/single/SingleUsing;->(Lci/s;Lci/o;Lci/g;Z)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object p0 return-object p0 .end method .method public static varargs w([Lai/v0;)Lai/m; .locals 2 .param p0 # [Lai/v0; .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 = { "([", "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 .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, 0x0 invoke-virtual {p0, v0, v1}, Lai/m;->w1(Lci/o;Z)Lai/m; move-result-object p0 return-object p0 .end method .method public static w2(Lai/v0;)Lai/p0; .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 = { "source" } .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, "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/p0; if-eqz v0, :cond_0 .line 3 check-cast p0, Lai/p0; invoke-static {p0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object p0 return-object p0 .line 4 :cond_0 new-instance v0, Lio/reactivex/rxjava3/internal/operators/single/t; invoke-direct {v0, p0}, Lio/reactivex/rxjava3/internal/operators/single/t;->(Lai/v0;)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object p0 return-object p0 .end method .method public static varargs x([Lai/v0;)Lai/m; .locals 2 .param p0 # [Lai/v0; .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 = { "([", "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 .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 invoke-virtual {p0, v0, v1}, Lai/m;->w1(Lci/o;Z)Lai/m; move-result-object p0 return-object p0 .end method .method public static x2(Lai/v0;Lai/v0;Lai/v0;Lai/v0;Lai/v0;Lai/v0;Lai/v0;Lai/v0;Lai/v0;Lci/n;)Lai/p0; .locals 2 .param p0 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p1 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p2 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p3 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p4 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p5 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p6 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p7 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p8 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p9 # Lci/n; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0 } names = { "source1", "source2", "source3", "source4", "source5", "source6", "source7", "source8", "source9", "zipper" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lai/v0<", "+TT1;>;", "Lai/v0<", "+TT2;>;", "Lai/v0<", "+TT3;>;", "Lai/v0<", "+TT4;>;", "Lai/v0<", "+TT5;>;", "Lai/v0<", "+TT6;>;", "Lai/v0<", "+TT7;>;", "Lai/v0<", "+TT8;>;", "Lai/v0<", "+TT9;>;", "Lci/n<", "-TT1;-TT2;-TT3;-TT4;-TT5;-TT6;-TT7;-TT8;-TT9;+TR;>;)", "Lai/p0<", "TR;>;" } .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-string v0, "source3 is null" .line 3 invoke-static {p2, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source4 is null" .line 4 invoke-static {p3, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source5 is null" .line 5 invoke-static {p4, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source6 is null" .line 6 invoke-static {p5, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source7 is null" .line 7 invoke-static {p6, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source8 is null" .line 8 invoke-static {p7, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source9 is null" .line 9 invoke-static {p8, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "zipper is null" .line 10 invoke-static {p9, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 11 invoke-static {p9}, Lio/reactivex/rxjava3/internal/functions/Functions;->E(Lci/n;)Lci/o; move-result-object p9 const/16 v0, 0x9 new-array v0, v0, [Lai/v0; const/4 v1, 0x0 aput-object p0, v0, v1 const/4 p0, 0x1 aput-object p1, v0, p0 const/4 p0, 0x2 aput-object p2, v0, p0 const/4 p0, 0x3 aput-object p3, v0, p0 const/4 p0, 0x4 aput-object p4, v0, p0 const/4 p0, 0x5 aput-object p5, v0, p0 const/4 p0, 0x6 aput-object p6, v0, p0 const/4 p0, 0x7 aput-object p7, v0, p0 const/16 p0, 0x8 aput-object p8, v0, p0 invoke-static {p9, v0}, Lai/p0;->G2(Lci/o;[Lai/v0;)Lai/p0; move-result-object p0 return-object p0 .end method .method public static varargs y([Lai/v0;)Lai/m; .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 = { "sources" } .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 .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/operators/single/SingleInternalHelper;->c()Lci/o; move-result-object v0 invoke-virtual {p0, v0}, Lai/m;->i1(Lci/o;)Lai/m; move-result-object p0 return-object p0 .end method .method public static y2(Lai/v0;Lai/v0;Lai/v0;Lai/v0;Lai/v0;Lai/v0;Lai/v0;Lai/v0;Lci/m;)Lai/p0; .locals 2 .param p0 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p1 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p2 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p3 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p4 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p5 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p6 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p7 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p8 # Lci/m; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0 } names = { "source1", "source2", "source3", "source4", "source5", "source6", "source7", "source8", "zipper" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lai/v0<", "+TT1;>;", "Lai/v0<", "+TT2;>;", "Lai/v0<", "+TT3;>;", "Lai/v0<", "+TT4;>;", "Lai/v0<", "+TT5;>;", "Lai/v0<", "+TT6;>;", "Lai/v0<", "+TT7;>;", "Lai/v0<", "+TT8;>;", "Lci/m<", "-TT1;-TT2;-TT3;-TT4;-TT5;-TT6;-TT7;-TT8;+TR;>;)", "Lai/p0<", "TR;>;" } .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-string v0, "source3 is null" .line 3 invoke-static {p2, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source4 is null" .line 4 invoke-static {p3, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source5 is null" .line 5 invoke-static {p4, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source6 is null" .line 6 invoke-static {p5, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source7 is null" .line 7 invoke-static {p6, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source8 is null" .line 8 invoke-static {p7, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "zipper is null" .line 9 invoke-static {p8, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 10 invoke-static {p8}, Lio/reactivex/rxjava3/internal/functions/Functions;->D(Lci/m;)Lci/o; move-result-object p8 const/16 v0, 0x8 new-array v0, v0, [Lai/v0; const/4 v1, 0x0 aput-object p0, v0, v1 const/4 p0, 0x1 aput-object p1, v0, p0 const/4 p0, 0x2 aput-object p2, v0, p0 const/4 p0, 0x3 aput-object p3, v0, p0 const/4 p0, 0x4 aput-object p4, v0, p0 const/4 p0, 0x5 aput-object p5, v0, p0 const/4 p0, 0x6 aput-object p6, v0, p0 const/4 p0, 0x7 aput-object p7, v0, p0 invoke-static {p8, v0}, Lai/p0;->G2(Lci/o;[Lai/v0;)Lai/p0; move-result-object p0 return-object p0 .end method .method public static varargs z([Lai/v0;)Lai/m; .locals 2 .param p0 # [Lai/v0; .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 = { "([", "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 .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/operators/single/SingleInternalHelper;->c()Lci/o; move-result-object v0 const/4 v1, 0x1 invoke-virtual {p0, v0, v1}, Lai/m;->k1(Lci/o;Z)Lai/m; move-result-object p0 return-object p0 .end method .method public static z2(Lai/v0;Lai/v0;Lai/v0;Lai/v0;Lai/v0;Lai/v0;Lai/v0;Lci/l;)Lai/p0; .locals 2 .param p0 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p1 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p2 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p3 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p4 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p5 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p6 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p7 # Lci/l; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0 } names = { "source1", "source2", "source3", "source4", "source5", "source6", "source7", "zipper" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lai/v0<", "+TT1;>;", "Lai/v0<", "+TT2;>;", "Lai/v0<", "+TT3;>;", "Lai/v0<", "+TT4;>;", "Lai/v0<", "+TT5;>;", "Lai/v0<", "+TT6;>;", "Lai/v0<", "+TT7;>;", "Lci/l<", "-TT1;-TT2;-TT3;-TT4;-TT5;-TT6;-TT7;+TR;>;)", "Lai/p0<", "TR;>;" } .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-string v0, "source3 is null" .line 3 invoke-static {p2, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source4 is null" .line 4 invoke-static {p3, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source5 is null" .line 5 invoke-static {p4, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source6 is null" .line 6 invoke-static {p5, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source7 is null" .line 7 invoke-static {p6, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "zipper is null" .line 8 invoke-static {p7, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 9 invoke-static {p7}, Lio/reactivex/rxjava3/internal/functions/Functions;->C(Lci/l;)Lci/o; move-result-object p7 const/4 v0, 0x7 new-array v0, v0, [Lai/v0; const/4 v1, 0x0 aput-object p0, v0, v1 const/4 p0, 0x1 aput-object p1, v0, p0 const/4 p0, 0x2 aput-object p2, v0, p0 const/4 p0, 0x3 aput-object p3, v0, p0 const/4 p0, 0x4 aput-object p4, v0, p0 const/4 p0, 0x5 aput-object p5, v0, p0 const/4 p0, 0x6 aput-object p6, v0, p0 invoke-static {p7, v0}, Lai/p0;->G2(Lci/o;[Lai/v0;)Lai/p0; move-result-object p0 return-object p0 .end method # virtual methods .method public final A0(Lci/o;)Lai/m; .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 = { "mapper" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/o<", "-TT;+", "Ljava/util/stream/Stream<", "+TR;>;>;)", "Lai/m<", "TR;>;" } .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, "mapper 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/jdk8/u; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/jdk8/u;->(Lai/p0;Lci/o;)V invoke-static {v0}, Lji/a;->P(Lai/m;)Lai/m; move-result-object p1 return-object p1 .end method .method public final A1(Lci/o;)Lai/p0; .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/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 .line 1 invoke-virtual {p0}, Lai/p0;->n2()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/p0;->r2(Lai/m;)Lai/p0; move-result-object p1 return-object p1 .end method .method public final B0(Lci/o;)Lai/g0; .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 = { "mapper" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/o<", "-TT;+", "Ljava/util/stream/Stream<", "+TR;>;>;)", "Lai/g0<", "TR;>;" } .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, "mapper 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/jdk8/v; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/jdk8/v;->(Lai/p0;Lci/o;)V invoke-static {v0}, Lji/a;->R(Lai/g0;)Lai/g0; move-result-object p1 return-object p1 .end method .method public final B1(Lai/s0;)V .locals 1 .param p1 # Lai/s0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "observer" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lai/s0<", "-TT;>;)V" } .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/s; invoke-direct {v0, p1}, Lfi/s;->(Lai/s0;)V invoke-virtual {p0, v0}, Lai/p0;->d(Lai/s0;)V return-void .end method .method public final D1(Lai/g;)Lai/m; .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 system Ldalvik/annotation/Signature; value = { "(", "Lai/g;", ")", "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/a;->A1(Lai/g;)Lai/a; move-result-object p1 invoke-virtual {p1}, Lai/a;->p1()Lai/m; move-result-object p1 invoke-virtual {p0}, Lai/p0;->n2()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 E1(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/p0;->n2()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 F1(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/p0;->n2()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 G1(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/p0;->n2()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 H1(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/p0;->q2()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 H2(Lai/v0;Lci/c;)Lai/p0; .locals 0 .param p1 # Lai/v0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p2 # Lci/c; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0 } names = { "other", "zipper" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lai/v0<", "TU;>;", "Lci/c<", "-TT;-TU;+TR;>;)", "Lai/p0<", "TR;>;" } .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, p1, p2}, Lai/p0;->E2(Lai/v0;Lai/v0;Lci/c;)Lai/p0; move-result-object p1 return-object p1 .end method .method public final I1()Lio/reactivex/rxjava3/disposables/c; .locals 2 .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 v0 sget-object v1, Lio/reactivex/rxjava3/internal/functions/Functions;->f:Lci/g; invoke-virtual {p0, v0, v1}, Lai/p0;->L1(Lci/g;Lci/g;)Lio/reactivex/rxjava3/disposables/c; move-result-object v0 return-object v0 .end method .method public final J1(Lci/b;)Lio/reactivex/rxjava3/disposables/c; .locals 1 .param p1 # Lci/b; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "onCallback" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/b<", "-TT;-", "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, "onCallback 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/BiConsumerSingleObserver; invoke-direct {v0, p1}, Lio/reactivex/rxjava3/internal/observers/BiConsumerSingleObserver;->(Lci/b;)V .line 3 invoke-virtual {p0, v0}, Lai/p0;->d(Lai/s0;)V return-object v0 .end method .method public final K1(Lci/g;)Lio/reactivex/rxjava3/disposables/c; .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 = { "onSuccess" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/g<", "-TT;>;)", "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 .line 1 sget-object v0, Lio/reactivex/rxjava3/internal/functions/Functions;->f:Lci/g; invoke-virtual {p0, p1, v0}, Lai/p0;->L1(Lci/g;Lci/g;)Lio/reactivex/rxjava3/disposables/c; move-result-object p1 return-object p1 .end method .method public final L(Lci/o;)Lai/p0; .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 = { "mapper" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/o<", "-TT;+", "Lai/v0<", "+TR;>;>;)", "Lai/p0<", "TR;>;" } .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, "mapper 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/SingleFlatMap; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/operators/single/SingleFlatMap;->(Lai/v0;Lci/o;)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object p1 return-object p1 .end method .method public final L0()Lai/p0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "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 .line 1 new-instance v0, Lio/reactivex/rxjava3/internal/operators/single/u; invoke-direct {v0, p0}, Lio/reactivex/rxjava3/internal/operators/single/u;->(Lai/v0;)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object v0 return-object v0 .end method .method public final L1(Lci/g;Lci/g;)Lio/reactivex/rxjava3/disposables/c; .locals 1 .param p1 # Lci/g; .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 = { "onSuccess", "onError" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/g<", "-TT;>;", "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, "onSuccess 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, Lio/reactivex/rxjava3/internal/observers/ConsumerSingleObserver; invoke-direct {v0, p1, p2}, Lio/reactivex/rxjava3/internal/observers/ConsumerSingleObserver;->(Lci/g;Lci/g;)V .line 4 invoke-virtual {p0, v0}, Lai/p0;->d(Lai/s0;)V return-object v0 .end method .method public final M(Lci/o;)Lai/a; .locals 0 .param p1 # Lci/o; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "mapper" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/o<", "-TT;+", "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-virtual {p0, p1}, Lai/p0;->u0(Lci/o;)Lai/a; move-result-object p1 return-object p1 .end method .method public final M0()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/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 v0 return-object v0 .end method .method public abstract M1(Lai/s0;)V .param p1 # Lai/s0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "observer" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lai/s0<", "-TT;>;)V" } .end annotation .end method .method public final N(Lci/o;)Lai/v; .locals 0 .param p1 # Lci/o; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "mapper" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/o<", "-TT;+", "Lai/b0<", "+TR;>;>;)", "Lai/v<", "TR;>;" } .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/p0;->v0(Lci/o;)Lai/v; move-result-object p1 return-object p1 .end method .method public final N1(Lai/o0;)Lai/p0; .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 system Ldalvik/annotation/Signature; value = { "(", "Lai/o0;", ")", "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 = "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/single/SingleSubscribeOn; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/operators/single/SingleSubscribeOn;->(Lai/v0;Lai/o0;)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object p1 return-object p1 .end method .method public final O(Lai/v0;)Lai/m; .locals 0 .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 .line 1 invoke-static {p0, p1}, Lai/p0;->p(Lai/v0;Lai/v0;)Lai/m; move-result-object p1 return-object p1 .end method .method public final O0(Lai/u0;)Lai/p0; .locals 1 .param p1 # Lai/u0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "lift" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lai/u0<", "+TR;-TT;>;)", "Lai/p0<", "TR;>;" } .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, "lift 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/w; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/operators/single/w;->(Lai/v0;Lai/u0;)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object p1 return-object p1 .end method .method public final O1(Lai/s0;)Lai/s0; .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/p0;->d(Lai/s0;)V return-object p1 .end method .method public final P(Ljava/lang/Object;)Lai/p0; .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 = { "(", "Ljava/lang/Object;", ")", "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 .line 1 invoke-static {}, Lio/reactivex/rxjava3/internal/functions/a;->a()Lci/d; move-result-object v0 invoke-virtual {p0, p1, v0}, Lai/p0;->Q(Ljava/lang/Object;Lci/d;)Lai/p0; move-result-object p1 return-object p1 .end method .method public final P0(Lci/o;)Lai/p0; .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 = { "mapper" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/o<", "-TT;+TR;>;)", "Lai/p0<", "TR;>;" } .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, "mapper 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/x; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/operators/single/x;->(Lai/v0;Lci/o;)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object p1 return-object p1 .end method .method public final Q(Ljava/lang/Object;Lci/d;)Lai/p0; .locals 1 .param p1 # Ljava/lang/Object; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p2 # Lci/d; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0 } names = { "item", "comparer" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Object;", "Lci/d<", "Ljava/lang/Object;", "Ljava/lang/Object;", ">;)", "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, "item is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "comparer 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, Lio/reactivex/rxjava3/internal/operators/single/b; invoke-direct {v0, p0, p1, p2}, Lio/reactivex/rxjava3/internal/operators/single/b;->(Lai/v0;Ljava/lang/Object;Lci/d;)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object p1 return-object p1 .end method .method public final Q0(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 = { "mapper" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/o<", "-TT;", "Ljava/util/Optional<", "+TR;>;>;)", "Lai/v<", "TR;>;" } .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, "mapper 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/jdk8/x; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/jdk8/x;->(Lai/p0;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 R0()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/single/y; invoke-direct {v0, p0}, Lio/reactivex/rxjava3/internal/operators/single/y;->(Lai/p0;)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object v0 return-object v0 .end method .method public final R1(Lai/g;)Lai/p0; .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 system Ldalvik/annotation/Signature; value = { "(", "Lai/g;", ")", "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, "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/a0; invoke-direct {v0, p1}, Lio/reactivex/rxjava3/internal/operators/completable/a0;->(Lai/g;)V invoke-virtual {p0, v0}, Lai/p0;->T1(Lok/c;)Lai/p0; move-result-object p1 return-object p1 .end method .method public final S1(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 = { "other" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lai/v0<", "+TE;>;)", "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, "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/single/SingleToFlowable; invoke-direct {v0, p1}, Lio/reactivex/rxjava3/internal/operators/single/SingleToFlowable;->(Lai/v0;)V invoke-virtual {p0, v0}, Lai/p0;->T1(Lok/c;)Lai/p0; move-result-object p1 return-object p1 .end method .method public final T(JLjava/util/concurrent/TimeUnit;)Lai/p0; .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 system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", ")", "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 = "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/p0;->V(JLjava/util/concurrent/TimeUnit;Lai/o0;Z)Lai/p0; move-result-object p1 return-object p1 .end method .method public final T1(Lok/c;)Lai/p0; .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<", "TE;>;)", "Lai/p0<", "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 new-instance v0, Lio/reactivex/rxjava3/internal/operators/single/SingleTakeUntil; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/operators/single/SingleTakeUntil;->(Lai/v0;Lok/c;)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object p1 return-object p1 .end method .method public final U(JLjava/util/concurrent/TimeUnit;Lai/o0;)Lai/p0; .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 system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", "Lai/o0;", ")", "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 = "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/p0;->V(JLjava/util/concurrent/TimeUnit;Lai/o0;Z)Lai/p0; move-result-object p1 return-object p1 .end method .method public final U1()Lio/reactivex/rxjava3/observers/TestObserver; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Lio/reactivex/rxjava3/observers/TestObserver<", "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/observers/TestObserver; invoke-direct {v0}, Lio/reactivex/rxjava3/observers/TestObserver;->()V .line 2 invoke-virtual {p0, v0}, Lai/p0;->d(Lai/s0;)V return-object v0 .end method .method public final V(JLjava/util/concurrent/TimeUnit;Lai/o0;Z)Lai/p0; .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 system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", "Lai/o0;", "Z)", "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 = "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/single/d; 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/single/d;->(Lai/v0;JLjava/util/concurrent/TimeUnit;Lai/o0;Z)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object p1 return-object p1 .end method .method public final V1(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<", "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/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/p0;->d(Lai/s0;)V return-object v0 .end method .method public final W(JLjava/util/concurrent/TimeUnit;Z)Lai/p0; .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, 0x0 } names = { "time", "unit", "delayError" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", "Z)", "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 = "io.reactivex:computation" .end annotation .line 1 invoke-static {}, Lki/b;->a()Lai/o0; move-result-object v4 move-object v0, p0 move-wide v1, p1 move-object v3, p3 move v5, p4 invoke-virtual/range {v0 .. v5}, Lai/p0;->V(JLjava/util/concurrent/TimeUnit;Lai/o0;Z)Lai/p0; move-result-object p1 return-object p1 .end method .method public final W1()Lai/p0; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "()", "Lai/p0<", "Lki/d<", "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 = "io.reactivex:computation" .end annotation .line 1 sget-object v0, Ljava/util/concurrent/TimeUnit;->MILLISECONDS:Ljava/util/concurrent/TimeUnit; invoke-static {}, Lki/b;->a()Lai/o0; move-result-object v1 invoke-virtual {p0, v0, v1}, Lai/p0;->Z1(Ljava/util/concurrent/TimeUnit;Lai/o0;)Lai/p0; move-result-object v0 return-object v0 .end method .method public final X(JLjava/util/concurrent/TimeUnit;)Lai/p0; .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 system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", ")", "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 = "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/p0;->Y(JLjava/util/concurrent/TimeUnit;Lai/o0;)Lai/p0; move-result-object p1 return-object p1 .end method .method public final X1(Lai/o0;)Lai/p0; .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 system Ldalvik/annotation/Signature; value = { "(", "Lai/o0;", ")", "Lai/p0<", "Lki/d<", "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 = "custom" .end annotation .line 1 sget-object v0, Ljava/util/concurrent/TimeUnit;->MILLISECONDS:Ljava/util/concurrent/TimeUnit; invoke-virtual {p0, v0, p1}, Lai/p0;->Z1(Ljava/util/concurrent/TimeUnit;Lai/o0;)Lai/p0; move-result-object p1 return-object p1 .end method .method public final Y(JLjava/util/concurrent/TimeUnit;Lai/o0;)Lai/p0; .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 system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", "Lai/o0;", ")", "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 = "custom" .end annotation .line 1 invoke-static {p1, p2, p3, p4}, Lai/g0;->t7(JLjava/util/concurrent/TimeUnit;Lai/o0;)Lai/g0; move-result-object p1 invoke-virtual {p0, p1}, Lai/p0;->a0(Lai/l0;)Lai/p0; move-result-object p1 return-object p1 .end method .method public final Y1(Ljava/util/concurrent/TimeUnit;)Lai/p0; .locals 1 .param p1 # Ljava/util/concurrent/TimeUnit; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "unit" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/TimeUnit;", ")", "Lai/p0<", "Lki/d<", "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 = "io.reactivex:computation" .end annotation .line 1 invoke-static {}, Lki/b;->a()Lai/o0; move-result-object v0 invoke-virtual {p0, p1, v0}, Lai/p0;->Z1(Ljava/util/concurrent/TimeUnit;Lai/o0;)Lai/p0; move-result-object p1 return-object p1 .end method .method public final Z(Lai/g;)Lai/p0; .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 = { "subscriptionIndicator" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lai/g;", ")", "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, "subscriptionIndicator 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, p0, p1}, 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 Z1(Ljava/util/concurrent/TimeUnit;Lai/o0;)Lai/p0; .locals 2 .param p1 # Ljava/util/concurrent/TimeUnit; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p2 # Lai/o0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0 } names = { "unit", "scheduler" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/TimeUnit;", "Lai/o0;", ")", "Lai/p0<", "Lki/d<", "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 = "custom" .end annotation const-string v0, "unit is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "scheduler 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, Lio/reactivex/rxjava3/internal/operators/single/c0; const/4 v1, 0x1 invoke-direct {v0, p0, p1, p2, v1}, Lio/reactivex/rxjava3/internal/operators/single/c0;->(Lai/v0;Ljava/util/concurrent/TimeUnit;Lai/o0;Z)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object p1 return-object p1 .end method .method public final a0(Lai/l0;)Lai/p0; .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 = { "subscriptionIndicator" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lai/l0<", "TU;>;)", "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, "subscriptionIndicator 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/SingleDelayWithObservable; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/operators/single/SingleDelayWithObservable;->(Lai/v0;Lai/l0;)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object p1 return-object p1 .end method .method public final a2(JLjava/util/concurrent/TimeUnit;)Lai/p0; .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 system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", ")", "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 = "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/p0;->e2(JLjava/util/concurrent/TimeUnit;Lai/o0;Lai/v0;)Lai/p0; move-result-object p1 return-object p1 .end method .method public final b0(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 = { "subscriptionIndicator" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lai/v0<", "TU;>;)", "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, "subscriptionIndicator 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/SingleDelayWithSingle; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/operators/single/SingleDelayWithSingle;->(Lai/v0;Lai/v0;)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object p1 return-object p1 .end method .method public final b2(JLjava/util/concurrent/TimeUnit;Lai/o0;)Lai/p0; .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 system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", "Lai/o0;", ")", "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 = "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/p0;->e2(JLjava/util/concurrent/TimeUnit;Lai/o0;Lai/v0;)Lai/p0; move-result-object p1 return-object p1 .end method .method public final c0(Lok/c;)Lai/p0; .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 = { "subscriptionIndicator" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lok/c<", "TU;>;)", "Lai/p0<", "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, "subscriptionIndicator 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/SingleDelayWithPublisher; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/operators/single/SingleDelayWithPublisher;->(Lai/v0;Lok/c;)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object p1 return-object p1 .end method .method public final c2(JLjava/util/concurrent/TimeUnit;Lai/o0;Lai/v0;)Lai/p0; .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/v0; .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 system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", "Lai/o0;", "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 = "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/p0;->e2(JLjava/util/concurrent/TimeUnit;Lai/o0;Lai/v0;)Lai/p0; move-result-object p1 return-object p1 .end method .method public final d(Lai/s0;)V .locals 2 .param p1 # Lai/s0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "observer" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lai/s0<", "-TT;>;)V" } .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 invoke-static {p0, p1}, Lji/a;->g0(Lai/p0;Lai/s0;)Lai/s0; move-result-object p1 const-string v0, "The RxJavaPlugins.onSubscribe hook returned a null SingleObserver. Please check the handler provided to RxJavaPlugins.setOnSingleSubscribe 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 :try_start_0 invoke-virtual {p0, p1}, Lai/p0;->M1(Lai/s0;)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 new-instance v0, Ljava/lang/NullPointerException; const-string v1, "subscribeActual failed" invoke-direct {v0, v1}, Ljava/lang/NullPointerException;->(Ljava/lang/String;)V .line 7 invoke-virtual {v0, p1}, Ljava/lang/NullPointerException;->initCause(Ljava/lang/Throwable;)Ljava/lang/Throwable; .line 8 throw v0 :catch_0 move-exception p1 .line 9 throw p1 .end method .method public final d0(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 = { "selector" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/o<", "-TT;", "Lai/d0<", "TR;>;>;)", "Lai/v<", "TR;>;" } .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, "selector 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/e; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/operators/single/e;->(Lai/p0;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 d2(JLjava/util/concurrent/TimeUnit;Lai/v0;)Lai/p0; .locals 7 .param p3 # Ljava/util/concurrent/TimeUnit; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p4 # Lai/v0; .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 system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", "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 = "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/p0;->e2(JLjava/util/concurrent/TimeUnit;Lai/o0;Lai/v0;)Lai/p0; move-result-object p1 return-object p1 .end method .method public final e0(Lci/g;)Lai/p0; .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 = { "onAfterSuccess" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/g<", "-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, "onAfterSuccess 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/g; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/operators/single/g;->(Lai/v0;Lci/g;)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object p1 return-object p1 .end method .method public final e2(JLjava/util/concurrent/TimeUnit;Lai/o0;Lai/v0;)Lai/p0; .locals 8 .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x10, 0x10, 0x10, 0x10 } names = { "timeout", "unit", "scheduler", "fallback" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", "Lai/o0;", "Lai/v0<", "+TT;>;)", "Lai/p0<", "TT;>;" } .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/single/SingleTimeout; 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/single/SingleTimeout;->(Lai/v0;JLjava/util/concurrent/TimeUnit;Lai/o0;Lai/v0;)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object p1 return-object p1 .end method .method public final f0(Lci/a;)Lai/p0; .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 = { "onAfterTerminate" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/a;", ")", "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, "onAfterTerminate 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/h; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/operators/single/h;->(Lai/v0;Lci/a;)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object p1 return-object p1 .end method .method public final f1(Lai/v0;)Lai/m; .locals 0 .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 .line 1 invoke-static {p0, p1}, Lai/p0;->S0(Lai/v0;Lai/v0;)Lai/m; move-result-object p1 return-object p1 .end method .method public final g(Lai/v0;)Lai/p0; .locals 2 .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/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, "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/v0; const/4 v1, 0x0 aput-object p0, v0, v1 const/4 v1, 0x1 aput-object p1, v0, v1 .line 2 invoke-static {v0}, Lai/p0;->f([Lai/v0;)Lai/p0; move-result-object p1 return-object p1 .end method .method public final g0(Lci/a;)Lai/p0; .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 system Ldalvik/annotation/Signature; value = { "(", "Lci/a;", ")", "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, "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/single/SingleDoFinally; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/operators/single/SingleDoFinally;->(Lai/v0;Lci/a;)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object p1 return-object p1 .end method .method public final h()Ljava/lang/Object; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()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, Lfi/g; invoke-direct {v0}, Lfi/g;->()V .line 2 invoke-virtual {p0, v0}, Lai/p0;->d(Lai/s0;)V .line 3 invoke-virtual {v0}, Lfi/g;->c()Ljava/lang/Object; move-result-object v0 return-object v0 .end method .method public final h0(Lci/a;)Lai/p0; .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 = { "onDispose" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/a;", ")", "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, "onDispose 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/SingleDoOnDispose; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/operators/single/SingleDoOnDispose;->(Lai/v0;Lci/a;)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object p1 return-object p1 .end method .method public final h1(Lai/o0;)Lai/p0; .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 system Ldalvik/annotation/Signature; value = { "(", "Lai/o0;", ")", "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 = "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/single/SingleObserveOn; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/operators/single/SingleObserveOn;->(Lai/v0;Lai/o0;)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object p1 return-object p1 .end method .method public final h2()Lai/p0; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "()", "Lai/p0<", "Lki/d<", "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 = "io.reactivex:computation" .end annotation .line 1 sget-object v0, Ljava/util/concurrent/TimeUnit;->MILLISECONDS:Ljava/util/concurrent/TimeUnit; invoke-static {}, Lki/b;->a()Lai/o0; move-result-object v1 invoke-virtual {p0, v0, v1}, Lai/p0;->k2(Ljava/util/concurrent/TimeUnit;Lai/o0;)Lai/p0; move-result-object v0 return-object v0 .end method .method public final i()V .locals 2 .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 v0 sget-object v1, Lio/reactivex/rxjava3/internal/functions/Functions;->e:Lci/g; invoke-virtual {p0, v0, v1}, Lai/p0;->l(Lci/g;Lci/g;)V return-void .end method .method public final i0(Lci/g;)Lai/p0; .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 = { "onError" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/g<", "-", "Ljava/lang/Throwable;", ">;)", "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, "onError 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/i; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/operators/single/i;->(Lai/v0;Lci/g;)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object p1 return-object p1 .end method .method public final i1(Ljava/lang/Class;)Lai/v; .locals 1 .param p1 # Ljava/lang/Class; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "clazz" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Class<", "TU;>;)", "Lai/v<", "TU;>;" } .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, "clazz 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;->l(Ljava/lang/Class;)Lci/r; move-result-object v0 invoke-virtual {p0, v0}, Lai/p0;->q0(Lci/r;)Lai/v; move-result-object v0 invoke-virtual {v0, p1}, Lai/v;->o(Ljava/lang/Class;)Lai/v; move-result-object p1 return-object p1 .end method .method public final i2(Lai/o0;)Lai/p0; .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 system Ldalvik/annotation/Signature; value = { "(", "Lai/o0;", ")", "Lai/p0<", "Lki/d<", "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 = "custom" .end annotation .line 1 sget-object v0, Ljava/util/concurrent/TimeUnit;->MILLISECONDS:Ljava/util/concurrent/TimeUnit; invoke-virtual {p0, v0, p1}, Lai/p0;->k2(Ljava/util/concurrent/TimeUnit;Lai/o0;)Lai/p0; move-result-object p1 return-object p1 .end method .method public final j(Lai/s0;)V .locals 1 .param p1 # Lai/s0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "observer" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lai/s0<", "-TT;>;)V" } .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/s0;->onSubscribe(Lio/reactivex/rxjava3/disposables/c;)V .line 4 invoke-virtual {p0, v0}, Lai/p0;->d(Lai/s0;)V .line 5 invoke-virtual {v0, p1}, Lfi/d;->c(Lai/s0;)V return-void .end method .method public final j0(Lci/b;)Lai/p0; .locals 1 .param p1 # Lci/b; .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/b<", "-TT;-", "Ljava/lang/Throwable;", ">;)", "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, "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/single/j; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/operators/single/j;->(Lai/v0;Lci/b;)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object p1 return-object p1 .end method .method public final j1()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 invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->c()Lci/r; move-result-object v0 invoke-virtual {p0, v0}, Lai/p0;->k1(Lci/r;)Lai/v; move-result-object v0 return-object v0 .end method .method public final j2(Ljava/util/concurrent/TimeUnit;)Lai/p0; .locals 1 .param p1 # Ljava/util/concurrent/TimeUnit; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "unit" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/TimeUnit;", ")", "Lai/p0<", "Lki/d<", "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 = "io.reactivex:computation" .end annotation .line 1 invoke-static {}, Lki/b;->a()Lai/o0; move-result-object v0 invoke-virtual {p0, p1, v0}, Lai/p0;->k2(Ljava/util/concurrent/TimeUnit;Lai/o0;)Lai/p0; move-result-object p1 return-object p1 .end method .method public final k(Lci/g;)V .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 = { "onSuccess" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/g<", "-TT;>;)V" } .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/p0;->l(Lci/g;Lci/g;)V return-void .end method .method public final k0(Lci/g;Lci/a;)Lai/p0; .locals 1 .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/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, "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, "onDispose 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, Lio/reactivex/rxjava3/internal/operators/single/k; invoke-direct {v0, p0, p1, p2}, Lio/reactivex/rxjava3/internal/operators/single/k;->(Lai/p0;Lci/g;Lci/a;)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object p1 return-object p1 .end method .method public final k1(Lci/r;)Lai/v; .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/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, "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/single/a0; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/operators/single/a0;->(Lai/p0;Lci/r;)V invoke-static {v0}, Lji/a;->Q(Lai/v;)Lai/v; move-result-object p1 return-object p1 .end method .method public final k2(Ljava/util/concurrent/TimeUnit;Lai/o0;)Lai/p0; .locals 2 .param p1 # Ljava/util/concurrent/TimeUnit; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p2 # Lai/o0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0 } names = { "unit", "scheduler" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/TimeUnit;", "Lai/o0;", ")", "Lai/p0<", "Lki/d<", "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 = "custom" .end annotation const-string v0, "unit is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "scheduler 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, Lio/reactivex/rxjava3/internal/operators/single/c0; const/4 v1, 0x0 invoke-direct {v0, p0, p1, p2, v1}, Lio/reactivex/rxjava3/internal/operators/single/c0;->(Lai/v0;Ljava/util/concurrent/TimeUnit;Lai/o0;Z)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object p1 return-object p1 .end method .method public final l(Lci/g;Lci/g;)V .locals 2 .param p1 # Lci/g; .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 = { "onSuccess", "onError" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/g<", "-TT;>;", "Lci/g<", "-", "Ljava/lang/Throwable;", ">;)V" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "onSuccess 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/p0;->d(Lai/s0;)V .line 5 sget-object v1, Lio/reactivex/rxjava3/internal/functions/Functions;->c:Lci/a; invoke-virtual {v0, p1, p2, v1}, Lfi/g;->b(Lci/g;Lci/g;Lci/a;)V return-void .end method .method public final l0(Lci/g;)Lai/p0; .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 = { "onSubscribe" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/g<", "-", "Lio/reactivex/rxjava3/disposables/c;", ">;)", "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, "onSubscribe 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/l; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/operators/single/l;->(Lai/v0;Lci/g;)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object p1 return-object p1 .end method .method public final l1(Lci/o;)Lai/p0; .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/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, "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/single/SingleResumeNext; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/operators/single/SingleResumeNext;->(Lai/v0;Lci/o;)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object p1 return-object p1 .end method .method public final l2(Lai/q0;)Ljava/lang/Object; .locals 1 .param p1 # Lai/q0; .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/q0<", "TT;+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/q0; invoke-interface {p1, p0}, Lai/q0;->a(Lai/p0;)Ljava/lang/Object; move-result-object p1 return-object p1 .end method .method public final m()Lai/p0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "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 .line 1 new-instance v0, Lio/reactivex/rxjava3/internal/operators/single/SingleCache; invoke-direct {v0, p0}, Lio/reactivex/rxjava3/internal/operators/single/SingleCache;->(Lai/v0;)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object v0 return-object v0 .end method .method public final m0(Lci/g;)Lai/p0; .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 = { "onSuccess" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/g<", "-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, "onSuccess 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/m; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/operators/single/m;->(Lai/v0;Lci/g;)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object p1 return-object p1 .end method .method public final m1(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 = { "fallback" } .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, "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/p0;->l1(Lci/o;)Lai/p0; move-result-object p1 return-object p1 .end method .method public final m2()Ljava/util/concurrent/CompletionStage; .locals 3 .annotation system Ldalvik/annotation/Signature; value = { "()", "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, 0x0 const/4 v2, 0x0 invoke-direct {v0, v1, v2}, Lio/reactivex/rxjava3/internal/jdk8/b;->(ZLjava/lang/Object;)V invoke-virtual {p0, v0}, Lai/p0;->O1(Lai/s0;)Lai/s0; move-result-object v0 check-cast v0, Ljava/util/concurrent/CompletionStage; return-object v0 .end method .method public final n(Ljava/lang/Class;)Lai/p0; .locals 1 .param p1 # Ljava/lang/Class; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "clazz" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Class<", "+TU;>;)", "Lai/p0<", "TU;>;" } .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, "clazz 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;->e(Ljava/lang/Class;)Lci/o; move-result-object p1 invoke-virtual {p0, p1}, Lai/p0;->P0(Lci/o;)Lai/p0; move-result-object p1 return-object p1 .end method .method public final n0(Lci/a;)Lai/p0; .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 = { "onTerminate" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/a;", ")", "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, "onTerminate 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/n; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/operators/single/n;->(Lai/v0;Lci/a;)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object p1 return-object p1 .end method .method public final n1(Lci/o;)Lai/p0; .locals 2 .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/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, "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/single/b0; const/4 v1, 0x0 invoke-direct {v0, p0, p1, v1}, Lio/reactivex/rxjava3/internal/operators/single/b0;->(Lai/v0;Lci/o;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 n2()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/single/SingleToFlowable; invoke-direct {v0, p0}, Lio/reactivex/rxjava3/internal/operators/single/SingleToFlowable;->(Lai/v0;)V invoke-static {v0}, Lji/a;->P(Lai/m;)Lai/m; move-result-object v0 return-object v0 .end method .method public final o(Lai/w0;)Lai/p0; .locals 1 .param p1 # Lai/w0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "transformer" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lai/w0<", "-TT;+TR;>;)", "Lai/p0<", "TR;>;" } .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/w0; invoke-interface {p1, p0}, Lai/w0;->a(Lai/p0;)Lai/v0; move-result-object p1 invoke-static {p1}, Lai/p0;->w2(Lai/v0;)Lai/p0; move-result-object p1 return-object p1 .end method .method public final o1(Ljava/lang/Object;)Lai/p0; .locals 2 .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/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, "item 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/b0; const/4 v1, 0x0 invoke-direct {v0, p0, v1, p1}, Lio/reactivex/rxjava3/internal/operators/single/b0;->(Lai/v0;Lci/o;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 o2()Ljava/util/concurrent/Future; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Ljava/util/concurrent/Future<", "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, Lfi/i; invoke-direct {v0}, Lfi/i;->()V invoke-virtual {p0, v0}, Lai/p0;->O1(Lai/s0;)Lai/s0; move-result-object v0 check-cast v0, Ljava/util/concurrent/Future; return-object v0 .end method .method public final p1()Lai/p0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "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 .line 1 new-instance v0, Lio/reactivex/rxjava3/internal/operators/single/f; invoke-direct {v0, p0}, Lio/reactivex/rxjava3/internal/operators/single/f;->(Lai/v0;)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object v0 return-object v0 .end method .method public final p2()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/w; invoke-direct {v0, p0}, Lio/reactivex/rxjava3/internal/operators/maybe/w;->(Lai/v0;)V invoke-static {v0}, Lji/a;->Q(Lai/v;)Lai/v; move-result-object v0 return-object v0 .end method .method public final q0(Lci/r;)Lai/v; .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<", "-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, "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/maybe/p; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/operators/maybe/p;->(Lai/v0;Lci/r;)V invoke-static {v0}, Lji/a;->Q(Lai/v;)Lai/v; move-result-object p1 return-object p1 .end method .method public final q1()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 invoke-virtual {p0}, Lai/p0;->n2()Lai/m; move-result-object v0 invoke-virtual {v0}, Lai/m;->r5()Lai/m; move-result-object v0 return-object v0 .end method .method public final q2()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/single/SingleToObservable; invoke-direct {v0, p0}, Lio/reactivex/rxjava3/internal/operators/single/SingleToObservable;->(Lai/v0;)V invoke-static {v0}, Lji/a;->R(Lai/g0;)Lai/g0; move-result-object v0 return-object v0 .end method .method public final r0(Lci/o;)Lai/p0; .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 = { "mapper" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/o<", "-TT;+", "Lai/v0<", "+TR;>;>;)", "Lai/p0<", "TR;>;" } .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, "mapper 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/SingleFlatMap; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/operators/single/SingleFlatMap;->(Lai/v0;Lci/o;)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object p1 return-object p1 .end method .method public final r1(J)Lai/m; .locals 1 .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "times" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(J)", "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 invoke-virtual {p0}, Lai/p0;->n2()Lai/m; move-result-object v0 invoke-virtual {v0, p1, p2}, Lai/m;->s5(J)Lai/m; move-result-object p1 return-object p1 .end method .method public final s0(Lci/o;Lci/c;)Lai/p0; .locals 1 .param p1 # Lci/o; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p2 # Lci/c; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0 } names = { "mapper", "combiner" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/o<", "-TT;+", "Lai/v0<", "+TU;>;>;", "Lci/c<", "-TT;-TU;+TR;>;)", "Lai/p0<", "TR;>;" } .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, "mapper is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "combiner 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, Lio/reactivex/rxjava3/internal/operators/single/SingleFlatMapBiSelector; invoke-direct {v0, p0, p1, p2}, Lio/reactivex/rxjava3/internal/operators/single/SingleFlatMapBiSelector;->(Lai/v0;Lci/o;Lci/c;)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object p1 return-object p1 .end method .method public final s1(Lci/e;)Lai/m; .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 system Ldalvik/annotation/Signature; value = { "(", "Lci/e;", ")", "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 invoke-virtual {p0}, Lai/p0;->n2()Lai/m; move-result-object v0 invoke-virtual {v0, p1}, Lai/m;->t5(Lci/e;)Lai/m; move-result-object p1 return-object p1 .end method .method public final t0(Lci/o;Lci/o;)Lai/p0; .locals 1 .param p1 # Lci/o; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p2 # Lci/o; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0 } names = { "onSuccessMapper", "onErrorMapper" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/o<", "-TT;+", "Lai/v0<", "+TR;>;>;", "Lci/o<", "-", "Ljava/lang/Throwable;", "+", "Lai/v0<", "+TR;>;>;)", "Lai/p0<", "TR;>;" } .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, "onSuccessMapper is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "onErrorMapper 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, Lio/reactivex/rxjava3/internal/operators/single/SingleFlatMapNotification; invoke-direct {v0, p0, p1, p2}, Lio/reactivex/rxjava3/internal/operators/single/SingleFlatMapNotification;->(Lai/v0;Lci/o;Lci/o;)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object p1 return-object p1 .end method .method public final t1(Lci/o;)Lai/m; .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/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 invoke-virtual {p0}, Lai/p0;->n2()Lai/m; move-result-object v0 invoke-virtual {v0, p1}, Lai/m;->u5(Lci/o;)Lai/m; move-result-object p1 return-object p1 .end method .method public final t2(Lai/o0;)Lai/p0; .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 system Ldalvik/annotation/Signature; value = { "(", "Lai/o0;", ")", "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 = "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/single/SingleUnsubscribeOn; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/operators/single/SingleUnsubscribeOn;->(Lai/v0;Lai/o0;)V invoke-static {v0}, Lji/a;->S(Lai/p0;)Lai/p0; move-result-object p1 return-object p1 .end method .method public final u0(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 = { "mapper" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/o<", "-TT;+", "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, "mapper 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/SingleFlatMapCompletable; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/operators/single/SingleFlatMapCompletable;->(Lai/v0;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 u1()Lai/p0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "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 .line 1 invoke-virtual {p0}, Lai/p0;->n2()Lai/m; move-result-object v0 invoke-virtual {v0}, Lai/m;->N5()Lai/m; move-result-object v0 invoke-static {v0}, Lai/p0;->r2(Lai/m;)Lai/p0; move-result-object v0 return-object v0 .end method .method public final v0(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 = { "mapper" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/o<", "-TT;+", "Lai/b0<", "+TR;>;>;)", "Lai/v<", "TR;>;" } .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, "mapper 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/SingleFlatMapMaybe; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/operators/single/SingleFlatMapMaybe;->(Lai/v0;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 v1(J)Lai/p0; .locals 1 .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "times" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(J)", "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 .line 1 invoke-virtual {p0}, Lai/p0;->n2()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/p0;->r2(Lai/m;)Lai/p0; move-result-object p1 return-object p1 .end method .method public final w0(Lci/o;)Lai/g0; .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 = { "mapper" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/o<", "-TT;+", "Lai/l0<", "+TR;>;>;)", "Lai/g0<", "TR;>;" } .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, "mapper 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/SingleFlatMapObservable; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/operators/mixed/SingleFlatMapObservable;->(Lai/v0;Lci/o;)V invoke-static {v0}, Lji/a;->R(Lai/g0;)Lai/g0; move-result-object p1 return-object p1 .end method .method public final w1(JLci/r;)Lai/p0; .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/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 .line 1 invoke-virtual {p0}, Lai/p0;->n2()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/p0;->r2(Lai/m;)Lai/p0; move-result-object p1 return-object p1 .end method .method public final x0(Lci/o;)Lai/m; .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 = { "mapper" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/o<", "-TT;+", "Lok/c<", "+TR;>;>;)", "Lai/m<", "TR;>;" } .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, "mapper 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/SingleFlatMapPublisher; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/operators/single/SingleFlatMapPublisher;->(Lai/v0;Lci/o;)V invoke-static {v0}, Lji/a;->P(Lai/m;)Lai/m; move-result-object p1 return-object p1 .end method .method public final x1(Lci/d;)Lai/p0; .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/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 .line 1 invoke-virtual {p0}, Lai/p0;->n2()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/p0;->r2(Lai/m;)Lai/p0; move-result-object p1 return-object p1 .end method .method public final y0(Lci/o;)Lai/m; .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 = { "mapper" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/o<", "-TT;+", "Ljava/lang/Iterable<", "+TU;>;>;)", "Lai/m<", "TU;>;" } .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, "mapper 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/SingleFlatMapIterableFlowable; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/operators/single/SingleFlatMapIterableFlowable;->(Lai/v0;Lci/o;)V invoke-static {v0}, Lji/a;->P(Lai/m;)Lai/m; move-result-object p1 return-object p1 .end method .method public final y1(Lci/r;)Lai/p0; .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/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 .line 1 invoke-virtual {p0}, Lai/p0;->n2()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/p0;->r2(Lai/m;)Lai/p0; move-result-object p1 return-object p1 .end method .method public final z0(Lci/o;)Lai/g0; .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 = { "mapper" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/o<", "-TT;+", "Ljava/lang/Iterable<", "+TU;>;>;)", "Lai/g0<", "TU;>;" } .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, "mapper 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/SingleFlatMapIterableObservable; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/operators/single/SingleFlatMapIterableObservable;->(Lai/v0;Lci/o;)V invoke-static {v0}, Lji/a;->R(Lai/g0;)Lai/g0; move-result-object p1 return-object p1 .end method .method public final z1(Lci/e;)Lai/p0; .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 system Ldalvik/annotation/Signature; value = { "(", "Lci/e;", ")", "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, "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/p0;->w1(JLci/r;)Lai/p0; move-result-object p1 return-object p1 .end method