.class public abstract Lii/a; .super Ljava/lang/Object; .source "ParallelFlowable.java" # annotations .annotation system Ldalvik/annotation/Signature; value = { "", "Ljava/lang/Object;" } .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 C(Lok/c;)Lii/a; .locals 2 .param p0 # Lok/c; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "source" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lok/c<", "+TT;>;)", "Lii/a<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->FULL:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-static {}, Ljava/lang/Runtime;->getRuntime()Ljava/lang/Runtime; move-result-object v0 invoke-virtual {v0}, Ljava/lang/Runtime;->availableProcessors()I move-result v0 invoke-static {}, Lai/m;->c0()I move-result v1 invoke-static {p0, v0, v1}, Lii/a;->E(Lok/c;II)Lii/a; move-result-object p0 return-object p0 .end method .method public static D(Lok/c;I)Lii/a; .locals 1 .param p0 # Lok/c; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0 } names = { "source", "parallelism" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lok/c<", "+TT;>;I)", "Lii/a<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->FULL:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-static {}, Lai/m;->c0()I move-result v0 invoke-static {p0, p1, v0}, Lii/a;->E(Lok/c;II)Lii/a; move-result-object p0 return-object p0 .end method .method public static E(Lok/c;II)Lii/a; .locals 1 .param p0 # Lok/c; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0, 0x0 } names = { "source", "parallelism", "prefetch" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lok/c<", "+TT;>;II)", "Lii/a<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->FULL:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "source is null" .line 1 invoke-static {p0, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "parallelism" .line 2 invoke-static {p1, v0}, Lio/reactivex/rxjava3/internal/functions/a;->b(ILjava/lang/String;)I const-string v0, "prefetch" .line 3 invoke-static {p2, v0}, Lio/reactivex/rxjava3/internal/functions/a;->b(ILjava/lang/String;)I .line 4 new-instance v0, Lio/reactivex/rxjava3/internal/operators/parallel/ParallelFromPublisher; invoke-direct {v0, p0, p1, p2}, Lio/reactivex/rxjava3/internal/operators/parallel/ParallelFromPublisher;->(Lok/c;II)V invoke-static {v0}, Lji/a;->V(Lii/a;)Lii/a; move-result-object p0 return-object p0 .end method .method public static varargs F([Lok/c;)Lii/a; .locals 1 .param p0 # [Lok/c; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "publishers" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "([", "Lok/c<", "TT;>;)", "Lii/a<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->PASS_THROUGH:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation .annotation runtime Ljava/lang/SafeVarargs; .end annotation const-string v0, "publishers is null" .line 1 invoke-static {p0, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 array-length v0, p0 if-eqz v0, :cond_0 .line 3 new-instance v0, Lio/reactivex/rxjava3/internal/operators/parallel/g; invoke-direct {v0, p0}, Lio/reactivex/rxjava3/internal/operators/parallel/g;->([Lok/c;)V invoke-static {v0}, Lji/a;->V(Lii/a;)Lii/a; move-result-object p0 return-object p0 .line 4 :cond_0 new-instance p0, Ljava/lang/IllegalArgumentException; const-string v0, "Zero publishers not supported" invoke-direct {p0, v0}, Ljava/lang/IllegalArgumentException;->(Ljava/lang/String;)V throw p0 .end method # virtual methods .method public final A(Lci/o;)Lii/a; .locals 1 .param p1 # Lci/o; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "mapper" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/o<", "-TT;+", "Ljava/util/stream/Stream<", "+TR;>;>;)", "Lii/a<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->FULL:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-static {}, Lai/m;->c0()I move-result v0 invoke-virtual {p0, p1, v0}, Lii/a;->B(Lci/o;I)Lii/a; move-result-object p1 return-object p1 .end method .method public final B(Lci/o;I)Lii/a; .locals 1 .param p1 # Lci/o; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0 } names = { "mapper", "prefetch" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/o<", "-TT;+", "Ljava/util/stream/Stream<", "+TR;>;>;I)", "Lii/a<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->FULL:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "mapper is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "prefetch" .line 2 invoke-static {p2, v0}, Lio/reactivex/rxjava3/internal/functions/a;->b(ILjava/lang/String;)I .line 3 new-instance v0, Lio/reactivex/rxjava3/internal/jdk8/r; invoke-direct {v0, p0, p1, p2}, Lio/reactivex/rxjava3/internal/jdk8/r;->(Lii/a;Lci/o;I)V invoke-static {v0}, Lji/a;->V(Lii/a;)Lii/a; move-result-object p1 return-object p1 .end method .method public final G(Lci/o;)Lii/a; .locals 1 .param p1 # Lci/o; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "mapper" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/o<", "-TT;+TR;>;)", "Lii/a<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->PASS_THROUGH:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "mapper is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/rxjava3/internal/operators/parallel/h; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/operators/parallel/h;->(Lii/a;Lci/o;)V invoke-static {v0}, Lji/a;->V(Lii/a;)Lii/a; move-result-object p1 return-object p1 .end method .method public final H(Lci/o;Lci/c;)Lii/a; .locals 1 .param p1 # Lci/o; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p2 # Lci/c; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0 } names = { "mapper", "errorHandler" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/o<", "-TT;+TR;>;", "Lci/c<", "-", "Ljava/lang/Long;", "-", "Ljava/lang/Throwable;", "Lio/reactivex/rxjava3/parallel/ParallelFailureHandling;", ">;)", "Lii/a<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->PASS_THROUGH:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "mapper is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "errorHandler is null" .line 2 invoke-static {p2, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 3 new-instance v0, Lio/reactivex/rxjava3/internal/operators/parallel/i; invoke-direct {v0, p0, p1, p2}, Lio/reactivex/rxjava3/internal/operators/parallel/i;->(Lii/a;Lci/o;Lci/c;)V invoke-static {v0}, Lji/a;->V(Lii/a;)Lii/a; move-result-object p1 return-object p1 .end method .method public final I(Lci/o;Lio/reactivex/rxjava3/parallel/ParallelFailureHandling;)Lii/a; .locals 1 .param p1 # Lci/o; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p2 # Lio/reactivex/rxjava3/parallel/ParallelFailureHandling; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0 } names = { "mapper", "errorHandler" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/o<", "-TT;+TR;>;", "Lio/reactivex/rxjava3/parallel/ParallelFailureHandling;", ")", "Lii/a<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->PASS_THROUGH:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "mapper is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "errorHandler is null" .line 2 invoke-static {p2, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 3 new-instance v0, Lio/reactivex/rxjava3/internal/operators/parallel/i; invoke-direct {v0, p0, p1, p2}, Lio/reactivex/rxjava3/internal/operators/parallel/i;->(Lii/a;Lci/o;Lci/c;)V invoke-static {v0}, Lji/a;->V(Lii/a;)Lii/a; move-result-object p1 return-object p1 .end method .method public final J(Lci/o;)Lii/a; .locals 1 .param p1 # Lci/o; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "mapper" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/o<", "-TT;", "Ljava/util/Optional<", "+TR;>;>;)", "Lii/a<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->PASS_THROUGH:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "mapper is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/rxjava3/internal/jdk8/s; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/jdk8/s;->(Lii/a;Lci/o;)V invoke-static {v0}, Lji/a;->V(Lii/a;)Lii/a; move-result-object p1 return-object p1 .end method .method public final K(Lci/o;Lci/c;)Lii/a; .locals 1 .param p1 # Lci/o; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p2 # Lci/c; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0 } names = { "mapper", "errorHandler" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/o<", "-TT;", "Ljava/util/Optional<", "+TR;>;>;", "Lci/c<", "-", "Ljava/lang/Long;", "-", "Ljava/lang/Throwable;", "Lio/reactivex/rxjava3/parallel/ParallelFailureHandling;", ">;)", "Lii/a<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->PASS_THROUGH:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "mapper is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "errorHandler is null" .line 2 invoke-static {p2, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 3 new-instance v0, Lio/reactivex/rxjava3/internal/jdk8/t; invoke-direct {v0, p0, p1, p2}, Lio/reactivex/rxjava3/internal/jdk8/t;->(Lii/a;Lci/o;Lci/c;)V invoke-static {v0}, Lji/a;->V(Lii/a;)Lii/a; move-result-object p1 return-object p1 .end method .method public final L(Lci/o;Lio/reactivex/rxjava3/parallel/ParallelFailureHandling;)Lii/a; .locals 1 .param p1 # Lci/o; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p2 # Lio/reactivex/rxjava3/parallel/ParallelFailureHandling; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0 } names = { "mapper", "errorHandler" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/o<", "-TT;", "Ljava/util/Optional<", "+TR;>;>;", "Lio/reactivex/rxjava3/parallel/ParallelFailureHandling;", ")", "Lii/a<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->PASS_THROUGH:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "mapper is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "errorHandler is null" .line 2 invoke-static {p2, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 3 new-instance v0, Lio/reactivex/rxjava3/internal/jdk8/t; invoke-direct {v0, p0, p1, p2}, Lio/reactivex/rxjava3/internal/jdk8/t;->(Lii/a;Lci/o;Lci/c;)V invoke-static {v0}, Lji/a;->V(Lii/a;)Lii/a; move-result-object p1 return-object p1 .end method .method public abstract M()I .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .end method .method public final N(Lci/c;)Lai/m; .locals 1 .param p1 # Lci/c; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "reducer" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/c<", "TT;TT;TT;>;)", "Lai/m<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->UNBOUNDED_IN:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "reducer is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/rxjava3/internal/operators/parallel/ParallelReduceFull; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/operators/parallel/ParallelReduceFull;->(Lii/a;Lci/c;)V invoke-static {v0}, Lji/a;->P(Lai/m;)Lai/m; move-result-object p1 return-object p1 .end method .method public final O(Lci/s;Lci/c;)Lii/a; .locals 1 .param p1 # Lci/s; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p2 # Lci/c; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0 } names = { "initialSupplier", "reducer" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/s<", "TR;>;", "Lci/c<", "TR;-TT;TR;>;)", "Lii/a<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->UNBOUNDED_IN:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "initialSupplier is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "reducer is null" .line 2 invoke-static {p2, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 3 new-instance v0, Lio/reactivex/rxjava3/internal/operators/parallel/ParallelReduce; invoke-direct {v0, p0, p1, p2}, Lio/reactivex/rxjava3/internal/operators/parallel/ParallelReduce;->(Lii/a;Lci/s;Lci/c;)V invoke-static {v0}, Lji/a;->V(Lii/a;)Lii/a; move-result-object p1 return-object p1 .end method .method public final P(Lai/o0;)Lii/a; .locals 1 .param p1 # Lai/o0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "scheduler" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lai/o0;", ")", "Lii/a<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->FULL:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "custom" .end annotation .line 1 invoke-static {}, Lai/m;->c0()I move-result v0 invoke-virtual {p0, p1, v0}, Lii/a;->Q(Lai/o0;I)Lii/a; move-result-object p1 return-object p1 .end method .method public final Q(Lai/o0;I)Lii/a; .locals 1 .param p1 # Lai/o0; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0 } names = { "scheduler", "prefetch" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lai/o0;", "I)", "Lii/a<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->FULL:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "custom" .end annotation const-string v0, "scheduler is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "prefetch" .line 2 invoke-static {p2, v0}, Lio/reactivex/rxjava3/internal/functions/a;->b(ILjava/lang/String;)I .line 3 new-instance v0, Lio/reactivex/rxjava3/internal/operators/parallel/ParallelRunOn; invoke-direct {v0, p0, p1, p2}, Lio/reactivex/rxjava3/internal/operators/parallel/ParallelRunOn;->(Lii/a;Lai/o0;I)V invoke-static {v0}, Lji/a;->V(Lii/a;)Lii/a; move-result-object p1 return-object p1 .end method .method public final R()Lai/m; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Lai/m<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->FULL:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-static {}, Lai/m;->c0()I move-result v0 invoke-virtual {p0, v0}, Lii/a;->S(I)Lai/m; move-result-object v0 return-object v0 .end method .method public final S(I)Lai/m; .locals 2 .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "prefetch" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(I)", "Lai/m<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->FULL:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "prefetch" .line 1 invoke-static {p1, v0}, Lio/reactivex/rxjava3/internal/functions/a;->b(ILjava/lang/String;)I .line 2 new-instance v0, Lio/reactivex/rxjava3/internal/operators/parallel/ParallelJoin; const/4 v1, 0x0 invoke-direct {v0, p0, p1, v1}, Lio/reactivex/rxjava3/internal/operators/parallel/ParallelJoin;->(Lii/a;IZ)V invoke-static {v0}, Lji/a;->P(Lai/m;)Lai/m; move-result-object p1 return-object p1 .end method .method public final T()Lai/m; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Lai/m<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->FULL:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-static {}, Lai/m;->c0()I move-result v0 invoke-virtual {p0, v0}, Lii/a;->U(I)Lai/m; move-result-object v0 return-object v0 .end method .method public final U(I)Lai/m; .locals 2 .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "prefetch" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(I)", "Lai/m<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->FULL:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "prefetch" .line 1 invoke-static {p1, v0}, Lio/reactivex/rxjava3/internal/functions/a;->b(ILjava/lang/String;)I .line 2 new-instance v0, Lio/reactivex/rxjava3/internal/operators/parallel/ParallelJoin; const/4 v1, 0x1 invoke-direct {v0, p0, p1, v1}, Lio/reactivex/rxjava3/internal/operators/parallel/ParallelJoin;->(Lii/a;IZ)V invoke-static {v0}, Lji/a;->P(Lai/m;)Lai/m; move-result-object p1 return-object p1 .end method .method public final V(Ljava/util/Comparator;)Lai/m; .locals 1 .param p1 # Ljava/util/Comparator; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "comparator" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/Comparator<", "-TT;>;)", "Lai/m<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->UNBOUNDED_IN:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const/16 v0, 0x10 .line 1 invoke-virtual {p0, p1, v0}, Lii/a;->W(Ljava/util/Comparator;I)Lai/m; move-result-object p1 return-object p1 .end method .method public final W(Ljava/util/Comparator;I)Lai/m; .locals 1 .param p1 # Ljava/util/Comparator; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0 } names = { "comparator", "capacityHint" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/Comparator<", "-TT;>;I)", "Lai/m<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->UNBOUNDED_IN:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "comparator is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "capacityHint" .line 2 invoke-static {p2, v0}, Lio/reactivex/rxjava3/internal/functions/a;->b(ILjava/lang/String;)I .line 3 invoke-virtual {p0}, Lii/a;->M()I move-result v0 div-int/2addr p2, v0 add-int/lit8 p2, p2, 0x1 .line 4 invoke-static {p2}, Lio/reactivex/rxjava3/internal/functions/Functions;->f(I)Lci/s; move-result-object p2 invoke-static {}, Lio/reactivex/rxjava3/internal/util/ListAddBiConsumer;->instance()Lci/c; move-result-object v0 invoke-virtual {p0, p2, v0}, Lii/a;->O(Lci/s;Lci/c;)Lii/a; move-result-object p2 .line 5 new-instance v0, Lio/reactivex/rxjava3/internal/util/o; invoke-direct {v0, p1}, Lio/reactivex/rxjava3/internal/util/o;->(Ljava/util/Comparator;)V invoke-virtual {p2, v0}, Lii/a;->G(Lci/o;)Lii/a; move-result-object p2 .line 6 new-instance v0, Lio/reactivex/rxjava3/internal/operators/parallel/ParallelSortedJoin; invoke-direct {v0, p2, p1}, Lio/reactivex/rxjava3/internal/operators/parallel/ParallelSortedJoin;->(Lii/a;Ljava/util/Comparator;)V invoke-static {v0}, Lji/a;->P(Lai/m;)Lai/m; move-result-object p1 return-object p1 .end method .method public abstract X([Lok/d;)V .param p1 # [Lok/d; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "subscribers" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "([", "Lok/d<", "-TT;>;)V" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->SPECIAL:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation .end method .method public final Y(Lii/b;)Ljava/lang/Object; .locals 1 .param p1 # Lii/b; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "converter" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lii/b<", "TT;TR;>;)TR;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->PASS_THROUGH:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "converter is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; check-cast p1, Lii/b; invoke-interface {p1, p0}, Lii/b;->a(Lii/a;)Ljava/lang/Object; move-result-object p1 return-object p1 .end method .method public final Z(Ljava/util/Comparator;)Lai/m; .locals 1 .param p1 # Ljava/util/Comparator; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "comparator" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/Comparator<", "-TT;>;)", "Lai/m<", "Ljava/util/List<", "TT;>;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->UNBOUNDED_IN:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const/16 v0, 0x10 .line 1 invoke-virtual {p0, p1, v0}, Lii/a;->a0(Ljava/util/Comparator;I)Lai/m; move-result-object p1 return-object p1 .end method .method public final a(Ljava/util/stream/Collector;)Lai/m; .locals 1 .param p1 # Ljava/util/stream/Collector; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "collector" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/stream/Collector<", "TT;TA;TR;>;)", "Lai/m<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->UNBOUNDED_IN:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "collector is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/rxjava3/internal/jdk8/ParallelCollector; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/jdk8/ParallelCollector;->(Lii/a;Ljava/util/stream/Collector;)V invoke-static {v0}, Lji/a;->P(Lai/m;)Lai/m; move-result-object p1 return-object p1 .end method .method public final a0(Ljava/util/Comparator;I)Lai/m; .locals 1 .param p1 # Ljava/util/Comparator; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0 } names = { "comparator", "capacityHint" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/Comparator<", "-TT;>;I)", "Lai/m<", "Ljava/util/List<", "TT;>;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->UNBOUNDED_IN:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "comparator is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "capacityHint" .line 2 invoke-static {p2, v0}, Lio/reactivex/rxjava3/internal/functions/a;->b(ILjava/lang/String;)I .line 3 invoke-virtual {p0}, Lii/a;->M()I move-result v0 div-int/2addr p2, v0 add-int/lit8 p2, p2, 0x1 .line 4 invoke-static {p2}, Lio/reactivex/rxjava3/internal/functions/Functions;->f(I)Lci/s; move-result-object p2 invoke-static {}, Lio/reactivex/rxjava3/internal/util/ListAddBiConsumer;->instance()Lci/c; move-result-object v0 invoke-virtual {p0, p2, v0}, Lii/a;->O(Lci/s;Lci/c;)Lii/a; move-result-object p2 .line 5 new-instance v0, Lio/reactivex/rxjava3/internal/util/o; invoke-direct {v0, p1}, Lio/reactivex/rxjava3/internal/util/o;->(Ljava/util/Comparator;)V invoke-virtual {p2, v0}, Lii/a;->G(Lci/o;)Lii/a; move-result-object p2 .line 6 new-instance v0, Lio/reactivex/rxjava3/internal/util/i; invoke-direct {v0, p1}, Lio/reactivex/rxjava3/internal/util/i;->(Ljava/util/Comparator;)V invoke-virtual {p2, v0}, Lii/a;->N(Lci/c;)Lai/m; move-result-object p1 .line 7 invoke-static {p1}, Lji/a;->P(Lai/m;)Lai/m; move-result-object p1 return-object p1 .end method .method public final b(Lci/s;Lci/b;)Lii/a; .locals 1 .param p1 # Lci/s; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p2 # Lci/b; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0 } names = { "collectionSupplier", "collector" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/s<", "+TC;>;", "Lci/b<", "-TC;-TT;>;)", "Lii/a<", "TC;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->UNBOUNDED_IN:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "collectionSupplier is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "collector is null" .line 2 invoke-static {p2, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 3 new-instance v0, Lio/reactivex/rxjava3/internal/operators/parallel/ParallelCollect; invoke-direct {v0, p0, p1, p2}, Lio/reactivex/rxjava3/internal/operators/parallel/ParallelCollect;->(Lii/a;Lci/s;Lci/b;)V invoke-static {v0}, Lji/a;->V(Lii/a;)Lii/a; move-result-object p1 return-object p1 .end method .method public final b0([Lok/d;)Z .locals 5 .param p1 # [Lok/d; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "subscribers" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "([", "Lok/d<", "*>;)Z" } .end annotation const-string v0, "subscribers is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 invoke-virtual {p0}, Lii/a;->M()I move-result v0 .line 3 array-length v1, p1 if-eq v1, v0, :cond_1 .line 4 new-instance v1, Ljava/lang/IllegalArgumentException; const-string v2, "parallelism = " const-string v3, ", subscribers = " invoke-static {v2, v0, v3}, Landroid/support/v4/media/a;->a(Ljava/lang/String;ILjava/lang/String;)Ljava/lang/StringBuilder; move-result-object v0 array-length v2, p1 invoke-virtual {v0, v2}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder; invoke-virtual {v0}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String; move-result-object v0 invoke-direct {v1, v0}, Ljava/lang/IllegalArgumentException;->(Ljava/lang/String;)V .line 5 array-length v0, p1 const/4 v2, 0x0 move v3, v2 :goto_0 if-ge v3, v0, :cond_0 aget-object v4, p1, v3 .line 6 invoke-static {v1, v4}, Lio/reactivex/rxjava3/internal/subscriptions/EmptySubscription;->error(Ljava/lang/Throwable;Lok/d;)V add-int/lit8 v3, v3, 0x1 goto :goto_0 :cond_0 return v2 :cond_1 const/4 p1, 0x1 return p1 .end method .method public final c(Lii/c;)Lii/a; .locals 1 .param p1 # Lii/c; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "composer" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lii/c<", "TT;TU;>;)", "Lii/a<", "TU;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->PASS_THROUGH:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "composer is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; check-cast p1, Lii/c; invoke-interface {p1, p0}, Lii/c;->a(Lii/a;)Lii/a; move-result-object p1 invoke-static {p1}, Lji/a;->V(Lii/a;)Lii/a; move-result-object p1 return-object p1 .end method .method public final d(Lci/o;)Lii/a; .locals 1 .param p1 # Lci/o; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "mapper" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/o<", "-TT;+", "Lok/c<", "+TR;>;>;)", "Lii/a<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->FULL:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const/4 v0, 0x2 .line 1 invoke-virtual {p0, p1, v0}, Lii/a;->e(Lci/o;I)Lii/a; move-result-object p1 return-object p1 .end method .method public final e(Lci/o;I)Lii/a; .locals 2 .param p1 # Lci/o; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0 } names = { "mapper", "prefetch" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/o<", "-TT;+", "Lok/c<", "+TR;>;>;I)", "Lii/a<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->FULL:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "mapper is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "prefetch" .line 2 invoke-static {p2, v0}, Lio/reactivex/rxjava3/internal/functions/a;->b(ILjava/lang/String;)I .line 3 new-instance v0, Lio/reactivex/rxjava3/internal/operators/parallel/a; sget-object v1, Lio/reactivex/rxjava3/internal/util/ErrorMode;->IMMEDIATE:Lio/reactivex/rxjava3/internal/util/ErrorMode; invoke-direct {v0, p0, p1, p2, v1}, Lio/reactivex/rxjava3/internal/operators/parallel/a;->(Lii/a;Lci/o;ILio/reactivex/rxjava3/internal/util/ErrorMode;)V invoke-static {v0}, Lji/a;->V(Lii/a;)Lii/a; move-result-object p1 return-object p1 .end method .method public final f(Lci/o;IZ)Lii/a; .locals 1 .param p1 # Lci/o; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0, 0x0 } names = { "mapper", "prefetch", "tillTheEnd" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/o<", "-TT;+", "Lok/c<", "+TR;>;>;IZ)", "Lii/a<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->FULL:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "mapper is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "prefetch" .line 2 invoke-static {p2, v0}, Lio/reactivex/rxjava3/internal/functions/a;->b(ILjava/lang/String;)I .line 3 new-instance v0, Lio/reactivex/rxjava3/internal/operators/parallel/a; if-eqz p3, :cond_0 sget-object p3, Lio/reactivex/rxjava3/internal/util/ErrorMode;->END:Lio/reactivex/rxjava3/internal/util/ErrorMode; goto :goto_0 :cond_0 sget-object p3, Lio/reactivex/rxjava3/internal/util/ErrorMode;->BOUNDARY:Lio/reactivex/rxjava3/internal/util/ErrorMode; :goto_0 invoke-direct {v0, p0, p1, p2, p3}, Lio/reactivex/rxjava3/internal/operators/parallel/a;->(Lii/a;Lci/o;ILio/reactivex/rxjava3/internal/util/ErrorMode;)V invoke-static {v0}, Lji/a;->V(Lii/a;)Lii/a; move-result-object p1 return-object p1 .end method .method public final g(Lci/o;Z)Lii/a; .locals 1 .param p1 # Lci/o; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0 } names = { "mapper", "tillTheEnd" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/o<", "-TT;+", "Lok/c<", "+TR;>;>;Z)", "Lii/a<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->FULL:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const/4 v0, 0x2 .line 1 invoke-virtual {p0, p1, v0, p2}, Lii/a;->f(Lci/o;IZ)Lii/a; move-result-object p1 return-object p1 .end method .method public final h(Lci/g;)Lii/a; .locals 11 .param p1 # Lci/g; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "onAfterNext" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/g<", "-TT;>;)", "Lii/a<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->PASS_THROUGH:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "onAfterNext is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/rxjava3/internal/operators/parallel/j; .line 3 invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->h()Lci/g; move-result-object v3 .line 4 invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->h()Lci/g; move-result-object v5 sget-object v10, Lio/reactivex/rxjava3/internal/functions/Functions;->c:Lci/a; .line 5 invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->h()Lci/g; move-result-object v8 sget-object v9, Lio/reactivex/rxjava3/internal/functions/Functions;->g:Lci/q; move-object v1, v0 move-object v2, p0 move-object v4, p1 move-object v6, v10 move-object v7, v10 invoke-direct/range {v1 .. v10}, Lio/reactivex/rxjava3/internal/operators/parallel/j;->(Lii/a;Lci/g;Lci/g;Lci/g;Lci/a;Lci/a;Lci/g;Lci/q;Lci/a;)V .line 6 invoke-static {v0}, Lji/a;->V(Lii/a;)Lii/a; move-result-object p1 return-object p1 .end method .method public final i(Lci/a;)Lii/a; .locals 11 .param p1 # Lci/a; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "onAfterTerminate" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/a;", ")", "Lii/a<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->PASS_THROUGH:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "onAfterTerminate is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/rxjava3/internal/operators/parallel/j; .line 3 invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->h()Lci/g; move-result-object v3 .line 4 invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->h()Lci/g; move-result-object v4 .line 5 invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->h()Lci/g; move-result-object v5 sget-object v10, Lio/reactivex/rxjava3/internal/functions/Functions;->c:Lci/a; .line 6 invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->h()Lci/g; move-result-object v8 sget-object v9, Lio/reactivex/rxjava3/internal/functions/Functions;->g:Lci/q; move-object v1, v0 move-object v2, p0 move-object v6, v10 move-object v7, p1 invoke-direct/range {v1 .. v10}, Lio/reactivex/rxjava3/internal/operators/parallel/j;->(Lii/a;Lci/g;Lci/g;Lci/g;Lci/a;Lci/a;Lci/g;Lci/q;Lci/a;)V .line 7 invoke-static {v0}, Lji/a;->V(Lii/a;)Lii/a; move-result-object p1 return-object p1 .end method .method public final j(Lci/a;)Lii/a; .locals 11 .param p1 # Lci/a; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "onCancel" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/a;", ")", "Lii/a<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->PASS_THROUGH:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "onCancel is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/rxjava3/internal/operators/parallel/j; .line 3 invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->h()Lci/g; move-result-object v3 .line 4 invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->h()Lci/g; move-result-object v4 .line 5 invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->h()Lci/g; move-result-object v5 sget-object v7, Lio/reactivex/rxjava3/internal/functions/Functions;->c:Lci/a; .line 6 invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->h()Lci/g; move-result-object v8 sget-object v9, Lio/reactivex/rxjava3/internal/functions/Functions;->g:Lci/q; move-object v1, v0 move-object v2, p0 move-object v6, v7 move-object v10, p1 invoke-direct/range {v1 .. v10}, Lio/reactivex/rxjava3/internal/operators/parallel/j;->(Lii/a;Lci/g;Lci/g;Lci/g;Lci/a;Lci/a;Lci/g;Lci/q;Lci/a;)V .line 7 invoke-static {v0}, Lji/a;->V(Lii/a;)Lii/a; move-result-object p1 return-object p1 .end method .method public final k(Lci/a;)Lii/a; .locals 11 .param p1 # Lci/a; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "onComplete" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/a;", ")", "Lii/a<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->PASS_THROUGH:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "onComplete is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/rxjava3/internal/operators/parallel/j; .line 3 invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->h()Lci/g; move-result-object v3 .line 4 invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->h()Lci/g; move-result-object v4 .line 5 invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->h()Lci/g; move-result-object v5 sget-object v10, Lio/reactivex/rxjava3/internal/functions/Functions;->c:Lci/a; .line 6 invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->h()Lci/g; move-result-object v8 sget-object v9, Lio/reactivex/rxjava3/internal/functions/Functions;->g:Lci/q; move-object v1, v0 move-object v2, p0 move-object v6, p1 move-object v7, v10 invoke-direct/range {v1 .. v10}, Lio/reactivex/rxjava3/internal/operators/parallel/j;->(Lii/a;Lci/g;Lci/g;Lci/g;Lci/a;Lci/a;Lci/g;Lci/q;Lci/a;)V .line 7 invoke-static {v0}, Lji/a;->V(Lii/a;)Lii/a; move-result-object p1 return-object p1 .end method .method public final l(Lci/g;)Lii/a; .locals 11 .param p1 # Lci/g; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "onError" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/g<", "-", "Ljava/lang/Throwable;", ">;)", "Lii/a<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->PASS_THROUGH:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "onError is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/rxjava3/internal/operators/parallel/j; .line 3 invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->h()Lci/g; move-result-object v3 .line 4 invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->h()Lci/g; move-result-object v4 sget-object v10, Lio/reactivex/rxjava3/internal/functions/Functions;->c:Lci/a; .line 5 invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->h()Lci/g; move-result-object v8 sget-object v9, Lio/reactivex/rxjava3/internal/functions/Functions;->g:Lci/q; move-object v1, v0 move-object v2, p0 move-object v5, p1 move-object v6, v10 move-object v7, v10 invoke-direct/range {v1 .. v10}, Lio/reactivex/rxjava3/internal/operators/parallel/j;->(Lii/a;Lci/g;Lci/g;Lci/g;Lci/a;Lci/a;Lci/g;Lci/q;Lci/a;)V .line 6 invoke-static {v0}, Lji/a;->V(Lii/a;)Lii/a; move-result-object p1 return-object p1 .end method .method public final m(Lci/g;)Lii/a; .locals 11 .param p1 # Lci/g; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "onNext" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/g<", "-TT;>;)", "Lii/a<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->PASS_THROUGH:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "onNext is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/rxjava3/internal/operators/parallel/j; .line 3 invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->h()Lci/g; move-result-object v4 .line 4 invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->h()Lci/g; move-result-object v5 sget-object v10, Lio/reactivex/rxjava3/internal/functions/Functions;->c:Lci/a; .line 5 invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->h()Lci/g; move-result-object v8 sget-object v9, Lio/reactivex/rxjava3/internal/functions/Functions;->g:Lci/q; move-object v1, v0 move-object v2, p0 move-object v3, p1 move-object v6, v10 move-object v7, v10 invoke-direct/range {v1 .. v10}, Lio/reactivex/rxjava3/internal/operators/parallel/j;->(Lii/a;Lci/g;Lci/g;Lci/g;Lci/a;Lci/a;Lci/g;Lci/q;Lci/a;)V .line 6 invoke-static {v0}, Lji/a;->V(Lii/a;)Lii/a; move-result-object p1 return-object p1 .end method .method public final n(Lci/g;Lci/c;)Lii/a; .locals 1 .param p1 # Lci/g; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p2 # Lci/c; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0 } names = { "onNext", "errorHandler" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/g<", "-TT;>;", "Lci/c<", "-", "Ljava/lang/Long;", "-", "Ljava/lang/Throwable;", "Lio/reactivex/rxjava3/parallel/ParallelFailureHandling;", ">;)", "Lii/a<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->PASS_THROUGH:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "onNext is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "errorHandler is null" .line 2 invoke-static {p2, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 3 new-instance v0, Lio/reactivex/rxjava3/internal/operators/parallel/b; invoke-direct {v0, p0, p1, p2}, Lio/reactivex/rxjava3/internal/operators/parallel/b;->(Lii/a;Lci/g;Lci/c;)V invoke-static {v0}, Lji/a;->V(Lii/a;)Lii/a; move-result-object p1 return-object p1 .end method .method public final o(Lci/g;Lio/reactivex/rxjava3/parallel/ParallelFailureHandling;)Lii/a; .locals 1 .param p1 # Lci/g; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p2 # Lio/reactivex/rxjava3/parallel/ParallelFailureHandling; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0 } names = { "onNext", "errorHandler" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/g<", "-TT;>;", "Lio/reactivex/rxjava3/parallel/ParallelFailureHandling;", ")", "Lii/a<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->PASS_THROUGH:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "onNext is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "errorHandler is null" .line 2 invoke-static {p2, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 3 new-instance v0, Lio/reactivex/rxjava3/internal/operators/parallel/b; invoke-direct {v0, p0, p1, p2}, Lio/reactivex/rxjava3/internal/operators/parallel/b;->(Lii/a;Lci/g;Lci/c;)V invoke-static {v0}, Lji/a;->V(Lii/a;)Lii/a; move-result-object p1 return-object p1 .end method .method public final p(Lci/q;)Lii/a; .locals 11 .param p1 # Lci/q; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "onRequest" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/q;", ")", "Lii/a<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->PASS_THROUGH:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "onRequest is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/rxjava3/internal/operators/parallel/j; .line 3 invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->h()Lci/g; move-result-object v3 .line 4 invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->h()Lci/g; move-result-object v4 .line 5 invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->h()Lci/g; move-result-object v5 sget-object v10, Lio/reactivex/rxjava3/internal/functions/Functions;->c:Lci/a; .line 6 invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->h()Lci/g; move-result-object v8 move-object v1, v0 move-object v2, p0 move-object v6, v10 move-object v7, v10 move-object v9, p1 invoke-direct/range {v1 .. v10}, Lio/reactivex/rxjava3/internal/operators/parallel/j;->(Lii/a;Lci/g;Lci/g;Lci/g;Lci/a;Lci/a;Lci/g;Lci/q;Lci/a;)V .line 7 invoke-static {v0}, Lji/a;->V(Lii/a;)Lii/a; move-result-object p1 return-object p1 .end method .method public final q(Lci/g;)Lii/a; .locals 11 .param p1 # Lci/g; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "onSubscribe" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/g<", "-", "Lok/e;", ">;)", "Lii/a<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->PASS_THROUGH:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "onSubscribe is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/rxjava3/internal/operators/parallel/j; .line 3 invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->h()Lci/g; move-result-object v3 .line 4 invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->h()Lci/g; move-result-object v4 .line 5 invoke-static {}, Lio/reactivex/rxjava3/internal/functions/Functions;->h()Lci/g; move-result-object v5 sget-object v10, Lio/reactivex/rxjava3/internal/functions/Functions;->c:Lci/a; sget-object v9, Lio/reactivex/rxjava3/internal/functions/Functions;->g:Lci/q; move-object v1, v0 move-object v2, p0 move-object v6, v10 move-object v7, v10 move-object v8, p1 invoke-direct/range {v1 .. v10}, Lio/reactivex/rxjava3/internal/operators/parallel/j;->(Lii/a;Lci/g;Lci/g;Lci/g;Lci/a;Lci/a;Lci/g;Lci/q;Lci/a;)V .line 6 invoke-static {v0}, Lji/a;->V(Lii/a;)Lii/a; move-result-object p1 return-object p1 .end method .method public final r(Lci/r;)Lii/a; .locals 1 .param p1 # Lci/r; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "predicate" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/r<", "-TT;>;)", "Lii/a<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->PASS_THROUGH:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "predicate is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/rxjava3/internal/operators/parallel/c; invoke-direct {v0, p0, p1}, Lio/reactivex/rxjava3/internal/operators/parallel/c;->(Lii/a;Lci/r;)V invoke-static {v0}, Lji/a;->V(Lii/a;)Lii/a; move-result-object p1 return-object p1 .end method .method public final s(Lci/r;Lci/c;)Lii/a; .locals 1 .param p1 # Lci/r; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p2 # Lci/c; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0 } names = { "predicate", "errorHandler" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/r<", "-TT;>;", "Lci/c<", "-", "Ljava/lang/Long;", "-", "Ljava/lang/Throwable;", "Lio/reactivex/rxjava3/parallel/ParallelFailureHandling;", ">;)", "Lii/a<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->PASS_THROUGH:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "predicate is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "errorHandler is null" .line 2 invoke-static {p2, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 3 new-instance v0, Lio/reactivex/rxjava3/internal/operators/parallel/d; invoke-direct {v0, p0, p1, p2}, Lio/reactivex/rxjava3/internal/operators/parallel/d;->(Lii/a;Lci/r;Lci/c;)V invoke-static {v0}, Lji/a;->V(Lii/a;)Lii/a; move-result-object p1 return-object p1 .end method .method public final t(Lci/r;Lio/reactivex/rxjava3/parallel/ParallelFailureHandling;)Lii/a; .locals 1 .param p1 # Lci/r; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .param p2 # Lio/reactivex/rxjava3/parallel/ParallelFailureHandling; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0 } names = { "predicate", "errorHandler" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/r<", "-TT;>;", "Lio/reactivex/rxjava3/parallel/ParallelFailureHandling;", ")", "Lii/a<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->PASS_THROUGH:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "predicate is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "errorHandler is null" .line 2 invoke-static {p2, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 3 new-instance v0, Lio/reactivex/rxjava3/internal/operators/parallel/d; invoke-direct {v0, p0, p1, p2}, Lio/reactivex/rxjava3/internal/operators/parallel/d;->(Lii/a;Lci/r;Lci/c;)V invoke-static {v0}, Lji/a;->V(Lii/a;)Lii/a; move-result-object p1 return-object p1 .end method .method public final u(Lci/o;)Lii/a; .locals 3 .param p1 # Lci/o; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "mapper" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/o<", "-TT;+", "Lok/c<", "+TR;>;>;)", "Lii/a<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->FULL:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-static {}, Lai/m;->c0()I move-result v0 invoke-static {}, Lai/m;->c0()I move-result v1 const/4 v2, 0x0 invoke-virtual {p0, p1, v2, v0, v1}, Lii/a;->x(Lci/o;ZII)Lii/a; move-result-object p1 return-object p1 .end method .method public final v(Lci/o;Z)Lii/a; .locals 2 .param p1 # Lci/o; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0 } names = { "mapper", "delayError" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/o<", "-TT;+", "Lok/c<", "+TR;>;>;Z)", "Lii/a<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->FULL:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-static {}, Lai/m;->c0()I move-result v0 invoke-static {}, Lai/m;->c0()I move-result v1 invoke-virtual {p0, p1, p2, v0, v1}, Lii/a;->x(Lci/o;ZII)Lii/a; move-result-object p1 return-object p1 .end method .method public final w(Lci/o;ZI)Lii/a; .locals 1 .param p1 # Lci/o; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0, 0x0 } names = { "mapper", "delayError", "maxConcurrency" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/o<", "-TT;+", "Lok/c<", "+TR;>;>;ZI)", "Lii/a<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->FULL:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-static {}, Lai/m;->c0()I move-result v0 invoke-virtual {p0, p1, p2, p3, v0}, Lii/a;->x(Lci/o;ZII)Lii/a; move-result-object p1 return-object p1 .end method .method public final x(Lci/o;ZII)Lii/a; .locals 7 .param p1 # Lci/o; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0, 0x0, 0x0 } names = { "mapper", "delayError", "maxConcurrency", "prefetch" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/o<", "-TT;+", "Lok/c<", "+TR;>;>;ZII)", "Lii/a<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->FULL:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "mapper is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "maxConcurrency" .line 2 invoke-static {p3, v0}, Lio/reactivex/rxjava3/internal/functions/a;->b(ILjava/lang/String;)I const-string v0, "prefetch" .line 3 invoke-static {p4, v0}, Lio/reactivex/rxjava3/internal/functions/a;->b(ILjava/lang/String;)I .line 4 new-instance v0, Lio/reactivex/rxjava3/internal/operators/parallel/e; move-object v1, v0 move-object v2, p0 move-object v3, p1 move v4, p2 move v5, p3 move v6, p4 invoke-direct/range {v1 .. v6}, Lio/reactivex/rxjava3/internal/operators/parallel/e;->(Lii/a;Lci/o;ZII)V invoke-static {v0}, Lji/a;->V(Lii/a;)Lii/a; move-result-object p1 return-object p1 .end method .method public final y(Lci/o;)Lii/a; .locals 1 .param p1 # Lci/o; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0 } names = { "mapper" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/o<", "-TT;+", "Ljava/lang/Iterable<", "+TU;>;>;)", "Lii/a<", "TU;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->FULL:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-static {}, Lai/m;->c0()I move-result v0 invoke-virtual {p0, p1, v0}, Lii/a;->z(Lci/o;I)Lii/a; move-result-object p1 return-object p1 .end method .method public final z(Lci/o;I)Lii/a; .locals 1 .param p1 # Lci/o; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0 } names = { "mapper", "bufferSize" } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "(", "Lci/o<", "-TT;+", "Ljava/lang/Iterable<", "+TU;>;>;I)", "Lii/a<", "TU;>;" } .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/BackpressureSupport; value = .enum Lio/reactivex/rxjava3/annotations/BackpressureKind;->FULL:Lio/reactivex/rxjava3/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/rxjava3/annotations/SchedulerSupport; value = "none" .end annotation const-string v0, "mapper is null" .line 1 invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "bufferSize" .line 2 invoke-static {p2, v0}, Lio/reactivex/rxjava3/internal/functions/a;->b(ILjava/lang/String;)I .line 3 new-instance v0, Lio/reactivex/rxjava3/internal/operators/parallel/f; invoke-direct {v0, p0, p1, p2}, Lio/reactivex/rxjava3/internal/operators/parallel/f;->(Lii/a;Lci/o;I)V invoke-static {v0}, Lji/a;->V(Lii/a;)Lii/a; move-result-object p1 return-object p1 .end method