.class public abstract Lkh/i0; .super Ljava/lang/Object; .source "Single.java" # interfaces .implements Lkh/o0; # annotations .annotation system Ldalvik/annotation/Signature; value = { "", "Ljava/lang/Object;", "Lkh/o0<", "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(Lkh/m0;)Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/m0<", "TT;>;)", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "source is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/single/SingleCreate; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/single/SingleCreate;->(Lkh/m0;)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object p0 return-object p0 .end method .method public static A0(Lkh/o0;Lkh/o0;)Lkh/j; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/o0<", "+TT;>;", "Lkh/o0<", "+TT;>;)", "Lkh/j<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "source1 is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source2 is null" .line 2 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const/4 v0, 0x2 new-array v0, v0, [Lkh/o0; const/4 v1, 0x0 aput-object p0, v0, v1 const/4 p0, 0x1 aput-object p1, v0, p0 .line 3 invoke-static {v0}, Lkh/j;->N2([Ljava/lang/Object;)Lkh/j; move-result-object p0 invoke-static {p0}, Lkh/i0;->D0(Lok/c;)Lkh/j; move-result-object p0 return-object p0 .end method .method public static A1(Lkh/o0;)Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/o0<", "TT;>;)", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "source is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 instance-of v0, p0, Lkh/i0; if-eqz v0, :cond_0 .line 3 check-cast p0, Lkh/i0; invoke-static {p0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object p0 return-object p0 .line 4 :cond_0 new-instance v0, Lio/reactivex/internal/operators/single/q; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/single/q;->(Lkh/o0;)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object p0 return-object p0 .end method .method public static B(Ljava/util/concurrent/Callable;)Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/Callable<", "+", "Lkh/o0<", "+TT;>;>;)", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "singleSupplier is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/single/c; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/single/c;->(Ljava/util/concurrent/Callable;)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object p0 return-object p0 .end method .method public static B0(Lkh/o0;Lkh/o0;Lkh/o0;)Lkh/j; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/o0<", "+TT;>;", "Lkh/o0<", "+TT;>;", "Lkh/o0<", "+TT;>;)", "Lkh/j<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "source1 is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source2 is null" .line 2 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source3 is null" .line 3 invoke-static {p2, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const/4 v0, 0x3 new-array v0, v0, [Lkh/o0; 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}, Lkh/j;->N2([Ljava/lang/Object;)Lkh/j; move-result-object p0 invoke-static {p0}, Lkh/i0;->D0(Lok/c;)Lkh/j; move-result-object p0 return-object p0 .end method .method public static B1(Ljava/lang/Iterable;Lph/o;)Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Iterable<", "+", "Lkh/o0<", "+TT;>;>;", "Lph/o<", "-[", "Ljava/lang/Object;", "+TR;>;)", "Lkh/i0<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "zipper is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "sources is null" .line 2 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 3 new-instance v0, Lio/reactivex/internal/operators/single/y; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/single/y;->(Ljava/lang/Iterable;Lph/o;)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object p0 return-object p0 .end method .method public static C0(Lkh/o0;Lkh/o0;Lkh/o0;Lkh/o0;)Lkh/j; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/o0<", "+TT;>;", "Lkh/o0<", "+TT;>;", "Lkh/o0<", "+TT;>;", "Lkh/o0<", "+TT;>;)", "Lkh/j<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "source1 is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source2 is null" .line 2 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source3 is null" .line 3 invoke-static {p2, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source4 is null" .line 4 invoke-static {p3, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const/4 v0, 0x4 new-array v0, v0, [Lkh/o0; 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}, Lkh/j;->N2([Ljava/lang/Object;)Lkh/j; move-result-object p0 invoke-static {p0}, Lkh/i0;->D0(Lok/c;)Lkh/j; move-result-object p0 return-object p0 .end method .method public static C1(Lkh/o0;Lkh/o0;Lkh/o0;Lkh/o0;Lkh/o0;Lkh/o0;Lkh/o0;Lkh/o0;Lkh/o0;Lph/n;)Lkh/i0; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/o0<", "+TT1;>;", "Lkh/o0<", "+TT2;>;", "Lkh/o0<", "+TT3;>;", "Lkh/o0<", "+TT4;>;", "Lkh/o0<", "+TT5;>;", "Lkh/o0<", "+TT6;>;", "Lkh/o0<", "+TT7;>;", "Lkh/o0<", "+TT8;>;", "Lkh/o0<", "+TT9;>;", "Lph/n<", "-TT1;-TT2;-TT3;-TT4;-TT5;-TT6;-TT7;-TT8;-TT9;+TR;>;)", "Lkh/i0<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "source1 is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source2 is null" .line 2 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source3 is null" .line 3 invoke-static {p2, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source4 is null" .line 4 invoke-static {p3, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source5 is null" .line 5 invoke-static {p4, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source6 is null" .line 6 invoke-static {p5, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source7 is null" .line 7 invoke-static {p6, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source8 is null" .line 8 invoke-static {p7, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source9 is null" .line 9 invoke-static {p8, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 10 invoke-static {p9}, Lio/reactivex/internal/functions/Functions;->E(Lph/n;)Lph/o; move-result-object p9 const/16 v0, 0x9 new-array v0, v0, [Lkh/o0; 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}, Lkh/i0;->K1(Lph/o;[Lkh/o0;)Lkh/i0; move-result-object p0 return-object p0 .end method .method public static D0(Lok/c;)Lkh/j; .locals 7 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lok/c<", "+", "Lkh/o0<", "+TT;>;>;)", "Lkh/j<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "sources is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/flowable/d0; invoke-static {}, Lio/reactivex/internal/operators/single/SingleInternalHelper;->c()Lph/o; move-result-object v3 invoke-static {}, Lkh/j;->U()I move-result v6 const/4 v4, 0x1 const v5, 0x7fffffff move-object v1, v0 move-object v2, p0 invoke-direct/range {v1 .. v6}, Lio/reactivex/internal/operators/flowable/d0;->(Lok/c;Lph/o;ZII)V invoke-static {v0}, Lwh/a;->P(Lkh/j;)Lkh/j; move-result-object p0 return-object p0 .end method .method public static D1(Lkh/o0;Lkh/o0;Lkh/o0;Lkh/o0;Lkh/o0;Lkh/o0;Lkh/o0;Lkh/o0;Lph/m;)Lkh/i0; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/o0<", "+TT1;>;", "Lkh/o0<", "+TT2;>;", "Lkh/o0<", "+TT3;>;", "Lkh/o0<", "+TT4;>;", "Lkh/o0<", "+TT5;>;", "Lkh/o0<", "+TT6;>;", "Lkh/o0<", "+TT7;>;", "Lkh/o0<", "+TT8;>;", "Lph/m<", "-TT1;-TT2;-TT3;-TT4;-TT5;-TT6;-TT7;-TT8;+TR;>;)", "Lkh/i0<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "source1 is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source2 is null" .line 2 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source3 is null" .line 3 invoke-static {p2, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source4 is null" .line 4 invoke-static {p3, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source5 is null" .line 5 invoke-static {p4, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source6 is null" .line 6 invoke-static {p5, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source7 is null" .line 7 invoke-static {p6, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source8 is null" .line 8 invoke-static {p7, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 9 invoke-static {p8}, Lio/reactivex/internal/functions/Functions;->D(Lph/m;)Lph/o; move-result-object p8 const/16 v0, 0x8 new-array v0, v0, [Lkh/o0; 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}, Lkh/i0;->K1(Lph/o;[Lkh/o0;)Lkh/i0; move-result-object p0 return-object p0 .end method .method public static E1(Lkh/o0;Lkh/o0;Lkh/o0;Lkh/o0;Lkh/o0;Lkh/o0;Lkh/o0;Lph/l;)Lkh/i0; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/o0<", "+TT1;>;", "Lkh/o0<", "+TT2;>;", "Lkh/o0<", "+TT3;>;", "Lkh/o0<", "+TT4;>;", "Lkh/o0<", "+TT5;>;", "Lkh/o0<", "+TT6;>;", "Lkh/o0<", "+TT7;>;", "Lph/l<", "-TT1;-TT2;-TT3;-TT4;-TT5;-TT6;-TT7;+TR;>;)", "Lkh/i0<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "source1 is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source2 is null" .line 2 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source3 is null" .line 3 invoke-static {p2, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source4 is null" .line 4 invoke-static {p3, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source5 is null" .line 5 invoke-static {p4, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source6 is null" .line 6 invoke-static {p5, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source7 is null" .line 7 invoke-static {p6, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 8 invoke-static {p7}, Lio/reactivex/internal/functions/Functions;->C(Lph/l;)Lph/o; move-result-object p7 const/4 v0, 0x7 new-array v0, v0, [Lkh/o0; 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}, Lkh/i0;->K1(Lph/o;[Lkh/o0;)Lkh/i0; move-result-object p0 return-object p0 .end method .method public static F0()Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 sget-object v0, Lio/reactivex/internal/operators/single/w;->a:Lkh/i0; invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object v0 return-object v0 .end method .method public static F1(Lkh/o0;Lkh/o0;Lkh/o0;Lkh/o0;Lkh/o0;Lkh/o0;Lph/k;)Lkh/i0; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/o0<", "+TT1;>;", "Lkh/o0<", "+TT2;>;", "Lkh/o0<", "+TT3;>;", "Lkh/o0<", "+TT4;>;", "Lkh/o0<", "+TT5;>;", "Lkh/o0<", "+TT6;>;", "Lph/k<", "-TT1;-TT2;-TT3;-TT4;-TT5;-TT6;+TR;>;)", "Lkh/i0<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "source1 is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source2 is null" .line 2 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source3 is null" .line 3 invoke-static {p2, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source4 is null" .line 4 invoke-static {p3, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source5 is null" .line 5 invoke-static {p4, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source6 is null" .line 6 invoke-static {p5, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 7 invoke-static {p6}, Lio/reactivex/internal/functions/Functions;->B(Lph/k;)Lph/o; move-result-object p6 const/4 v0, 0x6 new-array v0, v0, [Lkh/o0; 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}, Lkh/i0;->K1(Lph/o;[Lkh/o0;)Lkh/i0; move-result-object p0 return-object p0 .end method .method public static G1(Lkh/o0;Lkh/o0;Lkh/o0;Lkh/o0;Lkh/o0;Lph/j;)Lkh/i0; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/o0<", "+TT1;>;", "Lkh/o0<", "+TT2;>;", "Lkh/o0<", "+TT3;>;", "Lkh/o0<", "+TT4;>;", "Lkh/o0<", "+TT5;>;", "Lph/j<", "-TT1;-TT2;-TT3;-TT4;-TT5;+TR;>;)", "Lkh/i0<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "source1 is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source2 is null" .line 2 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source3 is null" .line 3 invoke-static {p2, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source4 is null" .line 4 invoke-static {p3, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source5 is null" .line 5 invoke-static {p4, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 6 invoke-static {p5}, Lio/reactivex/internal/functions/Functions;->A(Lph/j;)Lph/o; move-result-object p5 const/4 v0, 0x5 new-array v0, v0, [Lkh/o0; 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}, Lkh/i0;->K1(Lph/o;[Lkh/o0;)Lkh/i0; move-result-object p0 return-object p0 .end method .method public static H1(Lkh/o0;Lkh/o0;Lkh/o0;Lkh/o0;Lph/i;)Lkh/i0; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/o0<", "+TT1;>;", "Lkh/o0<", "+TT2;>;", "Lkh/o0<", "+TT3;>;", "Lkh/o0<", "+TT4;>;", "Lph/i<", "-TT1;-TT2;-TT3;-TT4;+TR;>;)", "Lkh/i0<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "source1 is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source2 is null" .line 2 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source3 is null" .line 3 invoke-static {p2, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source4 is null" .line 4 invoke-static {p3, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 5 invoke-static {p4}, Lio/reactivex/internal/functions/Functions;->z(Lph/i;)Lph/o; move-result-object p4 const/4 v0, 0x4 new-array v0, v0, [Lkh/o0; 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}, Lkh/i0;->K1(Lph/o;[Lkh/o0;)Lkh/i0; move-result-object p0 return-object p0 .end method .method public static I1(Lkh/o0;Lkh/o0;Lkh/o0;Lph/h;)Lkh/i0; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/o0<", "+TT1;>;", "Lkh/o0<", "+TT2;>;", "Lkh/o0<", "+TT3;>;", "Lph/h<", "-TT1;-TT2;-TT3;+TR;>;)", "Lkh/i0<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "source1 is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source2 is null" .line 2 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source3 is null" .line 3 invoke-static {p2, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 4 invoke-static {p3}, Lio/reactivex/internal/functions/Functions;->y(Lph/h;)Lph/o; move-result-object p3 const/4 v0, 0x3 new-array v0, v0, [Lkh/o0; 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}, Lkh/i0;->K1(Lph/o;[Lkh/o0;)Lkh/i0; move-result-object p0 return-object p0 .end method .method public static J1(Lkh/o0;Lkh/o0;Lph/c;)Lkh/i0; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/o0<", "+TT1;>;", "Lkh/o0<", "+TT2;>;", "Lph/c<", "-TT1;-TT2;+TR;>;)", "Lkh/i0<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "source1 is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source2 is null" .line 2 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 3 invoke-static {p2}, Lio/reactivex/internal/functions/Functions;->x(Lph/c;)Lph/o; move-result-object p2 const/4 v0, 0x2 new-array v0, v0, [Lkh/o0; const/4 v1, 0x0 aput-object p0, v0, v1 const/4 p0, 0x1 aput-object p1, v0, p0 invoke-static {p2, v0}, Lkh/i0;->K1(Lph/o;[Lkh/o0;)Lkh/i0; move-result-object p0 return-object p0 .end method .method public static varargs K1(Lph/o;[Lkh/o0;)Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/o<", "-[", "Ljava/lang/Object;", "+TR;>;[", "Lkh/o0<", "+TT;>;)", "Lkh/i0<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "zipper is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "sources is null" .line 2 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 3 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}, Lkh/i0;->W(Ljava/lang/Throwable;)Lkh/i0; move-result-object p0 return-object p0 .line 5 :cond_0 new-instance v0, Lio/reactivex/internal/operators/single/SingleZipArray; invoke-direct {v0, p1, p0}, Lio/reactivex/internal/operators/single/SingleZipArray;->([Lkh/o0;Lph/o;)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object p0 return-object p0 .end method .method public static V(Lkh/o0;Lkh/o0;)Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/o0<", "+TT;>;", "Lkh/o0<", "+TT;>;)", "Lkh/i0<", "Ljava/lang/Boolean;", ">;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "first is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "second is null" .line 2 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 3 new-instance v0, Lio/reactivex/internal/operators/single/m; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/single/m;->(Lkh/o0;Lkh/o0;)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object p0 return-object p0 .end method .method public static W(Ljava/lang/Throwable;)Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Throwable;", ")", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "error is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 invoke-static {p0}, Lio/reactivex/internal/functions/Functions;->m(Ljava/lang/Object;)Ljava/util/concurrent/Callable; move-result-object p0 invoke-static {p0}, Lkh/i0;->X(Ljava/util/concurrent/Callable;)Lkh/i0; move-result-object p0 return-object p0 .end method .method public static X(Ljava/util/concurrent/Callable;)Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/Callable<", "+", "Ljava/lang/Throwable;", ">;)", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "errorSupplier is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/single/n; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/single/n;->(Ljava/util/concurrent/Callable;)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object p0 return-object p0 .end method .method public static e(Ljava/lang/Iterable;)Lkh/i0; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Iterable<", "+", "Lkh/o0<", "+TT;>;>;)", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "sources is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/single/a; const/4 v1, 0x0 invoke-direct {v0, v1, p0}, Lio/reactivex/internal/operators/single/a;->([Lkh/o0;Ljava/lang/Iterable;)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object p0 return-object p0 .end method .method public static varargs f([Lkh/o0;)Lkh/i0; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "([", "Lkh/o0<", "+TT;>;)", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 array-length v0, p0 if-nez v0, :cond_0 .line 2 invoke-static {}, Lio/reactivex/internal/operators/single/SingleInternalHelper;->a()Ljava/util/concurrent/Callable; move-result-object p0 invoke-static {p0}, Lkh/i0;->X(Ljava/util/concurrent/Callable;)Lkh/i0; move-result-object p0 return-object p0 .line 3 :cond_0 array-length v0, p0 const/4 v1, 0x1 if-ne v0, v1, :cond_1 const/4 v0, 0x0 .line 4 aget-object p0, p0, v0 invoke-static {p0}, Lkh/i0;->A1(Lkh/o0;)Lkh/i0; move-result-object p0 return-object p0 .line 5 :cond_1 new-instance v0, Lio/reactivex/internal/operators/single/a; const/4 v1, 0x0 invoke-direct {v0, p0, v1}, Lio/reactivex/internal/operators/single/a;->([Lkh/o0;Ljava/lang/Iterable;)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object p0 return-object p0 .end method .method public static g0(Ljava/util/concurrent/Callable;)Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/Callable<", "+TT;>;)", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "callable is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/single/o; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/single/o;->(Ljava/util/concurrent/Callable;)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object p0 return-object p0 .end method .method public static h0(Ljava/util/concurrent/Future;)Lkh/i0; .locals 0 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/Future<", "+TT;>;)", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-static {p0}, Lkh/j;->P2(Ljava/util/concurrent/Future;)Lkh/j; move-result-object p0 invoke-static {p0}, Lkh/i0;->v1(Lkh/j;)Lkh/i0; move-result-object p0 return-object p0 .end method .method public static i0(Ljava/util/concurrent/Future;JLjava/util/concurrent/TimeUnit;)Lkh/i0; .locals 0 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/Future<", "+TT;>;J", "Ljava/util/concurrent/TimeUnit;", ")", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-static {p0, p1, p2, p3}, Lkh/j;->Q2(Ljava/util/concurrent/Future;JLjava/util/concurrent/TimeUnit;)Lkh/j; move-result-object p0 invoke-static {p0}, Lkh/i0;->v1(Lkh/j;)Lkh/i0; move-result-object p0 return-object p0 .end method .method public static j0(Ljava/util/concurrent/Future;JLjava/util/concurrent/TimeUnit;Lkh/h0;)Lkh/i0; .locals 0 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/Future<", "+TT;>;J", "Ljava/util/concurrent/TimeUnit;", "Lkh/h0;", ")", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "custom" .end annotation .line 1 invoke-static {p0, p1, p2, p3, p4}, Lkh/j;->R2(Ljava/util/concurrent/Future;JLjava/util/concurrent/TimeUnit;Lkh/h0;)Lkh/j; move-result-object p0 invoke-static {p0}, Lkh/i0;->v1(Lkh/j;)Lkh/i0; move-result-object p0 return-object p0 .end method .method public static k0(Ljava/util/concurrent/Future;Lkh/h0;)Lkh/i0; .locals 0 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/Future<", "+TT;>;", "Lkh/h0;", ")", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "custom" .end annotation .line 1 invoke-static {p0, p1}, Lkh/j;->S2(Ljava/util/concurrent/Future;Lkh/h0;)Lkh/j; move-result-object p0 invoke-static {p0}, Lkh/i0;->v1(Lkh/j;)Lkh/i0; move-result-object p0 return-object p0 .end method .method public static l0(Lkh/e0;)Lkh/i0; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/e0<", "+TT;>;)", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "observableSource is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/observable/k1; const/4 v1, 0x0 invoke-direct {v0, p0, v1}, Lio/reactivex/internal/operators/observable/k1;->(Lkh/e0;Ljava/lang/Object;)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object p0 return-object p0 .end method .method public static m(Ljava/lang/Iterable;)Lkh/j; .locals 0 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Iterable<", "+", "Lkh/o0<", "+TT;>;>;)", "Lkh/j<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-static {p0}, Lkh/j;->T2(Ljava/lang/Iterable;)Lkh/j; move-result-object p0 invoke-static {p0}, Lkh/i0;->q(Lok/c;)Lkh/j; move-result-object p0 return-object p0 .end method .method public static m0(Lok/c;)Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lok/c<", "+TT;>;)", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->UNBOUNDED_IN:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "publisher is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/single/p; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/single/p;->(Lok/c;)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object p0 return-object p0 .end method .method public static n(Lkh/o0;Lkh/o0;)Lkh/j; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/o0<", "+TT;>;", "Lkh/o0<", "+TT;>;)", "Lkh/j<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "source1 is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source2 is null" .line 2 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const/4 v0, 0x2 new-array v0, v0, [Lkh/o0; const/4 v1, 0x0 aput-object p0, v0, v1 const/4 p0, 0x1 aput-object p1, v0, p0 .line 3 invoke-static {v0}, Lkh/j;->N2([Ljava/lang/Object;)Lkh/j; move-result-object p0 invoke-static {p0}, Lkh/i0;->q(Lok/c;)Lkh/j; move-result-object p0 return-object p0 .end method .method public static n1(JLjava/util/concurrent/TimeUnit;)Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", ")", "Lkh/i0<", "Ljava/lang/Long;", ">;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "io.reactivex:computation" .end annotation .line 1 invoke-static {}, Lli/b;->a()Lkh/h0; move-result-object v0 invoke-static {p0, p1, p2, v0}, Lkh/i0;->o1(JLjava/util/concurrent/TimeUnit;Lkh/h0;)Lkh/i0; move-result-object p0 return-object p0 .end method .method public static o(Lkh/o0;Lkh/o0;Lkh/o0;)Lkh/j; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/o0<", "+TT;>;", "Lkh/o0<", "+TT;>;", "Lkh/o0<", "+TT;>;)", "Lkh/j<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "source1 is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source2 is null" .line 2 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source3 is null" .line 3 invoke-static {p2, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const/4 v0, 0x3 new-array v0, v0, [Lkh/o0; 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}, Lkh/j;->N2([Ljava/lang/Object;)Lkh/j; move-result-object p0 invoke-static {p0}, Lkh/i0;->q(Lok/c;)Lkh/j; move-result-object p0 return-object p0 .end method .method public static o1(JLjava/util/concurrent/TimeUnit;Lkh/h0;)Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", "Lkh/h0;", ")", "Lkh/i0<", "Ljava/lang/Long;", ">;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "custom" .end annotation const-string v0, "unit is null" .line 1 invoke-static {p2, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "scheduler is null" .line 2 invoke-static {p3, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 3 new-instance v0, Lio/reactivex/internal/operators/single/SingleTimer; invoke-direct {v0, p0, p1, p2, p3}, Lio/reactivex/internal/operators/single/SingleTimer;->(JLjava/util/concurrent/TimeUnit;Lkh/h0;)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object p0 return-object p0 .end method .method public static p(Lkh/o0;Lkh/o0;Lkh/o0;Lkh/o0;)Lkh/j; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/o0<", "+TT;>;", "Lkh/o0<", "+TT;>;", "Lkh/o0<", "+TT;>;", "Lkh/o0<", "+TT;>;)", "Lkh/j<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "source1 is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source2 is null" .line 2 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source3 is null" .line 3 invoke-static {p2, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source4 is null" .line 4 invoke-static {p3, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const/4 v0, 0x4 new-array v0, v0, [Lkh/o0; 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}, Lkh/j;->N2([Ljava/lang/Object;)Lkh/j; move-result-object p0 invoke-static {p0}, Lkh/i0;->q(Lok/c;)Lkh/j; move-result-object p0 return-object p0 .end method .method public static p0(Ljava/lang/Object;)Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(TT;)", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "value is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/single/s; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/single/s;->(Ljava/lang/Object;)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object p0 return-object p0 .end method .method public static q(Lok/c;)Lkh/j; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lok/c<", "+", "Lkh/o0<", "+TT;>;>;)", "Lkh/j<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const/4 v0, 0x2 .line 1 invoke-static {p0, v0}, Lkh/i0;->r(Lok/c;I)Lkh/j; move-result-object p0 return-object p0 .end method .method public static r(Lok/c;I)Lkh/j; .locals 3 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lok/c<", "+", "Lkh/o0<", "+TT;>;>;I)", "Lkh/j<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "sources is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "prefetch" .line 2 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->h(ILjava/lang/String;)I .line 3 new-instance v0, Lio/reactivex/internal/operators/flowable/n; invoke-static {}, Lio/reactivex/internal/operators/single/SingleInternalHelper;->c()Lph/o; move-result-object v1 sget-object v2, Lio/reactivex/internal/util/ErrorMode;->IMMEDIATE:Lio/reactivex/internal/util/ErrorMode; invoke-direct {v0, p0, v1, p1, v2}, Lio/reactivex/internal/operators/flowable/n;->(Lok/c;Lph/o;ILio/reactivex/internal/util/ErrorMode;)V invoke-static {v0}, Lwh/a;->P(Lkh/j;)Lkh/j; move-result-object p0 return-object p0 .end method .method public static s(Lkh/e0;)Lkh/z; .locals 4 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/e0<", "+", "Lkh/o0<", "+TT;>;>;)", "Lkh/z<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "sources is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/observable/ObservableConcatMap; invoke-static {}, Lio/reactivex/internal/operators/single/SingleInternalHelper;->d()Lph/o; move-result-object v1 sget-object v2, Lio/reactivex/internal/util/ErrorMode;->IMMEDIATE:Lio/reactivex/internal/util/ErrorMode; const/4 v3, 0x2 invoke-direct {v0, p0, v1, v3, v2}, Lio/reactivex/internal/operators/observable/ObservableConcatMap;->(Lkh/e0;Lph/o;ILio/reactivex/internal/util/ErrorMode;)V invoke-static {v0}, Lwh/a;->R(Lkh/z;)Lkh/z; move-result-object p0 return-object p0 .end method .method public static varargs t([Lkh/o0;)Lkh/j; .locals 4 .annotation system Ldalvik/annotation/Signature; value = { "([", "Lkh/o0<", "+TT;>;)", "Lkh/j<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 new-instance v0, Lio/reactivex/internal/operators/flowable/FlowableConcatMap; invoke-static {p0}, Lkh/j;->N2([Ljava/lang/Object;)Lkh/j; move-result-object p0 invoke-static {}, Lio/reactivex/internal/operators/single/SingleInternalHelper;->c()Lph/o; move-result-object v1 sget-object v2, Lio/reactivex/internal/util/ErrorMode;->BOUNDARY:Lio/reactivex/internal/util/ErrorMode; const/4 v3, 0x2 invoke-direct {v0, p0, v1, v3, v2}, Lio/reactivex/internal/operators/flowable/FlowableConcatMap;->(Lkh/j;Lph/o;ILio/reactivex/internal/util/ErrorMode;)V invoke-static {v0}, Lwh/a;->P(Lkh/j;)Lkh/j; move-result-object p0 return-object p0 .end method .method public static t0(Ljava/lang/Iterable;)Lkh/j; .locals 0 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Iterable<", "+", "Lkh/o0<", "+TT;>;>;)", "Lkh/j<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-static {p0}, Lkh/j;->T2(Ljava/lang/Iterable;)Lkh/j; move-result-object p0 invoke-static {p0}, Lkh/i0;->x0(Lok/c;)Lkh/j; move-result-object p0 return-object p0 .end method .method public static varargs u([Lkh/o0;)Lkh/j; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "([", "Lkh/o0<", "+TT;>;)", "Lkh/j<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-static {p0}, Lkh/j;->N2([Ljava/lang/Object;)Lkh/j; move-result-object p0 invoke-static {}, Lio/reactivex/internal/operators/single/SingleInternalHelper;->c()Lph/o; move-result-object v0 invoke-virtual {p0, v0}, Lkh/j;->W0(Lph/o;)Lkh/j; move-result-object p0 return-object p0 .end method .method public static u0(Lkh/o0;Lkh/o0;)Lkh/j; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/o0<", "+TT;>;", "Lkh/o0<", "+TT;>;)", "Lkh/j<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "source1 is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source2 is null" .line 2 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const/4 v0, 0x2 new-array v0, v0, [Lkh/o0; const/4 v1, 0x0 aput-object p0, v0, v1 const/4 p0, 0x1 aput-object p1, v0, p0 .line 3 invoke-static {v0}, Lkh/j;->N2([Ljava/lang/Object;)Lkh/j; move-result-object p0 invoke-static {p0}, Lkh/i0;->x0(Lok/c;)Lkh/j; move-result-object p0 return-object p0 .end method .method public static v(Ljava/lang/Iterable;)Lkh/j; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Iterable<", "+", "Lkh/o0<", "+TT;>;>;)", "Lkh/j<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-static {p0}, Lkh/j;->T2(Ljava/lang/Iterable;)Lkh/j; move-result-object p0 invoke-static {}, Lio/reactivex/internal/operators/single/SingleInternalHelper;->c()Lph/o; move-result-object v0 invoke-virtual {p0, v0}, Lkh/j;->W0(Lph/o;)Lkh/j; move-result-object p0 return-object p0 .end method .method public static v0(Lkh/o0;Lkh/o0;Lkh/o0;)Lkh/j; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/o0<", "+TT;>;", "Lkh/o0<", "+TT;>;", "Lkh/o0<", "+TT;>;)", "Lkh/j<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "source1 is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source2 is null" .line 2 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source3 is null" .line 3 invoke-static {p2, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const/4 v0, 0x3 new-array v0, v0, [Lkh/o0; 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}, Lkh/j;->N2([Ljava/lang/Object;)Lkh/j; move-result-object p0 invoke-static {p0}, Lkh/i0;->x0(Lok/c;)Lkh/j; move-result-object p0 return-object p0 .end method .method public static v1(Lkh/j;)Lkh/i0; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/j<", "TT;>;)", "Lkh/i0<", "TT;>;" } .end annotation .line 1 new-instance v0, Lio/reactivex/internal/operators/flowable/z0; const/4 v1, 0x0 invoke-direct {v0, p0, v1}, Lio/reactivex/internal/operators/flowable/z0;->(Lkh/j;Ljava/lang/Object;)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object p0 return-object p0 .end method .method public static w(Lok/c;)Lkh/j; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lok/c<", "+", "Lkh/o0<", "+TT;>;>;)", "Lkh/j<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-static {p0}, Lkh/j;->U2(Lok/c;)Lkh/j; move-result-object p0 invoke-static {}, Lio/reactivex/internal/operators/single/SingleInternalHelper;->c()Lph/o; move-result-object v0 invoke-virtual {p0, v0}, Lkh/j;->W0(Lph/o;)Lkh/j; move-result-object p0 return-object p0 .end method .method public static w0(Lkh/o0;Lkh/o0;Lkh/o0;Lkh/o0;)Lkh/j; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/o0<", "+TT;>;", "Lkh/o0<", "+TT;>;", "Lkh/o0<", "+TT;>;", "Lkh/o0<", "+TT;>;)", "Lkh/j<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "source1 is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source2 is null" .line 2 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source3 is null" .line 3 invoke-static {p2, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "source4 is null" .line 4 invoke-static {p3, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const/4 v0, 0x4 new-array v0, v0, [Lkh/o0; 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}, Lkh/j;->N2([Ljava/lang/Object;)Lkh/j; move-result-object p0 invoke-static {p0}, Lkh/i0;->x0(Lok/c;)Lkh/j; move-result-object p0 return-object p0 .end method .method public static w1(Lkh/o0;)Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/o0<", "TT;>;)", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "onSubscribe is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 instance-of v0, p0, Lkh/i0; if-nez v0, :cond_0 .line 3 new-instance v0, Lio/reactivex/internal/operators/single/q; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/single/q;->(Lkh/o0;)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; 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 x0(Lok/c;)Lkh/j; .locals 7 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lok/c<", "+", "Lkh/o0<", "+TT;>;>;)", "Lkh/j<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "sources is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/flowable/d0; invoke-static {}, Lio/reactivex/internal/operators/single/SingleInternalHelper;->c()Lph/o; move-result-object v3 invoke-static {}, Lkh/j;->U()I move-result v6 const/4 v4, 0x0 const v5, 0x7fffffff move-object v1, v0 move-object v2, p0 invoke-direct/range {v1 .. v6}, Lio/reactivex/internal/operators/flowable/d0;->(Lok/c;Lph/o;ZII)V invoke-static {v0}, Lwh/a;->P(Lkh/j;)Lkh/j; move-result-object p0 return-object p0 .end method .method public static y0(Lkh/o0;)Lkh/i0; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/o0<", "+", "Lkh/o0<", "+TT;>;>;)", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "source is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/single/SingleFlatMap; invoke-static {}, Lio/reactivex/internal/functions/Functions;->k()Lph/o; move-result-object v1 invoke-direct {v0, p0, v1}, Lio/reactivex/internal/operators/single/SingleFlatMap;->(Lkh/o0;Lph/o;)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object p0 return-object p0 .end method .method public static y1(Ljava/util/concurrent/Callable;Lph/o;Lph/g;)Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/Callable<", "TU;>;", "Lph/o<", "-TU;+", "Lkh/o0<", "+TT;>;>;", "Lph/g<", "-TU;>;)", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const/4 v0, 0x1 .line 1 invoke-static {p0, p1, p2, v0}, Lkh/i0;->z1(Ljava/util/concurrent/Callable;Lph/o;Lph/g;Z)Lkh/i0; move-result-object p0 return-object p0 .end method .method public static z0(Ljava/lang/Iterable;)Lkh/j; .locals 0 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Iterable<", "+", "Lkh/o0<", "+TT;>;>;)", "Lkh/j<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-static {p0}, Lkh/j;->T2(Ljava/lang/Iterable;)Lkh/j; move-result-object p0 invoke-static {p0}, Lkh/i0;->D0(Lok/c;)Lkh/j; move-result-object p0 return-object p0 .end method .method public static z1(Ljava/util/concurrent/Callable;Lph/o;Lph/g;Z)Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/Callable<", "TU;>;", "Lph/o<", "-TU;+", "Lkh/o0<", "+TT;>;>;", "Lph/g<", "-TU;>;Z)", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "resourceSupplier is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "singleFunction is null" .line 2 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "disposer is null" .line 3 invoke-static {p2, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 4 new-instance v0, Lio/reactivex/internal/operators/single/SingleUsing; invoke-direct {v0, p0, p1, p2, p3}, Lio/reactivex/internal/operators/single/SingleUsing;->(Ljava/util/concurrent/Callable;Lph/o;Lph/g;Z)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object p0 return-object p0 .end method # virtual methods .method public final C(JLjava/util/concurrent/TimeUnit;)Lkh/i0; .locals 6 .annotation system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", ")", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "io.reactivex:computation" .end annotation .line 1 invoke-static {}, Lli/b;->a()Lkh/h0; move-result-object v4 const/4 v5, 0x0 move-object v0, p0 move-wide v1, p1 move-object v3, p3 invoke-virtual/range {v0 .. v5}, Lkh/i0;->E(JLjava/util/concurrent/TimeUnit;Lkh/h0;Z)Lkh/i0; move-result-object p1 return-object p1 .end method .method public final D(JLjava/util/concurrent/TimeUnit;Lkh/h0;)Lkh/i0; .locals 6 .annotation system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", "Lkh/h0;", ")", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "custom" .end annotation const/4 v5, 0x0 move-object v0, p0 move-wide v1, p1 move-object v3, p3 move-object v4, p4 .line 1 invoke-virtual/range {v0 .. v5}, Lkh/i0;->E(JLjava/util/concurrent/TimeUnit;Lkh/h0;Z)Lkh/i0; move-result-object p1 return-object p1 .end method .method public final E(JLjava/util/concurrent/TimeUnit;Lkh/h0;Z)Lkh/i0; .locals 8 .annotation system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", "Lkh/h0;", "Z)", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "custom" .end annotation const-string v0, "unit is null" .line 1 invoke-static {p3, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "scheduler is null" .line 2 invoke-static {p4, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 3 new-instance v0, Lio/reactivex/internal/operators/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/internal/operators/single/d;->(Lkh/o0;JLjava/util/concurrent/TimeUnit;Lkh/h0;Z)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object p1 return-object p1 .end method .method public final E0(Lkh/o0;)Lkh/j; .locals 0 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/o0<", "+TT;>;)", "Lkh/j<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-static {p0, p1}, Lkh/i0;->u0(Lkh/o0;Lkh/o0;)Lkh/j; move-result-object p1 return-object p1 .end method .method public final F(JLjava/util/concurrent/TimeUnit;Z)Lkh/i0; .locals 6 .annotation system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", "Z)", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "io.reactivex:computation" .end annotation .line 1 invoke-static {}, Lli/b;->a()Lkh/h0; move-result-object v4 move-object v0, p0 move-wide v1, p1 move-object v3, p3 move v5, p4 invoke-virtual/range {v0 .. v5}, Lkh/i0;->E(JLjava/util/concurrent/TimeUnit;Lkh/h0;Z)Lkh/i0; move-result-object p1 return-object p1 .end method .method public final G(JLjava/util/concurrent/TimeUnit;)Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", ")", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "io.reactivex:computation" .end annotation .line 1 invoke-static {}, Lli/b;->a()Lkh/h0; move-result-object v0 invoke-virtual {p0, p1, p2, p3, v0}, Lkh/i0;->H(JLjava/util/concurrent/TimeUnit;Lkh/h0;)Lkh/i0; move-result-object p1 return-object p1 .end method .method public final G0(Lkh/h0;)Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/h0;", ")", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "custom" .end annotation const-string v0, "scheduler is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/single/SingleObserveOn; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/single/SingleObserveOn;->(Lkh/o0;Lkh/h0;)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object p1 return-object p1 .end method .method public final H(JLjava/util/concurrent/TimeUnit;Lkh/h0;)Lkh/i0; .locals 0 .annotation system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", "Lkh/h0;", ")", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "custom" .end annotation .line 1 invoke-static {p1, p2, p3, p4}, Lkh/z;->timer(JLjava/util/concurrent/TimeUnit;Lkh/h0;)Lkh/z; move-result-object p1 invoke-virtual {p0, p1}, Lkh/i0;->J(Lkh/e0;)Lkh/i0; move-result-object p1 return-object p1 .end method .method public final H0(Lkh/i0;)Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/i0<", "+TT;>;)", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "resumeSingleInCaseOfError is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 invoke-static {p1}, Lio/reactivex/internal/functions/Functions;->n(Ljava/lang/Object;)Lph/o; move-result-object p1 invoke-virtual {p0, p1}, Lkh/i0;->I0(Lph/o;)Lkh/i0; move-result-object p1 return-object p1 .end method .method public final I(Lkh/g;)Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/g;", ")", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "other is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/single/SingleDelayWithCompletable; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/single/SingleDelayWithCompletable;->(Lkh/o0;Lkh/g;)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object p1 return-object p1 .end method .method public final I0(Lph/o;)Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/o<", "-", "Ljava/lang/Throwable;", "+", "Lkh/o0<", "+TT;>;>;)", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "resumeFunctionInCaseOfError is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/single/SingleResumeNext; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/single/SingleResumeNext;->(Lkh/o0;Lph/o;)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object p1 return-object p1 .end method .method public final J(Lkh/e0;)Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/e0<", "TU;>;)", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "other is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/single/SingleDelayWithObservable; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/single/SingleDelayWithObservable;->(Lkh/o0;Lkh/e0;)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object p1 return-object p1 .end method .method public final J0(Lph/o;)Lkh/i0; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/o<", "Ljava/lang/Throwable;", "+TT;>;)", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "resumeFunction is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/single/x; const/4 v1, 0x0 invoke-direct {v0, p0, p1, v1}, Lio/reactivex/internal/operators/single/x;->(Lkh/o0;Lph/o;Ljava/lang/Object;)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object p1 return-object p1 .end method .method public final K(Lkh/o0;)Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/o0<", "TU;>;)", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "other is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/single/SingleDelayWithSingle; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/single/SingleDelayWithSingle;->(Lkh/o0;Lkh/o0;)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object p1 return-object p1 .end method .method public final K0(Ljava/lang/Object;)Lkh/i0; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(TT;)", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "value is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/single/x; const/4 v1, 0x0 invoke-direct {v0, p0, v1, p1}, Lio/reactivex/internal/operators/single/x;->(Lkh/o0;Lph/o;Ljava/lang/Object;)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object p1 return-object p1 .end method .method public final L(Lok/c;)Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lok/c<", "TU;>;)", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "other is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/single/SingleDelayWithPublisher; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/single/SingleDelayWithPublisher;->(Lkh/o0;Lok/c;)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object p1 return-object p1 .end method .method public final L0()Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 new-instance v0, Lio/reactivex/internal/operators/single/f; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/single/f;->(Lkh/o0;)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object v0 return-object v0 .end method .method public final L1(Lkh/o0;Lph/c;)Lkh/i0; .locals 0 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/o0<", "TU;>;", "Lph/c<", "-TT;-TU;+TR;>;)", "Lkh/i0<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-static {p0, p1, p2}, Lkh/i0;->J1(Lkh/o0;Lkh/o0;Lph/c;)Lkh/i0; move-result-object p1 return-object p1 .end method .method public final M(Lph/o;)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/o<", "-TT;", "Lkh/y<", "TR;>;>;)", "Lkh/q<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/Experimental; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "selector is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/single/e; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/single/e;->(Lkh/i0;Lph/o;)V invoke-static {v0}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object p1 return-object p1 .end method .method public final M0()Lkh/j; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Lkh/j<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-virtual {p0}, Lkh/i0;->r1()Lkh/j; move-result-object v0 invoke-virtual {v0}, Lkh/j;->P4()Lkh/j; move-result-object v0 return-object v0 .end method .method public final N(Lph/g;)Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/g<", "-TT;>;)", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "doAfterSuccess is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/single/g; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/single/g;->(Lkh/o0;Lph/g;)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object p1 return-object p1 .end method .method public final N0(J)Lkh/j; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(J)", "Lkh/j<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-virtual {p0}, Lkh/i0;->r1()Lkh/j; move-result-object v0 invoke-virtual {v0, p1, p2}, Lkh/j;->Q4(J)Lkh/j; move-result-object p1 return-object p1 .end method .method public final O(Lph/a;)Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/a;", ")", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "onAfterTerminate is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/single/h; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/single/h;->(Lkh/o0;Lph/a;)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object p1 return-object p1 .end method .method public final O0(Lph/e;)Lkh/j; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/e;", ")", "Lkh/j<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-virtual {p0}, Lkh/i0;->r1()Lkh/j; move-result-object v0 invoke-virtual {v0, p1}, Lkh/j;->R4(Lph/e;)Lkh/j; move-result-object p1 return-object p1 .end method .method public final P(Lph/a;)Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/a;", ")", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "onFinally is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/single/SingleDoFinally; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/single/SingleDoFinally;->(Lkh/o0;Lph/a;)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object p1 return-object p1 .end method .method public final P0(Lph/o;)Lkh/j; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/o<", "-", "Lkh/j<", "Ljava/lang/Object;", ">;+", "Lok/c<", "*>;>;)", "Lkh/j<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-virtual {p0}, Lkh/i0;->r1()Lkh/j; move-result-object v0 invoke-virtual {v0, p1}, Lkh/j;->S4(Lph/o;)Lkh/j; move-result-object p1 return-object p1 .end method .method public final Q(Lph/a;)Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/a;", ")", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "onDispose is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/single/SingleDoOnDispose; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/single/SingleDoOnDispose;->(Lkh/o0;Lph/a;)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object p1 return-object p1 .end method .method public final Q0()Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-virtual {p0}, Lkh/i0;->r1()Lkh/j; move-result-object v0 invoke-virtual {v0}, Lkh/j;->j5()Lkh/j; move-result-object v0 invoke-static {v0}, Lkh/i0;->v1(Lkh/j;)Lkh/i0; move-result-object v0 return-object v0 .end method .method public final R(Lph/g;)Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/g<", "-", "Ljava/lang/Throwable;", ">;)", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "onError is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/single/i; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/single/i;->(Lkh/o0;Lph/g;)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object p1 return-object p1 .end method .method public final R0(J)Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(J)", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-virtual {p0}, Lkh/i0;->r1()Lkh/j; move-result-object v0 invoke-virtual {v0, p1, p2}, Lkh/j;->k5(J)Lkh/j; move-result-object p1 invoke-static {p1}, Lkh/i0;->v1(Lkh/j;)Lkh/i0; move-result-object p1 return-object p1 .end method .method public final S(Lph/b;)Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/b<", "-TT;-", "Ljava/lang/Throwable;", ">;)", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "onEvent is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/single/j; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/single/j;->(Lkh/o0;Lph/b;)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object p1 return-object p1 .end method .method public final S0(JLph/r;)Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(J", "Lph/r<", "-", "Ljava/lang/Throwable;", ">;)", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-virtual {p0}, Lkh/i0;->r1()Lkh/j; move-result-object v0 invoke-virtual {v0, p1, p2, p3}, Lkh/j;->l5(JLph/r;)Lkh/j; move-result-object p1 invoke-static {p1}, Lkh/i0;->v1(Lkh/j;)Lkh/i0; move-result-object p1 return-object p1 .end method .method public final T(Lph/g;)Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/g<", "-", "Lio/reactivex/disposables/b;", ">;)", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "onSubscribe is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/single/k; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/single/k;->(Lkh/o0;Lph/g;)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object p1 return-object p1 .end method .method public final T0(Lph/d;)Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/d<", "-", "Ljava/lang/Integer;", "-", "Ljava/lang/Throwable;", ">;)", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-virtual {p0}, Lkh/i0;->r1()Lkh/j; move-result-object v0 invoke-virtual {v0, p1}, Lkh/j;->m5(Lph/d;)Lkh/j; move-result-object p1 invoke-static {p1}, Lkh/i0;->v1(Lkh/j;)Lkh/i0; move-result-object p1 return-object p1 .end method .method public final U(Lph/g;)Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/g<", "-TT;>;)", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "onSuccess is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/single/l; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/single/l;->(Lkh/o0;Lph/g;)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object p1 return-object p1 .end method .method public final U0(Lph/r;)Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/r<", "-", "Ljava/lang/Throwable;", ">;)", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-virtual {p0}, Lkh/i0;->r1()Lkh/j; move-result-object v0 invoke-virtual {v0, p1}, Lkh/j;->n5(Lph/r;)Lkh/j; move-result-object p1 invoke-static {p1}, Lkh/i0;->v1(Lkh/j;)Lkh/i0; move-result-object p1 return-object p1 .end method .method public final V0(Lph/o;)Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/o<", "-", "Lkh/j<", "Ljava/lang/Throwable;", ">;+", "Lok/c<", "*>;>;)", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-virtual {p0}, Lkh/i0;->r1()Lkh/j; move-result-object v0 invoke-virtual {v0, p1}, Lkh/j;->p5(Lph/o;)Lkh/j; move-result-object p1 invoke-static {p1}, Lkh/i0;->v1(Lkh/j;)Lkh/i0; move-result-object p1 return-object p1 .end method .method public final W0()Lio/reactivex/disposables/b; .locals 2 .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-static {}, Lio/reactivex/internal/functions/Functions;->h()Lph/g; move-result-object v0 sget-object v1, Lio/reactivex/internal/functions/Functions;->f:Lph/g; invoke-virtual {p0, v0, v1}, Lkh/i0;->Z0(Lph/g;Lph/g;)Lio/reactivex/disposables/b; move-result-object v0 return-object v0 .end method .method public final X0(Lph/b;)Lio/reactivex/disposables/b; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/b<", "-TT;-", "Ljava/lang/Throwable;", ">;)", "Lio/reactivex/disposables/b;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "onCallback is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/observers/BiConsumerSingleObserver; invoke-direct {v0, p1}, Lio/reactivex/internal/observers/BiConsumerSingleObserver;->(Lph/b;)V .line 3 invoke-virtual {p0, v0}, Lkh/i0;->d(Lkh/l0;)V return-object v0 .end method .method public final Y(Lph/r;)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/r<", "-TT;>;)", "Lkh/q<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "predicate is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/maybe/m; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/maybe/m;->(Lkh/o0;Lph/r;)V invoke-static {v0}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object p1 return-object p1 .end method .method public final Y0(Lph/g;)Lio/reactivex/disposables/b; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/g<", "-TT;>;)", "Lio/reactivex/disposables/b;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 sget-object v0, Lio/reactivex/internal/functions/Functions;->f:Lph/g; invoke-virtual {p0, p1, v0}, Lkh/i0;->Z0(Lph/g;Lph/g;)Lio/reactivex/disposables/b; move-result-object p1 return-object p1 .end method .method public final Z(Lph/o;)Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/o<", "-TT;+", "Lkh/o0<", "+TR;>;>;)", "Lkh/i0<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "mapper is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/single/SingleFlatMap; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/single/SingleFlatMap;->(Lkh/o0;Lph/o;)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object p1 return-object p1 .end method .method public final Z0(Lph/g;Lph/g;)Lio/reactivex/disposables/b; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/g<", "-TT;>;", "Lph/g<", "-", "Ljava/lang/Throwable;", ">;)", "Lio/reactivex/disposables/b;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "onSuccess is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "onError is null" .line 2 invoke-static {p2, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 3 new-instance v0, Lio/reactivex/internal/observers/ConsumerSingleObserver; invoke-direct {v0, p1, p2}, Lio/reactivex/internal/observers/ConsumerSingleObserver;->(Lph/g;Lph/g;)V .line 4 invoke-virtual {p0, v0}, Lkh/i0;->d(Lkh/l0;)V return-object v0 .end method .method public final a0(Lph/o;)Lkh/a; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/o<", "-TT;+", "Lkh/g;", ">;)", "Lkh/a;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "mapper is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/single/SingleFlatMapCompletable; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/single/SingleFlatMapCompletable;->(Lkh/o0;Lph/o;)V invoke-static {v0}, Lwh/a;->O(Lkh/a;)Lkh/a; move-result-object p1 return-object p1 .end method .method public abstract a1(Lkh/l0;)V .param p1 # Lkh/l0; .annotation build Lio/reactivex/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/l0<", "-TT;>;)V" } .end annotation .end method .method public final b0(Lph/o;)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/o<", "-TT;+", "Lkh/w<", "+TR;>;>;)", "Lkh/q<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "mapper is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/single/SingleFlatMapMaybe; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/single/SingleFlatMapMaybe;->(Lkh/o0;Lph/o;)V invoke-static {v0}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object p1 return-object p1 .end method .method public final b1(Lkh/h0;)Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/h0;", ")", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "custom" .end annotation const-string v0, "scheduler is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/single/SingleSubscribeOn; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/single/SingleSubscribeOn;->(Lkh/o0;Lkh/h0;)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object p1 return-object p1 .end method .method public final c0(Lph/o;)Lkh/z; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/o<", "-TT;+", "Lkh/e0<", "+TR;>;>;)", "Lkh/z<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "mapper is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/mixed/SingleFlatMapObservable; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/mixed/SingleFlatMapObservable;->(Lkh/o0;Lph/o;)V invoke-static {v0}, Lwh/a;->R(Lkh/z;)Lkh/z; move-result-object p1 return-object p1 .end method .method public final c1(Lkh/l0;)Lkh/l0; .locals 0 .annotation system Ldalvik/annotation/Signature; value = { ";>(TE;)TE;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-virtual {p0, p1}, Lkh/i0;->d(Lkh/l0;)V return-object p1 .end method .method public final d(Lkh/l0;)V .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/l0<", "-TT;>;)V" } .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "subscriber is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 invoke-static {p0, p1}, Lwh/a;->g0(Lkh/i0;Lkh/l0;)Lkh/l0; 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}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 4 :try_start_0 invoke-virtual {p0, p1}, Lkh/i0;->a1(Lkh/l0;)V :try_end_0 .catch Ljava/lang/NullPointerException; {:try_start_0 .. :try_end_0} :catch_0 .catchall {:try_start_0 .. :try_end_0} :catchall_0 return-void :catchall_0 move-exception p1 .line 5 invoke-static {p1}, Lio/reactivex/exceptions/a;->b(Ljava/lang/Throwable;)V .line 6 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(Lph/o;)Lkh/j; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/o<", "-TT;+", "Lok/c<", "+TR;>;>;)", "Lkh/j<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "mapper is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/single/SingleFlatMapPublisher; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/single/SingleFlatMapPublisher;->(Lkh/o0;Lph/o;)V invoke-static {v0}, Lwh/a;->P(Lkh/j;)Lkh/j; move-result-object p1 return-object p1 .end method .method public final d1(Lkh/g;)Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/g;", ")", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "other is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/completable/y; invoke-direct {v0, p1}, Lio/reactivex/internal/operators/completable/y;->(Lkh/g;)V invoke-virtual {p0, v0}, Lkh/i0;->f1(Lok/c;)Lkh/i0; move-result-object p1 return-object p1 .end method .method public final e0(Lph/o;)Lkh/j; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/o<", "-TT;+", "Ljava/lang/Iterable<", "+TU;>;>;)", "Lkh/j<", "TU;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "mapper is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/single/SingleFlatMapIterableFlowable; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/single/SingleFlatMapIterableFlowable;->(Lkh/o0;Lph/o;)V invoke-static {v0}, Lwh/a;->P(Lkh/j;)Lkh/j; move-result-object p1 return-object p1 .end method .method public final e1(Lkh/o0;)Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/o0<", "+TE;>;)", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "other is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/single/SingleToFlowable; invoke-direct {v0, p1}, Lio/reactivex/internal/operators/single/SingleToFlowable;->(Lkh/o0;)V invoke-virtual {p0, v0}, Lkh/i0;->f1(Lok/c;)Lkh/i0; move-result-object p1 return-object p1 .end method .method public final f0(Lph/o;)Lkh/z; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/o<", "-TT;+", "Ljava/lang/Iterable<", "+TU;>;>;)", "Lkh/z<", "TU;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "mapper is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/single/SingleFlatMapIterableObservable; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/single/SingleFlatMapIterableObservable;->(Lkh/o0;Lph/o;)V invoke-static {v0}, Lwh/a;->R(Lkh/z;)Lkh/z; move-result-object p1 return-object p1 .end method .method public final f1(Lok/c;)Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lok/c<", "TE;>;)", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "other is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/single/SingleTakeUntil; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/single/SingleTakeUntil;->(Lkh/o0;Lok/c;)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object p1 return-object p1 .end method .method public final g(Lkh/o0;)Lkh/i0; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/o0<", "+TT;>;)", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "other is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const/4 v0, 0x2 new-array v0, v0, [Lkh/o0; const/4 v1, 0x0 aput-object p0, v0, v1 const/4 v1, 0x1 aput-object p1, v0, v1 .line 2 invoke-static {v0}, Lkh/i0;->f([Lkh/o0;)Lkh/i0; move-result-object p1 return-object p1 .end method .method public final g1()Lio/reactivex/observers/TestObserver; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Lio/reactivex/observers/TestObserver<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 new-instance v0, Lio/reactivex/observers/TestObserver; invoke-direct {v0}, Lio/reactivex/observers/TestObserver;->()V .line 2 invoke-virtual {p0, v0}, Lkh/i0;->d(Lkh/l0;)V return-object v0 .end method .method public final h(Lkh/j0;)Ljava/lang/Object; .locals 1 .param p1 # Lkh/j0; .annotation build Lio/reactivex/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/j0<", "TT;+TR;>;)TR;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "converter is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; move-result-object p1 check-cast p1, Lkh/j0; invoke-interface {p1, p0}, Lkh/j0;->a(Lkh/i0;)Ljava/lang/Object; move-result-object p1 return-object p1 .end method .method public final h1(Z)Lio/reactivex/observers/TestObserver; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(Z)", "Lio/reactivex/observers/TestObserver<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 new-instance v0, Lio/reactivex/observers/TestObserver; invoke-direct {v0}, Lio/reactivex/observers/TestObserver;->()V if-eqz p1, :cond_0 .line 2 invoke-virtual {v0}, Lio/reactivex/observers/TestObserver;->cancel()V .line 3 :cond_0 invoke-virtual {p0, v0}, Lkh/i0;->d(Lkh/l0;)V return-object v0 .end method .method public final i()Ljava/lang/Object; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()TT;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 new-instance v0, Lsh/f; invoke-direct {v0}, Lsh/f;->()V .line 2 invoke-virtual {p0, v0}, Lkh/i0;->d(Lkh/l0;)V .line 3 invoke-virtual {v0}, Lsh/f;->b()Ljava/lang/Object; move-result-object v0 return-object v0 .end method .method public final i1(JLjava/util/concurrent/TimeUnit;)Lkh/i0; .locals 6 .annotation system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", ")", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "io.reactivex:computation" .end annotation .line 1 invoke-static {}, Lli/b;->a()Lkh/h0; move-result-object v4 const/4 v5, 0x0 move-object v0, p0 move-wide v1, p1 move-object v3, p3 invoke-virtual/range {v0 .. v5}, Lkh/i0;->m1(JLjava/util/concurrent/TimeUnit;Lkh/h0;Lkh/o0;)Lkh/i0; move-result-object p1 return-object p1 .end method .method public final j()Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 new-instance v0, Lio/reactivex/internal/operators/single/SingleCache; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/single/SingleCache;->(Lkh/o0;)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object v0 return-object v0 .end method .method public final j1(JLjava/util/concurrent/TimeUnit;Lkh/h0;)Lkh/i0; .locals 6 .annotation system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", "Lkh/h0;", ")", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "custom" .end annotation const/4 v5, 0x0 move-object v0, p0 move-wide v1, p1 move-object v3, p3 move-object v4, p4 .line 1 invoke-virtual/range {v0 .. v5}, Lkh/i0;->m1(JLjava/util/concurrent/TimeUnit;Lkh/h0;Lkh/o0;)Lkh/i0; move-result-object p1 return-object p1 .end method .method public final k(Ljava/lang/Class;)Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Class<", "+TU;>;)", "Lkh/i0<", "TU;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "clazz is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 invoke-static {p1}, Lio/reactivex/internal/functions/Functions;->e(Ljava/lang/Class;)Lph/o; move-result-object p1 invoke-virtual {p0, p1}, Lkh/i0;->r0(Lph/o;)Lkh/i0; move-result-object p1 return-object p1 .end method .method public final k1(JLjava/util/concurrent/TimeUnit;Lkh/h0;Lkh/o0;)Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", "Lkh/h0;", "Lkh/o0<", "+TT;>;)", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "custom" .end annotation const-string v0, "other is null" .line 1 invoke-static {p5, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 invoke-virtual/range {p0 .. p5}, Lkh/i0;->m1(JLjava/util/concurrent/TimeUnit;Lkh/h0;Lkh/o0;)Lkh/i0; move-result-object p1 return-object p1 .end method .method public final l(Lkh/p0;)Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/p0<", "-TT;+TR;>;)", "Lkh/i0<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "transformer is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; move-result-object p1 check-cast p1, Lkh/p0; invoke-interface {p1, p0}, Lkh/p0;->a(Lkh/i0;)Lkh/o0; move-result-object p1 invoke-static {p1}, Lkh/i0;->A1(Lkh/o0;)Lkh/i0; move-result-object p1 return-object p1 .end method .method public final l1(JLjava/util/concurrent/TimeUnit;Lkh/o0;)Lkh/i0; .locals 7 .annotation system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", "Lkh/o0<", "+TT;>;)", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "io.reactivex:computation" .end annotation const-string v0, "other is null" .line 1 invoke-static {p4, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 invoke-static {}, Lli/b;->a()Lkh/h0; move-result-object v5 move-object v1, p0 move-wide v2, p1 move-object v4, p3 move-object v6, p4 invoke-virtual/range {v1 .. v6}, Lkh/i0;->m1(JLjava/util/concurrent/TimeUnit;Lkh/h0;Lkh/o0;)Lkh/i0; move-result-object p1 return-object p1 .end method .method public final m1(JLjava/util/concurrent/TimeUnit;Lkh/h0;Lkh/o0;)Lkh/i0; .locals 8 .annotation system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", "Lkh/h0;", "Lkh/o0<", "+TT;>;)", "Lkh/i0<", "TT;>;" } .end annotation const-string v0, "unit is null" .line 1 invoke-static {p3, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "scheduler is null" .line 2 invoke-static {p4, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 3 new-instance v0, Lio/reactivex/internal/operators/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/internal/operators/single/SingleTimeout;->(Lkh/o0;JLjava/util/concurrent/TimeUnit;Lkh/h0;Lkh/o0;)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object p1 return-object p1 .end method .method public final n0()Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 new-instance v0, Lio/reactivex/internal/operators/single/r; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/single/r;->(Lkh/o0;)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object v0 return-object v0 .end method .method public final o0()Lkh/a; .locals 1 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 new-instance v0, Lio/reactivex/internal/operators/completable/n; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/completable/n;->(Lkh/o0;)V invoke-static {v0}, Lwh/a;->O(Lkh/a;)Lkh/a; move-result-object v0 return-object v0 .end method .method public final p1(Lph/o;)Ljava/lang/Object; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/o<", "-", "Lkh/i0<", "TT;>;TR;>;)TR;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation :try_start_0 const-string v0, "convert is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; move-result-object p1 check-cast p1, Lph/o; invoke-interface {p1, p0}, Lph/o;->apply(Ljava/lang/Object;)Ljava/lang/Object; move-result-object p1 :try_end_0 .catchall {:try_start_0 .. :try_end_0} :catchall_0 return-object p1 :catchall_0 move-exception p1 .line 2 invoke-static {p1}, Lio/reactivex/exceptions/a;->b(Ljava/lang/Throwable;)V .line 3 invoke-static {p1}, Lio/reactivex/internal/util/ExceptionHelper;->f(Ljava/lang/Throwable;)Ljava/lang/RuntimeException; move-result-object p1 throw p1 .end method .method public final q0(Lkh/n0;)Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/n0<", "+TR;-TT;>;)", "Lkh/i0<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "onLift is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/single/t; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/single/t;->(Lkh/o0;Lkh/n0;)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object p1 return-object p1 .end method .method public final q1()Lkh/a; .locals 1 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .annotation runtime Ljava/lang/Deprecated; .end annotation .line 1 new-instance v0, Lio/reactivex/internal/operators/completable/n; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/completable/n;->(Lkh/o0;)V invoke-static {v0}, Lwh/a;->O(Lkh/a;)Lkh/a; move-result-object v0 return-object v0 .end method .method public final r0(Lph/o;)Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/o<", "-TT;+TR;>;)", "Lkh/i0<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "mapper is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/single/u; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/single/u;->(Lkh/o0;Lph/o;)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object p1 return-object p1 .end method .method public final r1()Lkh/j; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Lkh/j<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 instance-of v0, p0, Lrh/b; if-eqz v0, :cond_0 .line 2 move-object v0, p0 check-cast v0, Lrh/b; invoke-interface {v0}, Lrh/b;->c()Lkh/j; move-result-object v0 return-object v0 .line 3 :cond_0 new-instance v0, Lio/reactivex/internal/operators/single/SingleToFlowable; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/single/SingleToFlowable;->(Lkh/o0;)V invoke-static {v0}, Lwh/a;->P(Lkh/j;)Lkh/j; move-result-object v0 return-object v0 .end method .method public final s0()Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Lkh/i0<", "Lkh/y<", "TT;>;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/Experimental; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 new-instance v0, Lio/reactivex/internal/operators/single/v; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/single/v;->(Lkh/i0;)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object v0 return-object v0 .end method .method public final s1()Ljava/util/concurrent/Future; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Ljava/util/concurrent/Future<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 new-instance v0, Lsh/i; invoke-direct {v0}, Lsh/i;->()V invoke-virtual {p0, v0}, Lkh/i0;->c1(Lkh/l0;)Lkh/l0; move-result-object v0 check-cast v0, Ljava/util/concurrent/Future; return-object v0 .end method .method public final t1()Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Lkh/q<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 instance-of v0, p0, Lrh/c; if-eqz v0, :cond_0 .line 2 move-object v0, p0 check-cast v0, Lrh/c; invoke-interface {v0}, Lrh/c;->b()Lkh/q; move-result-object v0 return-object v0 .line 3 :cond_0 new-instance v0, Lio/reactivex/internal/operators/maybe/t; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/t;->(Lkh/o0;)V invoke-static {v0}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object v0 return-object v0 .end method .method public final u1()Lkh/z; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Lkh/z<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 instance-of v0, p0, Lrh/d; if-eqz v0, :cond_0 .line 2 move-object v0, p0 check-cast v0, Lrh/d; invoke-interface {v0}, Lrh/d;->a()Lkh/z; move-result-object v0 return-object v0 .line 3 :cond_0 new-instance v0, Lio/reactivex/internal/operators/single/SingleToObservable; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/single/SingleToObservable;->(Lkh/o0;)V invoke-static {v0}, Lwh/a;->R(Lkh/z;)Lkh/z; move-result-object v0 return-object v0 .end method .method public final x(Lkh/o0;)Lkh/j; .locals 0 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/o0<", "+TT;>;)", "Lkh/j<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-static {p0, p1}, Lkh/i0;->n(Lkh/o0;Lkh/o0;)Lkh/j; move-result-object p1 return-object p1 .end method .method public final x1(Lkh/h0;)Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/h0;", ")", "Lkh/i0<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "custom" .end annotation const-string v0, "scheduler is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/single/SingleUnsubscribeOn; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/single/SingleUnsubscribeOn;->(Lkh/o0;Lkh/h0;)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object p1 return-object p1 .end method .method public final y(Ljava/lang/Object;)Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Object;", ")", "Lkh/i0<", "Ljava/lang/Boolean;", ">;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-static {}, Lio/reactivex/internal/functions/a;->d()Lph/d; move-result-object v0 invoke-virtual {p0, p1, v0}, Lkh/i0;->z(Ljava/lang/Object;Lph/d;)Lkh/i0; move-result-object p1 return-object p1 .end method .method public final z(Ljava/lang/Object;Lph/d;)Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Object;", "Lph/d<", "Ljava/lang/Object;", "Ljava/lang/Object;", ">;)", "Lkh/i0<", "Ljava/lang/Boolean;", ">;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "value is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "comparer is null" .line 2 invoke-static {p2, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 3 new-instance v0, Lio/reactivex/internal/operators/single/b; invoke-direct {v0, p0, p1, p2}, Lio/reactivex/internal/operators/single/b;->(Lkh/o0;Ljava/lang/Object;Lph/d;)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object p1 return-object p1 .end method