.class public abstract Lkh/q; .super Ljava/lang/Object; .source "Maybe.java" # interfaces .implements Lkh/w; # annotations .annotation system Ldalvik/annotation/Signature; value = { "", "Ljava/lang/Object;", "Lkh/w<", "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 A0(Lkh/w;Lkh/w;Lkh/w;Lkh/w;)Lkh/j; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/w<", "+TT;>;", "Lkh/w<", "+TT;>;", "Lkh/w<", "+TT;>;", "Lkh/w<", "+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/w; 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/q;->E0([Lkh/w;)Lkh/j; move-result-object p0 return-object p0 .end method .method public static B0(Lok/c;)Lkh/j; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lok/c<", "+", "Lkh/w<", "+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 const v0, 0x7fffffff .line 1 invoke-static {p0, v0}, Lkh/q;->C0(Lok/c;I)Lkh/j; move-result-object p0 return-object p0 .end method .method public static C0(Lok/c;I)Lkh/j; .locals 7 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lok/c<", "+", "Lkh/w<", "+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, "source is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "maxConcurrency" .line 2 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->h(ILjava/lang/String;)I .line 3 new-instance v0, Lio/reactivex/internal/operators/flowable/d0; invoke-static {}, Lio/reactivex/internal/operators/maybe/MaybeToPublisher;->instance()Lph/o; move-result-object v3 const/4 v4, 0x0 const/4 v6, 0x1 move-object v1, v0 move-object v2, p0 move v5, p1 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 D(Lkh/u;)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/u<", "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, "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 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeCreate; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/MaybeCreate;->(Lkh/u;)V invoke-static {v0}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object p0 return-object p0 .end method .method public static D0(Lkh/w;)Lkh/q; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/w<", "+", "Lkh/w<", "+TT;>;>;)", "Lkh/q<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "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/maybe/MaybeFlatten; invoke-static {}, Lio/reactivex/internal/functions/Functions;->k()Lph/o; move-result-object v1 invoke-direct {v0, p0, v1}, Lio/reactivex/internal/operators/maybe/MaybeFlatten;->(Lkh/w;Lph/o;)V invoke-static {v0}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object p0 return-object p0 .end method .method public static varargs E0([Lkh/w;)Lkh/j; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "([", "Lkh/w<", "+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 array-length v0, p0 if-nez v0, :cond_0 .line 3 invoke-static {}, Lkh/j;->g2()Lkh/j; move-result-object p0 return-object p0 .line 4 :cond_0 array-length v0, p0 const/4 v1, 0x1 if-ne v0, v1, :cond_1 .line 5 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeToFlowable; const/4 v1, 0x0 aget-object p0, p0, v1 invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/MaybeToFlowable;->(Lkh/w;)V invoke-static {v0}, Lwh/a;->P(Lkh/j;)Lkh/j; move-result-object p0 return-object p0 .line 6 :cond_1 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeMergeArray; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/MaybeMergeArray;->([Lkh/w;)V invoke-static {v0}, Lwh/a;->P(Lkh/j;)Lkh/j; move-result-object p0 return-object p0 .end method .method public static F(Ljava/util/concurrent/Callable;)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/Callable<", "+", "Lkh/w<", "+TT;>;>;)", "Lkh/q<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "maybeSupplier is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/maybe/e; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/e;->(Ljava/util/concurrent/Callable;)V invoke-static {v0}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object p0 return-object p0 .end method .method public static varargs F0([Lkh/w;)Lkh/j; .locals 3 .annotation system Ldalvik/annotation/Signature; value = { "([", "Lkh/w<", "+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 array-length v0, p0 if-nez v0, :cond_0 .line 2 invoke-static {}, Lkh/j;->g2()Lkh/j; move-result-object p0 return-object p0 .line 3 :cond_0 invoke-static {p0}, Lkh/j;->N2([Ljava/lang/Object;)Lkh/j; move-result-object v0 invoke-static {}, Lio/reactivex/internal/operators/maybe/MaybeToPublisher;->instance()Lph/o; move-result-object v1 const/4 v2, 0x1 array-length p0, p0 invoke-virtual {v0, v1, v2, p0}, Lkh/j;->x2(Lph/o;ZI)Lkh/j; move-result-object p0 return-object p0 .end method .method public static G0(Ljava/lang/Iterable;)Lkh/j; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Iterable<", "+", "Lkh/w<", "+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}, Lkh/j;->T2(Ljava/lang/Iterable;)Lkh/j; move-result-object p0 invoke-static {}, Lio/reactivex/internal/operators/maybe/MaybeToPublisher;->instance()Lph/o; move-result-object v0 const/4 v1, 0x1 invoke-virtual {p0, v0, v1}, Lkh/j;->w2(Lph/o;Z)Lkh/j; move-result-object p0 return-object p0 .end method .method public static G1(JLjava/util/concurrent/TimeUnit;)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", ")", "Lkh/q<", "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/q;->H1(JLjava/util/concurrent/TimeUnit;Lkh/h0;)Lkh/q; move-result-object p0 return-object p0 .end method .method public static H0(Lkh/w;Lkh/w;)Lkh/j; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/w<", "+TT;>;", "Lkh/w<", "+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/w; const/4 v1, 0x0 aput-object p0, v0, v1 const/4 p0, 0x1 aput-object p1, v0, p0 .line 3 invoke-static {v0}, Lkh/q;->F0([Lkh/w;)Lkh/j; move-result-object p0 return-object p0 .end method .method public static H1(JLjava/util/concurrent/TimeUnit;Lkh/h0;)Lkh/q; .locals 3 .annotation system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", "Lkh/h0;", ")", "Lkh/q<", "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/maybe/MaybeTimer; const-wide/16 v1, 0x0 invoke-static {v1, v2, p0, p1}, Ljava/lang/Math;->max(JJ)J move-result-wide p0 invoke-direct {v0, p0, p1, p2, p3}, Lio/reactivex/internal/operators/maybe/MaybeTimer;->(JLjava/util/concurrent/TimeUnit;Lkh/h0;)V invoke-static {v0}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object p0 return-object p0 .end method .method public static I0(Lkh/w;Lkh/w;Lkh/w;)Lkh/j; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/w<", "+TT;>;", "Lkh/w<", "+TT;>;", "Lkh/w<", "+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/w; 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/q;->F0([Lkh/w;)Lkh/j; move-result-object p0 return-object p0 .end method .method public static J0(Lkh/w;Lkh/w;Lkh/w;Lkh/w;)Lkh/j; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/w<", "+TT;>;", "Lkh/w<", "+TT;>;", "Lkh/w<", "+TT;>;", "Lkh/w<", "+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/w; 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/q;->F0([Lkh/w;)Lkh/j; move-result-object p0 return-object p0 .end method .method public static K0(Lok/c;)Lkh/j; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lok/c<", "+", "Lkh/w<", "+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 const v0, 0x7fffffff .line 1 invoke-static {p0, v0}, Lkh/q;->L0(Lok/c;I)Lkh/j; move-result-object p0 return-object p0 .end method .method public static L0(Lok/c;I)Lkh/j; .locals 7 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lok/c<", "+", "Lkh/w<", "+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, "source is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "maxConcurrency" .line 2 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->h(ILjava/lang/String;)I .line 3 new-instance v0, Lio/reactivex/internal/operators/flowable/d0; invoke-static {}, Lio/reactivex/internal/operators/maybe/MaybeToPublisher;->instance()Lph/o; move-result-object v3 const/4 v4, 0x1 const/4 v6, 0x1 move-object v1, v0 move-object v2, p0 move v5, p1 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 N0()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 sget-object v0, Lio/reactivex/internal/operators/maybe/d0;->a:Lio/reactivex/internal/operators/maybe/d0; invoke-static {v0}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object v0 return-object v0 .end method .method public static N1(Lkh/w;)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/w<", "TT;>;)", "Lkh/q<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 instance-of v0, p0, Lkh/q; if-nez v0, :cond_0 const-string v0, "onSubscribe 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/maybe/i0; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/i0;->(Lkh/w;)V invoke-static {v0}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object p0 return-object p0 .line 4 :cond_0 new-instance p0, Ljava/lang/IllegalArgumentException; const-string v0, "unsafeCreate(Maybe) should be upgraded" invoke-direct {p0, v0}, Ljava/lang/IllegalArgumentException;->(Ljava/lang/String;)V throw p0 .end method .method public static P1(Ljava/util/concurrent/Callable;Lph/o;Lph/g;)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/Callable<", "+TD;>;", "Lph/o<", "-TD;+", "Lkh/w<", "+TT;>;>;", "Lph/g<", "-TD;>;)", "Lkh/q<", "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/q;->Q1(Ljava/util/concurrent/Callable;Lph/o;Lph/g;Z)Lkh/q; move-result-object p0 return-object p0 .end method .method public static Q1(Ljava/util/concurrent/Callable;Lph/o;Lph/g;Z)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/Callable<", "+TD;>;", "Lph/o<", "-TD;+", "Lkh/w<", "+TT;>;>;", "Lph/g<", "-TD;>;Z)", "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, "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, "sourceSupplier 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/maybe/MaybeUsing; invoke-direct {v0, p0, p1, p2, p3}, Lio/reactivex/internal/operators/maybe/MaybeUsing;->(Ljava/util/concurrent/Callable;Lph/o;Lph/g;Z)V invoke-static {v0}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object p0 return-object p0 .end method .method public static R1(Lkh/w;)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/w<", "TT;>;)", "Lkh/q<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 instance-of v0, p0, Lkh/q; if-eqz v0, :cond_0 .line 2 check-cast p0, Lkh/q; invoke-static {p0}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object p0 return-object p0 :cond_0 const-string v0, "onSubscribe is null" .line 3 invoke-static {p0, 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/maybe/i0; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/i0;->(Lkh/w;)V invoke-static {v0}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object p0 return-object p0 .end method .method public static S1(Ljava/lang/Iterable;Lph/o;)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Iterable<", "+", "Lkh/w<", "+TT;>;>;", "Lph/o<", "-[", "Ljava/lang/Object;", "+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, "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/maybe/j0; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/maybe/j0;->(Ljava/lang/Iterable;Lph/o;)V invoke-static {v0}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object p0 return-object p0 .end method .method public static T1(Lkh/w;Lkh/w;Lkh/w;Lkh/w;Lkh/w;Lkh/w;Lkh/w;Lkh/w;Lkh/w;Lph/n;)Lkh/q; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/w<", "+TT1;>;", "Lkh/w<", "+TT2;>;", "Lkh/w<", "+TT3;>;", "Lkh/w<", "+TT4;>;", "Lkh/w<", "+TT5;>;", "Lkh/w<", "+TT6;>;", "Lkh/w<", "+TT7;>;", "Lkh/w<", "+TT8;>;", "Lkh/w<", "+TT9;>;", "Lph/n<", "-TT1;-TT2;-TT3;-TT4;-TT5;-TT6;-TT7;-TT8;-TT9;+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, "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/w; 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/q;->b2(Lph/o;[Lkh/w;)Lkh/q; move-result-object p0 return-object p0 .end method .method public static U1(Lkh/w;Lkh/w;Lkh/w;Lkh/w;Lkh/w;Lkh/w;Lkh/w;Lkh/w;Lph/m;)Lkh/q; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/w<", "+TT1;>;", "Lkh/w<", "+TT2;>;", "Lkh/w<", "+TT3;>;", "Lkh/w<", "+TT4;>;", "Lkh/w<", "+TT5;>;", "Lkh/w<", "+TT6;>;", "Lkh/w<", "+TT7;>;", "Lkh/w<", "+TT8;>;", "Lph/m<", "-TT1;-TT2;-TT3;-TT4;-TT5;-TT6;-TT7;-TT8;+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, "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/w; 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/q;->b2(Lph/o;[Lkh/w;)Lkh/q; move-result-object p0 return-object p0 .end method .method public static V()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 sget-object v0, Lio/reactivex/internal/operators/maybe/i;->a:Lio/reactivex/internal/operators/maybe/i; invoke-static {v0}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object v0 return-object v0 .end method .method public static V1(Lkh/w;Lkh/w;Lkh/w;Lkh/w;Lkh/w;Lkh/w;Lkh/w;Lph/l;)Lkh/q; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/w<", "+TT1;>;", "Lkh/w<", "+TT2;>;", "Lkh/w<", "+TT3;>;", "Lkh/w<", "+TT4;>;", "Lkh/w<", "+TT5;>;", "Lkh/w<", "+TT6;>;", "Lkh/w<", "+TT7;>;", "Lph/l<", "-TT1;-TT2;-TT3;-TT4;-TT5;-TT6;-TT7;+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, "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/w; 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/q;->b2(Lph/o;[Lkh/w;)Lkh/q; move-result-object p0 return-object p0 .end method .method public static W(Ljava/lang/Throwable;)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Throwable;", ")", "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, "exception is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/maybe/j; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/j;->(Ljava/lang/Throwable;)V invoke-static {v0}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object p0 return-object p0 .end method .method public static W1(Lkh/w;Lkh/w;Lkh/w;Lkh/w;Lkh/w;Lkh/w;Lph/k;)Lkh/q; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/w<", "+TT1;>;", "Lkh/w<", "+TT2;>;", "Lkh/w<", "+TT3;>;", "Lkh/w<", "+TT4;>;", "Lkh/w<", "+TT5;>;", "Lkh/w<", "+TT6;>;", "Lph/k<", "-TT1;-TT2;-TT3;-TT4;-TT5;-TT6;+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, "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/w; 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/q;->b2(Lph/o;[Lkh/w;)Lkh/q; move-result-object p0 return-object p0 .end method .method public static X(Ljava/util/concurrent/Callable;)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/Callable<", "+", "Ljava/lang/Throwable;", ">;)", "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, "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/maybe/k; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/k;->(Ljava/util/concurrent/Callable;)V invoke-static {v0}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object p0 return-object p0 .end method .method public static X1(Lkh/w;Lkh/w;Lkh/w;Lkh/w;Lkh/w;Lph/j;)Lkh/q; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/w<", "+TT1;>;", "Lkh/w<", "+TT2;>;", "Lkh/w<", "+TT3;>;", "Lkh/w<", "+TT4;>;", "Lkh/w<", "+TT5;>;", "Lph/j<", "-TT1;-TT2;-TT3;-TT4;-TT5;+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, "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/w; 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/q;->b2(Lph/o;[Lkh/w;)Lkh/q; move-result-object p0 return-object p0 .end method .method public static Y1(Lkh/w;Lkh/w;Lkh/w;Lkh/w;Lph/i;)Lkh/q; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/w<", "+TT1;>;", "Lkh/w<", "+TT2;>;", "Lkh/w<", "+TT3;>;", "Lkh/w<", "+TT4;>;", "Lph/i<", "-TT1;-TT2;-TT3;-TT4;+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, "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/w; 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/q;->b2(Lph/o;[Lkh/w;)Lkh/q; move-result-object p0 return-object p0 .end method .method public static Z1(Lkh/w;Lkh/w;Lkh/w;Lph/h;)Lkh/q; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/w<", "+TT1;>;", "Lkh/w<", "+TT2;>;", "Lkh/w<", "+TT3;>;", "Lph/h<", "-TT1;-TT2;-TT3;+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, "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/w; 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/q;->b2(Lph/o;[Lkh/w;)Lkh/q; move-result-object p0 return-object p0 .end method .method public static a2(Lkh/w;Lkh/w;Lph/c;)Lkh/q; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/w<", "+TT1;>;", "Lkh/w<", "+TT2;>;", "Lph/c<", "-TT1;-TT2;+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, "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/w; const/4 v1, 0x0 aput-object p0, v0, v1 const/4 p0, 0x1 aput-object p1, v0, p0 invoke-static {p2, v0}, Lkh/q;->b2(Lph/o;[Lkh/w;)Lkh/q; move-result-object p0 return-object p0 .end method .method public static varargs b2(Lph/o;[Lkh/w;)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/o<", "-[", "Ljava/lang/Object;", "+TR;>;[", "Lkh/w<", "+TT;>;)", "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, "sources 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 array-length v0, p1 if-nez v0, :cond_0 .line 3 invoke-static {}, Lkh/q;->V()Lkh/q; move-result-object p0 return-object p0 :cond_0 const-string v0, "zipper is null" .line 4 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 5 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeZipArray; invoke-direct {v0, p1, p0}, Lio/reactivex/internal/operators/maybe/MaybeZipArray;->([Lkh/w;Lph/o;)V invoke-static {v0}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object p0 return-object p0 .end method .method public static d(Ljava/lang/Iterable;)Lkh/q; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Iterable<", "+", "Lkh/w<", "+TT;>;>;)", "Lkh/q<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "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/maybe/b; const/4 v1, 0x0 invoke-direct {v0, v1, p0}, Lio/reactivex/internal/operators/maybe/b;->([Lkh/w;Ljava/lang/Iterable;)V invoke-static {v0}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object p0 return-object p0 .end method .method public static varargs e([Lkh/w;)Lkh/q; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "([", "Lkh/w<", "+TT;>;)", "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 array-length v0, p0 if-nez v0, :cond_0 .line 2 invoke-static {}, Lkh/q;->V()Lkh/q; 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/q;->R1(Lkh/w;)Lkh/q; move-result-object p0 return-object p0 .line 5 :cond_1 new-instance v0, Lio/reactivex/internal/operators/maybe/b; const/4 v1, 0x0 invoke-direct {v0, p0, v1}, Lio/reactivex/internal/operators/maybe/b;->([Lkh/w;Ljava/lang/Iterable;)V invoke-static {v0}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object p0 return-object p0 .end method .method public static j0(Lph/a;)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/a;", ")", "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, "run is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/maybe/o; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/o;->(Lph/a;)V invoke-static {v0}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object p0 return-object p0 .end method .method public static j1(Lkh/w;Lkh/w;)Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/w<", "+TT;>;", "Lkh/w<", "+TT;>;)", "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-static {p0, p1, v0}, Lkh/q;->k1(Lkh/w;Lkh/w;Lph/d;)Lkh/i0; move-result-object p0 return-object p0 .end method .method public static k0(Ljava/util/concurrent/Callable;)Lkh/q; .locals 1 .param p0 # Ljava/util/concurrent/Callable; .annotation build Lio/reactivex/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/Callable<", "+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, "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/maybe/p; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/p;->(Ljava/util/concurrent/Callable;)V invoke-static {v0}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object p0 return-object p0 .end method .method public static k1(Lkh/w;Lkh/w;Lph/d;)Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/w<", "+TT;>;", "Lkh/w<", "+TT;>;", "Lph/d<", "-TT;-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, "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, "isEqual 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/maybe/MaybeEqualSingle; invoke-direct {v0, p0, p1, p2}, Lio/reactivex/internal/operators/maybe/MaybeEqualSingle;->(Lkh/w;Lkh/w;Lph/d;)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object p0 return-object p0 .end method .method public static l0(Lkh/g;)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/g;", ")", "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, "completableSource is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/maybe/q; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/q;->(Lkh/g;)V invoke-static {v0}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object p0 return-object p0 .end method .method public static m(Ljava/lang/Iterable;)Lkh/j; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Iterable<", "+", "Lkh/w<", "+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/maybe/MaybeConcatIterable; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/MaybeConcatIterable;->(Ljava/lang/Iterable;)V invoke-static {v0}, Lwh/a;->P(Lkh/j;)Lkh/j; move-result-object p0 return-object p0 .end method .method public static m0(Ljava/util/concurrent/Future;)Lkh/q; .locals 4 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/Future<", "+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, "future is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/maybe/r; const-wide/16 v1, 0x0 const/4 v3, 0x0 invoke-direct {v0, p0, v1, v2, v3}, Lio/reactivex/internal/operators/maybe/r;->(Ljava/util/concurrent/Future;JLjava/util/concurrent/TimeUnit;)V invoke-static {v0}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object p0 return-object p0 .end method .method public static n(Lkh/w;Lkh/w;)Lkh/j; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/w<", "+TT;>;", "Lkh/w<", "+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/w; const/4 v1, 0x0 aput-object p0, v0, v1 const/4 p0, 0x1 aput-object p1, v0, p0 .line 3 invoke-static {v0}, Lkh/q;->s([Lkh/w;)Lkh/j; move-result-object p0 return-object p0 .end method .method public static n0(Ljava/util/concurrent/Future;JLjava/util/concurrent/TimeUnit;)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/Future<", "+TT;>;J", "Ljava/util/concurrent/TimeUnit;", ")", "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, "future 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, "unit 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/maybe/r; invoke-direct {v0, p0, p1, p2, p3}, Lio/reactivex/internal/operators/maybe/r;->(Ljava/util/concurrent/Future;JLjava/util/concurrent/TimeUnit;)V invoke-static {v0}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object p0 return-object p0 .end method .method public static o(Lkh/w;Lkh/w;Lkh/w;)Lkh/j; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/w<", "+TT;>;", "Lkh/w<", "+TT;>;", "Lkh/w<", "+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/w; 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/q;->s([Lkh/w;)Lkh/j; move-result-object p0 return-object p0 .end method .method public static o0(Ljava/lang/Runnable;)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Runnable;", ")", "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, "run is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/maybe/s; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/s;->(Ljava/lang/Runnable;)V invoke-static {v0}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object p0 return-object p0 .end method .method public static p(Lkh/w;Lkh/w;Lkh/w;Lkh/w;)Lkh/j; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/w<", "+TT;>;", "Lkh/w<", "+TT;>;", "Lkh/w<", "+TT;>;", "Lkh/w<", "+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/w; 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/q;->s([Lkh/w;)Lkh/j; move-result-object p0 return-object p0 .end method .method public static p0(Lkh/o0;)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/o0<", "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, "singleSource is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/maybe/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 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/w<", "+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 const/4 v0, 0x2 .line 1 invoke-static {p0, v0}, Lkh/q;->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/w<", "+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/maybe/MaybeToPublisher;->instance()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 varargs s([Lkh/w;)Lkh/j; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "([", "Lkh/w<", "+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 array-length v0, p0 if-nez v0, :cond_0 .line 3 invoke-static {}, Lkh/j;->g2()Lkh/j; move-result-object p0 return-object p0 .line 4 :cond_0 array-length v0, p0 const/4 v1, 0x1 if-ne v0, v1, :cond_1 .line 5 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeToFlowable; const/4 v1, 0x0 aget-object p0, p0, v1 invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/MaybeToFlowable;->(Lkh/w;)V invoke-static {v0}, Lwh/a;->P(Lkh/j;)Lkh/j; move-result-object p0 return-object p0 .line 6 :cond_1 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeConcatArray; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/MaybeConcatArray;->([Lkh/w;)V invoke-static {v0}, Lwh/a;->P(Lkh/j;)Lkh/j; move-result-object p0 return-object p0 .end method .method public static varargs t([Lkh/w;)Lkh/j; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "([", "Lkh/w<", "+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 array-length v0, p0 if-nez v0, :cond_0 .line 2 invoke-static {}, Lkh/j;->g2()Lkh/j; 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 .line 4 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeToFlowable; const/4 v1, 0x0 aget-object p0, p0, v1 invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/MaybeToFlowable;->(Lkh/w;)V invoke-static {v0}, Lwh/a;->P(Lkh/j;)Lkh/j; move-result-object p0 return-object p0 .line 5 :cond_1 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeConcatArrayDelayError; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/MaybeConcatArrayDelayError;->([Lkh/w;)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/Object;)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(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, "item is null" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/maybe/z; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/z;->(Ljava/lang/Object;)V invoke-static {v0}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object p0 return-object p0 .end method .method public static varargs u([Lkh/w;)Lkh/j; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "([", "Lkh/w<", "+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}, Lkh/j;->N2([Ljava/lang/Object;)Lkh/j; move-result-object p0 invoke-static {}, Lio/reactivex/internal/operators/maybe/MaybeToPublisher;->instance()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 v(Ljava/lang/Iterable;)Lkh/j; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Iterable<", "+", "Lkh/w<", "+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 invoke-static {p0}, Lkh/j;->T2(Ljava/lang/Iterable;)Lkh/j; move-result-object p0 invoke-static {}, Lio/reactivex/internal/operators/maybe/MaybeToPublisher;->instance()Lph/o; move-result-object v0 invoke-virtual {p0, v0}, Lkh/j;->U0(Lph/o;)Lkh/j; 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/w<", "+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}, Lkh/j;->U2(Lok/c;)Lkh/j; move-result-object p0 invoke-static {}, Lio/reactivex/internal/operators/maybe/MaybeToPublisher;->instance()Lph/o; move-result-object v0 invoke-virtual {p0, v0}, Lkh/j;->U0(Lph/o;)Lkh/j; move-result-object p0 return-object p0 .end method .method public static x(Ljava/lang/Iterable;)Lkh/j; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Iterable<", "+", "Lkh/w<", "+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}, Lkh/j;->T2(Ljava/lang/Iterable;)Lkh/j; move-result-object p0 invoke-static {}, Lio/reactivex/internal/operators/maybe/MaybeToPublisher;->instance()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 x0(Ljava/lang/Iterable;)Lkh/j; .locals 0 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Iterable<", "+", "Lkh/w<", "+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}, Lkh/j;->T2(Ljava/lang/Iterable;)Lkh/j; move-result-object p0 invoke-static {p0}, Lkh/q;->B0(Lok/c;)Lkh/j; move-result-object p0 return-object p0 .end method .method public static y(Lok/c;)Lkh/j; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lok/c<", "+", "Lkh/w<", "+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}, Lkh/j;->U2(Lok/c;)Lkh/j; move-result-object p0 invoke-static {}, Lio/reactivex/internal/operators/maybe/MaybeToPublisher;->instance()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 y0(Lkh/w;Lkh/w;)Lkh/j; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/w<", "+TT;>;", "Lkh/w<", "+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/w; const/4 v1, 0x0 aput-object p0, v0, v1 const/4 p0, 0x1 aput-object p1, v0, p0 .line 3 invoke-static {v0}, Lkh/q;->E0([Lkh/w;)Lkh/j; move-result-object p0 return-object p0 .end method .method public static z0(Lkh/w;Lkh/w;Lkh/w;)Lkh/j; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/w<", "+TT;>;", "Lkh/w<", "+TT;>;", "Lkh/w<", "+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/w; 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/q;->E0([Lkh/w;)Lkh/j; move-result-object p0 return-object p0 .end method # virtual methods .method public final A(Lkh/w;)Lkh/j; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/w<", "+TT;>;)", "Lkh/j<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "other is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 invoke-static {p0, p1}, Lkh/q;->n(Lkh/w;Lkh/w;)Lkh/j; move-result-object p1 return-object p1 .end method .method public final A1(JLjava/util/concurrent/TimeUnit;Lkh/h0;)Lkh/q; .locals 0 .annotation system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", "Lkh/h0;", ")", "Lkh/q<", "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/q;->H1(JLjava/util/concurrent/TimeUnit;Lkh/h0;)Lkh/q; move-result-object p1 invoke-virtual {p0, p1}, Lkh/q;->C1(Lkh/w;)Lkh/q; move-result-object p1 return-object p1 .end method .method public final B(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 build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "item 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/c; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/maybe/c;->(Lkh/w;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 B1(JLjava/util/concurrent/TimeUnit;Lkh/h0;Lkh/w;)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", "Lkh/h0;", "Lkh/w<", "+TT;>;)", "Lkh/q<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "custom" .end annotation const-string v0, "fallback 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-static {p1, p2, p3, p4}, Lkh/q;->H1(JLjava/util/concurrent/TimeUnit;Lkh/h0;)Lkh/q; move-result-object p1 invoke-virtual {p0, p1, p5}, Lkh/q;->D1(Lkh/w;Lkh/w;)Lkh/q; move-result-object p1 return-object p1 .end method .method public final C()Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Lkh/i0<", "Ljava/lang/Long;", ">;" } .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/maybe/d; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/d;->(Lkh/w;)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object v0 return-object v0 .end method .method public final C1(Lkh/w;)Lkh/q; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/w<", "TU;>;)", "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, "timeoutIndicator 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/MaybeTimeoutMaybe; const/4 v1, 0x0 invoke-direct {v0, p0, p1, v1}, Lio/reactivex/internal/operators/maybe/MaybeTimeoutMaybe;->(Lkh/w;Lkh/w;Lkh/w;)V invoke-static {v0}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object p1 return-object p1 .end method .method public final D1(Lkh/w;Lkh/w;)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/w<", "TU;>;", "Lkh/w<", "+TT;>;)", "Lkh/q<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "timeoutIndicator 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, "fallback 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/maybe/MaybeTimeoutMaybe; invoke-direct {v0, p0, p1, p2}, Lio/reactivex/internal/operators/maybe/MaybeTimeoutMaybe;->(Lkh/w;Lkh/w;Lkh/w;)V invoke-static {v0}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object p1 return-object p1 .end method .method public final E(Ljava/lang/Object;)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(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, "item 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}, Lkh/q;->t0(Ljava/lang/Object;)Lkh/q; move-result-object p1 invoke-virtual {p0, p1}, Lkh/q;->s1(Lkh/w;)Lkh/q; move-result-object p1 return-object p1 .end method .method public final E1(Lok/c;)Lkh/q; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lok/c<", "TU;>;)", "Lkh/q<", "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, "timeoutIndicator 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/MaybeTimeoutPublisher; const/4 v1, 0x0 invoke-direct {v0, p0, p1, v1}, Lio/reactivex/internal/operators/maybe/MaybeTimeoutPublisher;->(Lkh/w;Lok/c;Lkh/w;)V invoke-static {v0}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object p1 return-object p1 .end method .method public final F1(Lok/c;Lkh/w;)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lok/c<", "TU;>;", "Lkh/w<", "+TT;>;)", "Lkh/q<", "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, "timeoutIndicator 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, "fallback 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/maybe/MaybeTimeoutPublisher; invoke-direct {v0, p0, p1, p2}, Lio/reactivex/internal/operators/maybe/MaybeTimeoutPublisher;->(Lkh/w;Lok/c;Lkh/w;)V invoke-static {v0}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object p1 return-object p1 .end method .method public final G(JLjava/util/concurrent/TimeUnit;)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", ")", "Lkh/q<", "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/q;->H(JLjava/util/concurrent/TimeUnit;Lkh/h0;)Lkh/q; move-result-object p1 return-object p1 .end method .method public final H(JLjava/util/concurrent/TimeUnit;Lkh/h0;)Lkh/q; .locals 7 .annotation system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", "Lkh/h0;", ")", "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 = "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/maybe/MaybeDelay; const-wide/16 v1, 0x0 invoke-static {v1, v2, p1, p2}, Ljava/lang/Math;->max(JJ)J move-result-wide v3 move-object v1, v0 move-object v2, p0 move-object v5, p3 move-object v6, p4 invoke-direct/range {v1 .. v6}, Lio/reactivex/internal/operators/maybe/MaybeDelay;->(Lkh/w;JLjava/util/concurrent/TimeUnit;Lkh/h0;)V invoke-static {v0}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object p1 return-object p1 .end method .method public final I(Lok/c;)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lok/c<", "TU;>;)", "Lkh/q<", "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, "delayIndicator 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/MaybeDelayOtherPublisher; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/maybe/MaybeDelayOtherPublisher;->(Lkh/w;Lok/c;)V invoke-static {v0}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object p1 return-object p1 .end method .method public final I1(Lph/o;)Ljava/lang/Object; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/o<", "-", "Lkh/q<", "TT;>;TR;>;)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 :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 J(JLjava/util/concurrent/TimeUnit;)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", ")", "Lkh/q<", "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/q;->K(JLjava/util/concurrent/TimeUnit;Lkh/h0;)Lkh/q; move-result-object p1 return-object p1 .end method .method public final J1()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/maybe/MaybeToFlowable; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/MaybeToFlowable;->(Lkh/w;)V invoke-static {v0}, Lwh/a;->P(Lkh/j;)Lkh/j; move-result-object v0 return-object v0 .end method .method public final K(JLjava/util/concurrent/TimeUnit;Lkh/h0;)Lkh/q; .locals 0 .annotation system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", "Lkh/h0;", ")", "Lkh/q<", "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/j;->r7(JLjava/util/concurrent/TimeUnit;Lkh/h0;)Lkh/j; move-result-object p1 invoke-virtual {p0, p1}, Lkh/q;->L(Lok/c;)Lkh/q; move-result-object p1 return-object p1 .end method .method public final K1()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/maybe/MaybeToObservable; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/MaybeToObservable;->(Lkh/w;)V invoke-static {v0}, Lwh/a;->R(Lkh/z;)Lkh/z; move-result-object v0 return-object v0 .end method .method public final L(Lok/c;)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lok/c<", "TU;>;)", "Lkh/q<", "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, "subscriptionIndicator 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/MaybeDelaySubscriptionOtherPublisher; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/maybe/MaybeDelaySubscriptionOtherPublisher;->(Lkh/w;Lok/c;)V invoke-static {v0}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object p1 return-object p1 .end method .method public final L1()Lkh/i0; .locals 2 .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/maybe/h0; const/4 v1, 0x0 invoke-direct {v0, p0, v1}, Lio/reactivex/internal/operators/maybe/h0;->(Lkh/w;Ljava/lang/Object;)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object v0 return-object v0 .end method .method public final M(Lph/g;)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/g<", "-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, "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/maybe/g; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/maybe/g;->(Lkh/w;Lph/g;)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/w;)Lkh/j; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/w<", "+TT;>;)", "Lkh/j<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "other is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 invoke-static {p0, p1}, Lkh/q;->y0(Lkh/w;Lkh/w;)Lkh/j; move-result-object p1 return-object p1 .end method .method public final M1(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, "defaultValue 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/h0; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/maybe/h0;->(Lkh/w;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 N(Lph/a;)Lkh/q; .locals 9 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/a;", ")", "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 .line 1 new-instance v8, Lio/reactivex/internal/operators/maybe/g0; .line 2 invoke-static {}, Lio/reactivex/internal/functions/Functions;->h()Lph/g; move-result-object v2 .line 3 invoke-static {}, Lio/reactivex/internal/functions/Functions;->h()Lph/g; move-result-object v3 .line 4 invoke-static {}, Lio/reactivex/internal/functions/Functions;->h()Lph/g; move-result-object v4 sget-object v7, Lio/reactivex/internal/functions/Functions;->c:Lph/a; const-string v0, "onAfterTerminate is null" .line 5 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; move-result-object p1 move-object v6, p1 check-cast v6, Lph/a; move-object v0, v8 move-object v1, p0 move-object v5, v7 invoke-direct/range {v0 .. v7}, Lio/reactivex/internal/operators/maybe/g0;->(Lkh/w;Lph/g;Lph/g;Lph/g;Lph/a;Lph/a;Lph/a;)V .line 6 invoke-static {v8}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object p1 return-object p1 .end method .method public final O(Lph/a;)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/a;", ")", "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, "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/maybe/MaybeDoFinally; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/maybe/MaybeDoFinally;->(Lkh/w;Lph/a;)V invoke-static {v0}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object p1 return-object p1 .end method .method public final O0(Lkh/h0;)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/h0;", ")", "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 = "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/maybe/MaybeObserveOn; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/maybe/MaybeObserveOn;->(Lkh/w;Lkh/h0;)V invoke-static {v0}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object p1 return-object p1 .end method .method public final O1(Lkh/h0;)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/h0;", ")", "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 = "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/maybe/MaybeUnsubscribeOn; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/maybe/MaybeUnsubscribeOn;->(Lkh/w;Lkh/h0;)V invoke-static {v0}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object p1 return-object p1 .end method .method public final P(Lph/a;)Lkh/q; .locals 9 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/a;", ")", "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 .line 1 new-instance v8, Lio/reactivex/internal/operators/maybe/g0; .line 2 invoke-static {}, Lio/reactivex/internal/functions/Functions;->h()Lph/g; move-result-object v2 .line 3 invoke-static {}, Lio/reactivex/internal/functions/Functions;->h()Lph/g; move-result-object v3 .line 4 invoke-static {}, Lio/reactivex/internal/functions/Functions;->h()Lph/g; move-result-object v4 const-string v0, "onComplete is null" .line 5 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; move-result-object p1 move-object v5, p1 check-cast v5, Lph/a; sget-object v7, Lio/reactivex/internal/functions/Functions;->c:Lph/a; move-object v0, v8 move-object v1, p0 move-object v6, v7 invoke-direct/range {v0 .. v7}, Lio/reactivex/internal/operators/maybe/g0;->(Lkh/w;Lph/g;Lph/g;Lph/g;Lph/a;Lph/a;Lph/a;)V .line 6 invoke-static {v8}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object p1 return-object p1 .end method .method public final P0(Ljava/lang/Class;)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Class<", "TU;>;)", "Lkh/q<", "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;->l(Ljava/lang/Class;)Lph/r; move-result-object v0 invoke-virtual {p0, v0}, Lkh/q;->Y(Lph/r;)Lkh/q; move-result-object v0 invoke-virtual {v0, p1}, Lkh/q;->k(Ljava/lang/Class;)Lkh/q; move-result-object p1 return-object p1 .end method .method public final Q(Lph/a;)Lkh/q; .locals 9 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/a;", ")", "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 .line 1 new-instance v8, Lio/reactivex/internal/operators/maybe/g0; .line 2 invoke-static {}, Lio/reactivex/internal/functions/Functions;->h()Lph/g; move-result-object v2 .line 3 invoke-static {}, Lio/reactivex/internal/functions/Functions;->h()Lph/g; move-result-object v3 .line 4 invoke-static {}, Lio/reactivex/internal/functions/Functions;->h()Lph/g; move-result-object v4 sget-object v6, Lio/reactivex/internal/functions/Functions;->c:Lph/a; const-string v0, "onDispose is null" .line 5 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; move-result-object p1 move-object v7, p1 check-cast v7, Lph/a; move-object v0, v8 move-object v1, p0 move-object v5, v6 invoke-direct/range {v0 .. v7}, Lio/reactivex/internal/operators/maybe/g0;->(Lkh/w;Lph/g;Lph/g;Lph/g;Lph/a;Lph/a;Lph/a;)V .line 6 invoke-static {v8}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object p1 return-object p1 .end method .method public final Q0()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 invoke-static {}, Lio/reactivex/internal/functions/Functions;->c()Lph/r; move-result-object v0 invoke-virtual {p0, v0}, Lkh/q;->R0(Lph/r;)Lkh/q; move-result-object v0 return-object v0 .end method .method public final R(Lph/g;)Lkh/q; .locals 9 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/g<", "-", "Ljava/lang/Throwable;", ">;)", "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 .line 1 new-instance v8, Lio/reactivex/internal/operators/maybe/g0; .line 2 invoke-static {}, Lio/reactivex/internal/functions/Functions;->h()Lph/g; move-result-object v2 .line 3 invoke-static {}, Lio/reactivex/internal/functions/Functions;->h()Lph/g; move-result-object v3 const-string v0, "onError is null" .line 4 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; move-result-object p1 move-object v4, p1 check-cast v4, Lph/g; sget-object v7, Lio/reactivex/internal/functions/Functions;->c:Lph/a; move-object v0, v8 move-object v1, p0 move-object v5, v7 move-object v6, v7 invoke-direct/range {v0 .. v7}, Lio/reactivex/internal/operators/maybe/g0;->(Lkh/w;Lph/g;Lph/g;Lph/g;Lph/a;Lph/a;Lph/a;)V .line 5 invoke-static {v8}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object p1 return-object p1 .end method .method public final R0(Lph/r;)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/r<", "-", "Ljava/lang/Throwable;", ">;)", "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/e0; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/maybe/e0;->(Lkh/w;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 S(Lph/b;)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/b<", "-TT;-", "Ljava/lang/Throwable;", ">;)", "Lkh/q<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .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/maybe/h; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/maybe/h;->(Lkh/w;Lph/b;)V invoke-static {v0}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object p1 return-object p1 .end method .method public final S0(Lkh/w;)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/w<", "+TT;>;)", "Lkh/q<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "next is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 invoke-static {p1}, Lio/reactivex/internal/functions/Functions;->n(Ljava/lang/Object;)Lph/o; move-result-object p1 invoke-virtual {p0, p1}, Lkh/q;->T0(Lph/o;)Lkh/q; move-result-object p1 return-object p1 .end method .method public final T(Lph/g;)Lkh/q; .locals 9 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/g<", "-", "Lio/reactivex/disposables/b;", ">;)", "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 .line 1 new-instance v8, Lio/reactivex/internal/operators/maybe/g0; const-string v0, "onSubscribe is null" .line 2 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; move-result-object p1 move-object v2, p1 check-cast v2, Lph/g; .line 3 invoke-static {}, Lio/reactivex/internal/functions/Functions;->h()Lph/g; move-result-object v3 .line 4 invoke-static {}, Lio/reactivex/internal/functions/Functions;->h()Lph/g; move-result-object v4 sget-object v7, Lio/reactivex/internal/functions/Functions;->c:Lph/a; move-object v0, v8 move-object v1, p0 move-object v5, v7 move-object v6, v7 invoke-direct/range {v0 .. v7}, Lio/reactivex/internal/operators/maybe/g0;->(Lkh/w;Lph/g;Lph/g;Lph/g;Lph/a;Lph/a;Lph/a;)V .line 5 invoke-static {v8}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object p1 return-object p1 .end method .method public final T0(Lph/o;)Lkh/q; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/o<", "-", "Ljava/lang/Throwable;", "+", "Lkh/w<", "+TT;>;>;)", "Lkh/q<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "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/maybe/MaybeOnErrorNext; const/4 v1, 0x1 invoke-direct {v0, p0, p1, v1}, Lio/reactivex/internal/operators/maybe/MaybeOnErrorNext;->(Lkh/w;Lph/o;Z)V invoke-static {v0}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object p1 return-object p1 .end method .method public final U(Lph/g;)Lkh/q; .locals 9 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/g<", "-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 .line 1 new-instance v8, Lio/reactivex/internal/operators/maybe/g0; .line 2 invoke-static {}, Lio/reactivex/internal/functions/Functions;->h()Lph/g; move-result-object v2 const-string v0, "onSubscribe is null" .line 3 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; move-result-object p1 move-object v3, p1 check-cast v3, Lph/g; .line 4 invoke-static {}, Lio/reactivex/internal/functions/Functions;->h()Lph/g; move-result-object v4 sget-object v7, Lio/reactivex/internal/functions/Functions;->c:Lph/a; move-object v0, v8 move-object v1, p0 move-object v5, v7 move-object v6, v7 invoke-direct/range {v0 .. v7}, Lio/reactivex/internal/operators/maybe/g0;->(Lkh/w;Lph/g;Lph/g;Lph/g;Lph/a;Lph/a;Lph/a;)V .line 5 invoke-static {v8}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object p1 return-object p1 .end method .method public final U0(Lph/o;)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/o<", "-", "Ljava/lang/Throwable;", "+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, "valueSupplier 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/f0; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/maybe/f0;->(Lkh/w;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 V0(Ljava/lang/Object;)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(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, "item 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/q;->U0(Lph/o;)Lkh/q; move-result-object p1 return-object p1 .end method .method public final W0(Lkh/w;)Lkh/q; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/w<", "+TT;>;)", "Lkh/q<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "next is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeOnErrorNext; invoke-static {p1}, Lio/reactivex/internal/functions/Functions;->n(Ljava/lang/Object;)Lph/o; move-result-object p1 const/4 v1, 0x0 invoke-direct {v0, p0, p1, v1}, Lio/reactivex/internal/operators/maybe/MaybeOnErrorNext;->(Lkh/w;Lph/o;Z)V invoke-static {v0}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object p1 return-object p1 .end method .method public final X0()Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Lkh/q<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 new-instance v0, Lio/reactivex/internal/operators/maybe/f; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/f;->(Lkh/w;)V invoke-static {v0}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object v0 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/l; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/maybe/l;->(Lkh/w;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()Lkh/j; .locals 2 .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 const-wide v0, 0x7fffffffffffffffL .line 1 invoke-virtual {p0, v0, v1}, Lkh/q;->Z0(J)Lkh/j; move-result-object v0 return-object v0 .end method .method public final Z(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/maybe/MaybeFlatten; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/maybe/MaybeFlatten;->(Lkh/w;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 Z0(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/q;->J1()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 a0(Lph/o;Lph/c;)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/o<", "-TT;+", "Lkh/w<", "+TU;>;>;", "Lph/c<", "-TT;-TU;+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; const-string v0, "resultSelector 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/maybe/MaybeFlatMapBiSelector; invoke-direct {v0, p0, p1, p2}, Lio/reactivex/internal/operators/maybe/MaybeFlatMapBiSelector;->(Lkh/w;Lph/o;Lph/c;)V invoke-static {v0}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object p1 return-object p1 .end method .method public final a1(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/q;->J1()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 b(Lkh/t;)V .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/t<", "-TT;>;)V" } .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "observer 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;->e0(Lkh/q;Lkh/t;)Lkh/t; move-result-object p1 const-string v0, "The RxJavaPlugins.onSubscribe hook returned a null MaybeObserver. Please check the handler provided to RxJavaPlugins.setOnMaybeSubscribe 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/q;->p1(Lkh/t;)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 b0(Lph/o;Lph/o;Ljava/util/concurrent/Callable;)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/o<", "-TT;+", "Lkh/w<", "+TR;>;>;", "Lph/o<", "-", "Ljava/lang/Throwable;", "+", "Lkh/w<", "+TR;>;>;", "Ljava/util/concurrent/Callable<", "+", "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, "onSuccessMapper 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, "onErrorMapper is null" .line 2 invoke-static {p2, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "onCompleteSupplier is null" .line 3 invoke-static {p3, 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/maybe/MaybeFlatMapNotification; invoke-direct {v0, p0, p1, p2, p3}, Lio/reactivex/internal/operators/maybe/MaybeFlatMapNotification;->(Lkh/w;Lph/o;Lph/o;Ljava/util/concurrent/Callable;)V invoke-static {v0}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object p1 return-object p1 .end method .method public final b1(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/q;->J1()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 c0(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/maybe/MaybeFlatMapCompletable; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/maybe/MaybeFlatMapCompletable;->(Lkh/w;Lph/o;)V invoke-static {v0}, Lwh/a;->O(Lkh/a;)Lkh/a; move-result-object p1 return-object p1 .end method .method public final c1()Lkh/q; .locals 3 .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 invoke-static {}, Lio/reactivex/internal/functions/Functions;->c()Lph/r; move-result-object v0 const-wide v1, 0x7fffffffffffffffL invoke-virtual {p0, v1, v2, v0}, Lkh/q;->e1(JLph/r;)Lkh/q; move-result-object v0 return-object v0 .end method .method public final c2(Lkh/w;Lph/c;)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/w<", "+TU;>;", "Lph/c<", "-TT;-TU;+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, "other is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 invoke-static {p0, p1, p2}, Lkh/q;->a2(Lkh/w;Lkh/w;Lph/c;)Lkh/q; move-result-object p1 return-object p1 .end method .method public final d0(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/MaybeFlatMapObservable; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/mixed/MaybeFlatMapObservable;->(Lkh/w;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 d1(J)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(J)", "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 invoke-static {}, Lio/reactivex/internal/functions/Functions;->c()Lph/r; move-result-object v0 invoke-virtual {p0, p1, p2, v0}, Lkh/q;->e1(JLph/r;)Lkh/q; 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;+", "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/mixed/MaybeFlatMapPublisher; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/mixed/MaybeFlatMapPublisher;->(Lkh/w;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(JLph/r;)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(J", "Lph/r<", "-", "Ljava/lang/Throwable;", ">;)", "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 invoke-virtual {p0}, Lkh/q;->J1()Lkh/j; move-result-object v0 invoke-virtual {v0, p1, p2, p3}, Lkh/j;->l5(JLph/r;)Lkh/j; move-result-object p1 invoke-virtual {p1}, Lkh/j;->H5()Lkh/q; move-result-object p1 return-object p1 .end method .method public final f(Lkh/w;)Lkh/q; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/w<", "+TT;>;)", "Lkh/q<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "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/w; const/4 v1, 0x0 aput-object p0, v0, v1 const/4 v1, 0x1 aput-object p1, v0, v1 .line 2 invoke-static {v0}, Lkh/q;->e([Lkh/w;)Lkh/q; move-result-object p1 return-object p1 .end method .method public final f0(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/maybe/MaybeFlatMapSingle; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/maybe/MaybeFlatMapSingle;->(Lkh/w;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 f1(Lph/d;)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/d<", "-", "Ljava/lang/Integer;", "-", "Ljava/lang/Throwable;", ">;)", "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 invoke-virtual {p0}, Lkh/q;->J1()Lkh/j; move-result-object v0 invoke-virtual {v0, p1}, Lkh/j;->m5(Lph/d;)Lkh/j; move-result-object p1 invoke-virtual {p1}, Lkh/j;->H5()Lkh/q; move-result-object p1 return-object p1 .end method .method public final g(Lkh/r;)Ljava/lang/Object; .locals 1 .param p1 # Lkh/r; .annotation build Lio/reactivex/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/r<", "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/r; invoke-interface {p1, p0}, Lkh/r;->a(Lkh/q;)Ljava/lang/Object; move-result-object p1 return-object p1 .end method .method public final g0(Lph/o;)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/o<", "-TT;+", "Lkh/o0<", "+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/maybe/MaybeFlatMapSingleElement; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/maybe/MaybeFlatMapSingleElement;->(Lkh/w;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 g1(Lph/r;)Lkh/q; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/r<", "-", "Ljava/lang/Throwable;", ">;)", "Lkh/q<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-wide v0, 0x7fffffffffffffffL .line 1 invoke-virtual {p0, v0, v1, p1}, Lkh/q;->e1(JLph/r;)Lkh/q; move-result-object p1 return-object p1 .end method .method public final h()Ljava/lang/Object; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()TT;" } .end annotation .annotation runtime Lio/reactivex/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/q;->b(Lkh/t;)V .line 3 invoke-virtual {v0}, Lsh/f;->b()Ljava/lang/Object; move-result-object v0 return-object v0 .end method .method public final h0(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/maybe/MaybeFlatMapIterableFlowable; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/maybe/MaybeFlatMapIterableFlowable;->(Lkh/w;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 h1(Lph/e;)Lkh/q; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/e;", ")", "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, "stop 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;->v(Lph/e;)Lph/r; move-result-object p1 const-wide v0, 0x7fffffffffffffffL invoke-virtual {p0, v0, v1, p1}, Lkh/q;->e1(JLph/r;)Lkh/q; move-result-object p1 return-object p1 .end method .method public final i(Ljava/lang/Object;)Ljava/lang/Object; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(TT;)TT;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "defaultValue 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, Lsh/f; invoke-direct {v0}, Lsh/f;->()V .line 3 invoke-virtual {p0, v0}, Lkh/q;->b(Lkh/t;)V .line 4 invoke-virtual {v0, p1}, Lsh/f;->c(Ljava/lang/Object;)Ljava/lang/Object; move-result-object p1 return-object p1 .end method .method public final i0(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/maybe/n; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/maybe/n;->(Lkh/w;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 i1(Lph/o;)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/o<", "-", "Lkh/j<", "Ljava/lang/Throwable;", ">;+", "Lok/c<", "*>;>;)", "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 invoke-virtual {p0}, Lkh/q;->J1()Lkh/j; move-result-object v0 invoke-virtual {v0, p1}, Lkh/j;->p5(Lph/o;)Lkh/j; move-result-object p1 invoke-virtual {p1}, Lkh/j;->H5()Lkh/q; move-result-object p1 return-object p1 .end method .method public final j()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 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeCache; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/MaybeCache;->(Lkh/w;)V invoke-static {v0}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object v0 return-object v0 .end method .method public final k(Ljava/lang/Class;)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/lang/Class<", "+TU;>;)", "Lkh/q<", "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/q;->v0(Lph/o;)Lkh/q; move-result-object p1 return-object p1 .end method .method public final l(Lkh/x;)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/x<", "-TT;+TR;>;)", "Lkh/q<", "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/x; invoke-interface {p1, p0}, Lkh/x;->a(Lkh/q;)Lkh/w; move-result-object p1 invoke-static {p1}, Lkh/q;->R1(Lkh/w;)Lkh/q; move-result-object p1 return-object p1 .end method .method public final l1()Lio/reactivex/disposables/b; .locals 3 .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; sget-object v2, Lio/reactivex/internal/functions/Functions;->c:Lph/a; invoke-virtual {p0, v0, v1, v2}, Lkh/q;->o1(Lph/g;Lph/g;Lph/a;)Lio/reactivex/disposables/b; move-result-object v0 return-object v0 .end method .method public final m1(Lph/g;)Lio/reactivex/disposables/b; .locals 2 .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; sget-object v1, Lio/reactivex/internal/functions/Functions;->c:Lph/a; invoke-virtual {p0, p1, v0, v1}, Lkh/q;->o1(Lph/g;Lph/g;Lph/a;)Lio/reactivex/disposables/b; move-result-object p1 return-object p1 .end method .method public final n1(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 runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 sget-object v0, Lio/reactivex/internal/functions/Functions;->c:Lph/a; invoke-virtual {p0, p1, p2, v0}, Lkh/q;->o1(Lph/g;Lph/g;Lph/a;)Lio/reactivex/disposables/b; move-result-object p1 return-object p1 .end method .method public final o1(Lph/g;Lph/g;Lph/a;)Lio/reactivex/disposables/b; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/g<", "-TT;>;", "Lph/g<", "-", "Ljava/lang/Throwable;", ">;", "Lph/a;", ")", "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; const-string v0, "onComplete is null" .line 3 invoke-static {p3, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 4 new-instance v0, Lio/reactivex/internal/operators/maybe/MaybeCallbackObserver; invoke-direct {v0, p1, p2, p3}, Lio/reactivex/internal/operators/maybe/MaybeCallbackObserver;->(Lph/g;Lph/g;Lph/a;)V invoke-virtual {p0, v0}, Lkh/q;->r1(Lkh/t;)Lkh/t; move-result-object p1 check-cast p1, Lio/reactivex/disposables/b; return-object p1 .end method .method public abstract p1(Lkh/t;)V .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/t<", "-TT;>;)V" } .end annotation .end method .method public final q0()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 new-instance v0, Lio/reactivex/internal/operators/maybe/u; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/u;->(Lkh/w;)V invoke-static {v0}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object v0 return-object v0 .end method .method public final q1(Lkh/h0;)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/h0;", ")", "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 = "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/maybe/MaybeSubscribeOn; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/maybe/MaybeSubscribeOn;->(Lkh/w;Lkh/h0;)V invoke-static {v0}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object p1 return-object p1 .end method .method public final r0()Lkh/a; .locals 1 .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 new-instance v0, Lio/reactivex/internal/operators/maybe/w; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/w;->(Lkh/w;)V invoke-static {v0}, Lwh/a;->O(Lkh/a;)Lkh/a; move-result-object v0 return-object v0 .end method .method public final r1(Lkh/t;)Lkh/t; .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/q;->b(Lkh/t;)V return-object p1 .end method .method public final s0()Lkh/i0; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "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 new-instance v0, Lio/reactivex/internal/operators/maybe/y; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/y;->(Lkh/w;)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object v0 return-object v0 .end method .method public final s1(Lkh/w;)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/w<", "+TT;>;)", "Lkh/q<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "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/maybe/MaybeSwitchIfEmpty; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/maybe/MaybeSwitchIfEmpty;->(Lkh/w;Lkh/w;)V invoke-static {v0}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object p1 return-object p1 .end method .method public final t1(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, "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/maybe/MaybeSwitchIfEmptySingle; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/maybe/MaybeSwitchIfEmptySingle;->(Lkh/w;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 u0(Lkh/v;)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/v<", "+TR;-TT;>;)", "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, "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/maybe/a0; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/maybe/a0;->(Lkh/w;Lkh/v;)V invoke-static {v0}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object p1 return-object p1 .end method .method public final u1(Lkh/w;)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/w<", "TU;>;)", "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, "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/maybe/MaybeTakeUntilMaybe; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/maybe/MaybeTakeUntilMaybe;->(Lkh/w;Lkh/w;)V invoke-static {v0}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object p1 return-object p1 .end method .method public final v0(Lph/o;)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/o<", "-TT;+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/maybe/b0; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/maybe/b0;->(Lkh/w;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 v1(Lok/c;)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lok/c<", "TU;>;)", "Lkh/q<", "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, "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/maybe/MaybeTakeUntilPublisher; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/maybe/MaybeTakeUntilPublisher;->(Lkh/w;Lok/c;)V invoke-static {v0}, Lwh/a;->Q(Lkh/q;)Lkh/q; move-result-object p1 return-object p1 .end method .method public final w0()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/maybe/c0; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/maybe/c0;->(Lkh/q;)V invoke-static {v0}, Lwh/a;->S(Lkh/i0;)Lkh/i0; move-result-object v0 return-object v0 .end method .method public final w1()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/q;->b(Lkh/t;)V return-object v0 .end method .method public final x1(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/q;->b(Lkh/t;)V return-object v0 .end method .method public final y1(JLjava/util/concurrent/TimeUnit;)Lkh/q; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", ")", "Lkh/q<", "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/q;->A1(JLjava/util/concurrent/TimeUnit;Lkh/h0;)Lkh/q; move-result-object p1 return-object p1 .end method .method public final z(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/maybe/MaybeFlatten; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/maybe/MaybeFlatten;->(Lkh/w;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 z1(JLjava/util/concurrent/TimeUnit;Lkh/w;)Lkh/q; .locals 7 .annotation system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/concurrent/TimeUnit;", "Lkh/w<", "+TT;>;)", "Lkh/q<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "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/q;->B1(JLjava/util/concurrent/TimeUnit;Lkh/h0;Lkh/w;)Lkh/q; move-result-object p1 return-object p1 .end method