.class public abstract Lvh/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 A(Lok/c;II)Lvh/a; .locals 1 .param p0 # Lok/c; .annotation build Lio/reactivex/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/Signature; value = { "(", "Lok/c<", "+TT;>;II)", "Lvh/a<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation const-string v0, "source" .line 1 invoke-static {p0, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "parallelism" .line 2 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->h(ILjava/lang/String;)I const-string v0, "prefetch" .line 3 invoke-static {p2, v0}, Lio/reactivex/internal/functions/a;->h(ILjava/lang/String;)I .line 4 new-instance v0, Lio/reactivex/internal/operators/parallel/ParallelFromPublisher; invoke-direct {v0, p0, p1, p2}, Lio/reactivex/internal/operators/parallel/ParallelFromPublisher;->(Lok/c;II)V invoke-static {v0}, Lwh/a;->V(Lvh/a;)Lvh/a; move-result-object p0 return-object p0 .end method .method public static varargs B([Lok/c;)Lvh/a; .locals 1 .param p0 # [Lok/c; .annotation build Lio/reactivex/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/Signature; value = { "([", "Lok/c<", "TT;>;)", "Lvh/a<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .line 1 array-length v0, p0 if-eqz v0, :cond_0 .line 2 new-instance v0, Lio/reactivex/internal/operators/parallel/f; invoke-direct {v0, p0}, Lio/reactivex/internal/operators/parallel/f;->([Lok/c;)V invoke-static {v0}, Lwh/a;->V(Lvh/a;)Lvh/a; move-result-object p0 return-object p0 .line 3 :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 .method public static y(Lok/c;)Lvh/a; .locals 2 .param p0 # Lok/c; .annotation build Lio/reactivex/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/Signature; value = { "(", "Lok/c<", "+TT;>;)", "Lvh/a<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .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 {}, Lkh/j;->U()I move-result v1 invoke-static {p0, v0, v1}, Lvh/a;->A(Lok/c;II)Lvh/a; move-result-object p0 return-object p0 .end method .method public static z(Lok/c;I)Lvh/a; .locals 1 .param p0 # Lok/c; .annotation build Lio/reactivex/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/Signature; value = { "(", "Lok/c<", "+TT;>;I)", "Lvh/a<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .line 1 invoke-static {}, Lkh/j;->U()I move-result v0 invoke-static {p0, p1, v0}, Lvh/a;->A(Lok/c;II)Lvh/a; move-result-object p0 return-object p0 .end method # virtual methods .method public final C(Lph/o;)Lvh/a; .locals 1 .param p1 # Lph/o; .annotation build Lio/reactivex/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/o<", "-TT;+TR;>;)", "Lvh/a<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation const-string v0, "mapper" .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/parallel/g; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/parallel/g;->(Lvh/a;Lph/o;)V invoke-static {v0}, Lwh/a;->V(Lvh/a;)Lvh/a; move-result-object p1 return-object p1 .end method .method public final D(Lph/o;Lio/reactivex/parallel/ParallelFailureHandling;)Lvh/a; .locals 1 .param p1 # Lph/o; .annotation build Lio/reactivex/annotations/NonNull; .end annotation .end param .param p2 # Lio/reactivex/parallel/ParallelFailureHandling; .annotation build Lio/reactivex/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/o<", "-TT;+TR;>;", "Lio/reactivex/parallel/ParallelFailureHandling;", ")", "Lvh/a<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation const-string v0, "mapper" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "errorHandler 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/parallel/h; invoke-direct {v0, p0, p1, p2}, Lio/reactivex/internal/operators/parallel/h;->(Lvh/a;Lph/o;Lph/c;)V invoke-static {v0}, Lwh/a;->V(Lvh/a;)Lvh/a; move-result-object p1 return-object p1 .end method .method public final E(Lph/o;Lph/c;)Lvh/a; .locals 1 .param p1 # Lph/o; .annotation build Lio/reactivex/annotations/NonNull; .end annotation .end param .param p2 # Lph/c; .annotation build Lio/reactivex/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/o<", "-TT;+TR;>;", "Lph/c<", "-", "Ljava/lang/Long;", "-", "Ljava/lang/Throwable;", "Lio/reactivex/parallel/ParallelFailureHandling;", ">;)", "Lvh/a<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation const-string v0, "mapper" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "errorHandler 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/parallel/h; invoke-direct {v0, p0, p1, p2}, Lio/reactivex/internal/operators/parallel/h;->(Lvh/a;Lph/o;Lph/c;)V invoke-static {v0}, Lwh/a;->V(Lvh/a;)Lvh/a; move-result-object p1 return-object p1 .end method .method public abstract F()I .end method .method public final G(Lph/c;)Lkh/j; .locals 1 .param p1 # Lph/c; .annotation build Lio/reactivex/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/c<", "TT;TT;TT;>;)", "Lkh/j<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation const-string v0, "reducer" .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/parallel/ParallelReduceFull; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/parallel/ParallelReduceFull;->(Lvh/a;Lph/c;)V invoke-static {v0}, Lwh/a;->P(Lkh/j;)Lkh/j; move-result-object p1 return-object p1 .end method .method public final H(Ljava/util/concurrent/Callable;Lph/c;)Lvh/a; .locals 1 .param p1 # Ljava/util/concurrent/Callable; .annotation build Lio/reactivex/annotations/NonNull; .end annotation .end param .param p2 # Lph/c; .annotation build Lio/reactivex/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/Callable<", "TR;>;", "Lph/c<", "TR;-TT;TR;>;)", "Lvh/a<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation const-string v0, "initialSupplier" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "reducer" .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/parallel/ParallelReduce; invoke-direct {v0, p0, p1, p2}, Lio/reactivex/internal/operators/parallel/ParallelReduce;->(Lvh/a;Ljava/util/concurrent/Callable;Lph/c;)V invoke-static {v0}, Lwh/a;->V(Lvh/a;)Lvh/a; move-result-object p1 return-object p1 .end method .method public final I(Lkh/h0;)Lvh/a; .locals 1 .param p1 # Lkh/h0; .annotation build Lio/reactivex/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/h0;", ")", "Lvh/a<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .line 1 invoke-static {}, Lkh/j;->U()I move-result v0 invoke-virtual {p0, p1, v0}, Lvh/a;->J(Lkh/h0;I)Lvh/a; move-result-object p1 return-object p1 .end method .method public final J(Lkh/h0;I)Lvh/a; .locals 1 .param p1 # Lkh/h0; .annotation build Lio/reactivex/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkh/h0;", "I)", "Lvh/a<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation const-string v0, "scheduler" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "prefetch" .line 2 invoke-static {p2, v0}, Lio/reactivex/internal/functions/a;->h(ILjava/lang/String;)I .line 3 new-instance v0, Lio/reactivex/internal/operators/parallel/ParallelRunOn; invoke-direct {v0, p0, p1, p2}, Lio/reactivex/internal/operators/parallel/ParallelRunOn;->(Lvh/a;Lkh/h0;I)V invoke-static {v0}, Lwh/a;->V(Lvh/a;)Lvh/a; move-result-object p1 return-object p1 .end method .method public final K()Lkh/j; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Lkh/j<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/BackpressureSupport; value = .enum Lio/reactivex/annotations/BackpressureKind;->FULL:Lio/reactivex/annotations/BackpressureKind; .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-static {}, Lkh/j;->U()I move-result v0 invoke-virtual {p0, v0}, Lvh/a;->L(I)Lkh/j; move-result-object v0 return-object v0 .end method .method public final L(I)Lkh/j; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(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, "prefetch" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->h(ILjava/lang/String;)I .line 2 new-instance v0, Lio/reactivex/internal/operators/parallel/ParallelJoin; const/4 v1, 0x0 invoke-direct {v0, p0, p1, v1}, Lio/reactivex/internal/operators/parallel/ParallelJoin;->(Lvh/a;IZ)V invoke-static {v0}, Lwh/a;->P(Lkh/j;)Lkh/j; move-result-object p1 return-object p1 .end method .method public final M()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 build Lio/reactivex/annotations/NonNull; .end annotation .annotation runtime Lio/reactivex/annotations/SchedulerSupport; value = "none" .end annotation .line 1 invoke-static {}, Lkh/j;->U()I move-result v0 invoke-virtual {p0, v0}, Lvh/a;->N(I)Lkh/j; move-result-object v0 return-object v0 .end method .method public final N(I)Lkh/j; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(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, "prefetch" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->h(ILjava/lang/String;)I .line 2 new-instance v0, Lio/reactivex/internal/operators/parallel/ParallelJoin; const/4 v1, 0x1 invoke-direct {v0, p0, p1, v1}, Lio/reactivex/internal/operators/parallel/ParallelJoin;->(Lvh/a;IZ)V invoke-static {v0}, Lwh/a;->P(Lkh/j;)Lkh/j; move-result-object p1 return-object p1 .end method .method public final O(Ljava/util/Comparator;)Lkh/j; .locals 1 .param p1 # Ljava/util/Comparator; .annotation build Lio/reactivex/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/Comparator<", "-TT;>;)", "Lkh/j<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation const/16 v0, 0x10 .line 1 invoke-virtual {p0, p1, v0}, Lvh/a;->P(Ljava/util/Comparator;I)Lkh/j; move-result-object p1 return-object p1 .end method .method public final P(Ljava/util/Comparator;I)Lkh/j; .locals 1 .param p1 # Ljava/util/Comparator; .annotation build Lio/reactivex/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/Comparator<", "-TT;>;I)", "Lkh/j<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation const-string v0, "comparator 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, "capacityHint" .line 2 invoke-static {p2, v0}, Lio/reactivex/internal/functions/a;->h(ILjava/lang/String;)I .line 3 invoke-virtual {p0}, Lvh/a;->F()I move-result v0 div-int/2addr p2, v0 add-int/lit8 p2, p2, 0x1 .line 4 invoke-static {p2}, Lio/reactivex/internal/functions/Functions;->f(I)Ljava/util/concurrent/Callable; move-result-object p2 invoke-static {}, Lio/reactivex/internal/util/ListAddBiConsumer;->instance()Lph/c; move-result-object v0 invoke-virtual {p0, p2, v0}, Lvh/a;->H(Ljava/util/concurrent/Callable;Lph/c;)Lvh/a; move-result-object p2 .line 5 new-instance v0, Lio/reactivex/internal/util/o; invoke-direct {v0, p1}, Lio/reactivex/internal/util/o;->(Ljava/util/Comparator;)V invoke-virtual {p2, v0}, Lvh/a;->C(Lph/o;)Lvh/a; move-result-object p2 .line 6 new-instance v0, Lio/reactivex/internal/operators/parallel/ParallelSortedJoin; invoke-direct {v0, p2, p1}, Lio/reactivex/internal/operators/parallel/ParallelSortedJoin;->(Lvh/a;Ljava/util/Comparator;)V invoke-static {v0}, Lwh/a;->P(Lkh/j;)Lkh/j; move-result-object p1 return-object p1 .end method .method public abstract Q([Lok/d;)V .param p1 # [Lok/d; .annotation build Lio/reactivex/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/Signature; value = { "([", "Lok/d<", "-TT;>;)V" } .end annotation .end method .method public final R(Lph/o;)Ljava/lang/Object; .locals 1 .param p1 # Lph/o; .annotation build Lio/reactivex/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/o<", "-", "Lvh/a<", "TT;>;TU;>;)TU;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation :try_start_0 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, 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 S(Ljava/util/Comparator;)Lkh/j; .locals 1 .param p1 # Ljava/util/Comparator; .annotation build Lio/reactivex/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/Comparator<", "-TT;>;)", "Lkh/j<", "Ljava/util/List<", "TT;>;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation const/16 v0, 0x10 .line 1 invoke-virtual {p0, p1, v0}, Lvh/a;->T(Ljava/util/Comparator;I)Lkh/j; move-result-object p1 return-object p1 .end method .method public final T(Ljava/util/Comparator;I)Lkh/j; .locals 1 .param p1 # Ljava/util/Comparator; .annotation build Lio/reactivex/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/Comparator<", "-TT;>;I)", "Lkh/j<", "Ljava/util/List<", "TT;>;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation const-string v0, "comparator 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, "capacityHint" .line 2 invoke-static {p2, v0}, Lio/reactivex/internal/functions/a;->h(ILjava/lang/String;)I .line 3 invoke-virtual {p0}, Lvh/a;->F()I move-result v0 div-int/2addr p2, v0 add-int/lit8 p2, p2, 0x1 .line 4 invoke-static {p2}, Lio/reactivex/internal/functions/Functions;->f(I)Ljava/util/concurrent/Callable; move-result-object p2 invoke-static {}, Lio/reactivex/internal/util/ListAddBiConsumer;->instance()Lph/c; move-result-object v0 invoke-virtual {p0, p2, v0}, Lvh/a;->H(Ljava/util/concurrent/Callable;Lph/c;)Lvh/a; move-result-object p2 .line 5 new-instance v0, Lio/reactivex/internal/util/o; invoke-direct {v0, p1}, Lio/reactivex/internal/util/o;->(Ljava/util/Comparator;)V invoke-virtual {p2, v0}, Lvh/a;->C(Lph/o;)Lvh/a; move-result-object p2 .line 6 new-instance v0, Lio/reactivex/internal/util/i; invoke-direct {v0, p1}, Lio/reactivex/internal/util/i;->(Ljava/util/Comparator;)V invoke-virtual {p2, v0}, Lvh/a;->G(Lph/c;)Lkh/j; move-result-object p1 .line 7 invoke-static {p1}, Lwh/a;->P(Lkh/j;)Lkh/j; move-result-object p1 return-object p1 .end method .method public final U([Lok/d;)Z .locals 5 .param p1 # [Lok/d; .annotation build Lio/reactivex/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/Signature; value = { "([", "Lok/d<", "*>;)Z" } .end annotation .line 1 invoke-virtual {p0}, Lvh/a;->F()I move-result v0 .line 2 array-length v1, p1 if-eq v1, v0, :cond_1 .line 3 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 4 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 5 invoke-static {v1, v4}, Lio/reactivex/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 a(Lvh/b;)Ljava/lang/Object; .locals 1 .param p1 # Lvh/b; .annotation build Lio/reactivex/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/Signature; value = { "(", "Lvh/b<", "TT;TR;>;)TR;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .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, Lvh/b; invoke-interface {p1, p0}, Lvh/b;->a(Lvh/a;)Ljava/lang/Object; move-result-object p1 return-object p1 .end method .method public final b(Ljava/util/concurrent/Callable;Lph/b;)Lvh/a; .locals 1 .param p1 # Ljava/util/concurrent/Callable; .annotation build Lio/reactivex/annotations/NonNull; .end annotation .end param .param p2 # Lph/b; .annotation build Lio/reactivex/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/Callable<", "+TC;>;", "Lph/b<", "-TC;-TT;>;)", "Lvh/a<", "TC;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation const-string v0, "collectionSupplier 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, "collector 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/parallel/ParallelCollect; invoke-direct {v0, p0, p1, p2}, Lio/reactivex/internal/operators/parallel/ParallelCollect;->(Lvh/a;Ljava/util/concurrent/Callable;Lph/b;)V invoke-static {v0}, Lwh/a;->V(Lvh/a;)Lvh/a; move-result-object p1 return-object p1 .end method .method public final c(Lvh/c;)Lvh/a; .locals 1 .param p1 # Lvh/c; .annotation build Lio/reactivex/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/Signature; value = { "(", "Lvh/c<", "TT;TU;>;)", "Lvh/a<", "TU;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation const-string v0, "composer 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, Lvh/c; invoke-interface {p1, p0}, Lvh/c;->a(Lvh/a;)Lvh/a; move-result-object p1 invoke-static {p1}, Lwh/a;->V(Lvh/a;)Lvh/a; move-result-object p1 return-object p1 .end method .method public final d(Lph/o;)Lvh/a; .locals 1 .param p1 # Lph/o; .annotation build Lio/reactivex/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/o<", "-TT;+", "Lok/c<", "+TR;>;>;)", "Lvh/a<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation const/4 v0, 0x2 .line 1 invoke-virtual {p0, p1, v0}, Lvh/a;->e(Lph/o;I)Lvh/a; move-result-object p1 return-object p1 .end method .method public final e(Lph/o;I)Lvh/a; .locals 2 .param p1 # Lph/o; .annotation build Lio/reactivex/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/o<", "-TT;+", "Lok/c<", "+TR;>;>;I)", "Lvh/a<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .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, "prefetch" .line 2 invoke-static {p2, v0}, Lio/reactivex/internal/functions/a;->h(ILjava/lang/String;)I .line 3 new-instance v0, Lio/reactivex/internal/operators/parallel/a; sget-object v1, Lio/reactivex/internal/util/ErrorMode;->IMMEDIATE:Lio/reactivex/internal/util/ErrorMode; invoke-direct {v0, p0, p1, p2, v1}, Lio/reactivex/internal/operators/parallel/a;->(Lvh/a;Lph/o;ILio/reactivex/internal/util/ErrorMode;)V invoke-static {v0}, Lwh/a;->V(Lvh/a;)Lvh/a; move-result-object p1 return-object p1 .end method .method public final f(Lph/o;IZ)Lvh/a; .locals 1 .param p1 # Lph/o; .annotation build Lio/reactivex/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/o<", "-TT;+", "Lok/c<", "+TR;>;>;IZ)", "Lvh/a<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .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, "prefetch" .line 2 invoke-static {p2, v0}, Lio/reactivex/internal/functions/a;->h(ILjava/lang/String;)I .line 3 new-instance v0, Lio/reactivex/internal/operators/parallel/a; if-eqz p3, :cond_0 sget-object p3, Lio/reactivex/internal/util/ErrorMode;->END:Lio/reactivex/internal/util/ErrorMode; goto :goto_0 :cond_0 sget-object p3, Lio/reactivex/internal/util/ErrorMode;->BOUNDARY:Lio/reactivex/internal/util/ErrorMode; :goto_0 invoke-direct {v0, p0, p1, p2, p3}, Lio/reactivex/internal/operators/parallel/a;->(Lvh/a;Lph/o;ILio/reactivex/internal/util/ErrorMode;)V invoke-static {v0}, Lwh/a;->V(Lvh/a;)Lvh/a; move-result-object p1 return-object p1 .end method .method public final g(Lph/o;Z)Lvh/a; .locals 1 .param p1 # Lph/o; .annotation build Lio/reactivex/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/o<", "-TT;+", "Lok/c<", "+TR;>;>;Z)", "Lvh/a<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation const/4 v0, 0x2 .line 1 invoke-virtual {p0, p1, v0, p2}, Lvh/a;->f(Lph/o;IZ)Lvh/a; move-result-object p1 return-object p1 .end method .method public final h(Lph/g;)Lvh/a; .locals 11 .param p1 # Lph/g; .annotation build Lio/reactivex/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/g<", "-TT;>;)", "Lvh/a<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation const-string v0, "onAfterNext 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/parallel/i; .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 v5 sget-object v10, Lio/reactivex/internal/functions/Functions;->c:Lph/a; .line 5 invoke-static {}, Lio/reactivex/internal/functions/Functions;->h()Lph/g; move-result-object v8 sget-object v9, Lio/reactivex/internal/functions/Functions;->g:Lph/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/internal/operators/parallel/i;->(Lvh/a;Lph/g;Lph/g;Lph/g;Lph/a;Lph/a;Lph/g;Lph/q;Lph/a;)V .line 6 invoke-static {v0}, Lwh/a;->V(Lvh/a;)Lvh/a; move-result-object p1 return-object p1 .end method .method public final i(Lph/a;)Lvh/a; .locals 11 .param p1 # Lph/a; .annotation build Lio/reactivex/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/a;", ")", "Lvh/a<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation const-string v0, "onAfterTerminate is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/parallel/i; .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 .line 5 invoke-static {}, Lio/reactivex/internal/functions/Functions;->h()Lph/g; move-result-object v5 sget-object v10, Lio/reactivex/internal/functions/Functions;->c:Lph/a; .line 6 invoke-static {}, Lio/reactivex/internal/functions/Functions;->h()Lph/g; move-result-object v8 sget-object v9, Lio/reactivex/internal/functions/Functions;->g:Lph/q; move-object v1, v0 move-object v2, p0 move-object v6, v10 move-object v7, p1 invoke-direct/range {v1 .. v10}, Lio/reactivex/internal/operators/parallel/i;->(Lvh/a;Lph/g;Lph/g;Lph/g;Lph/a;Lph/a;Lph/g;Lph/q;Lph/a;)V .line 7 invoke-static {v0}, Lwh/a;->V(Lvh/a;)Lvh/a; move-result-object p1 return-object p1 .end method .method public final j(Lph/a;)Lvh/a; .locals 11 .param p1 # Lph/a; .annotation build Lio/reactivex/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/a;", ")", "Lvh/a<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation const-string v0, "onCancel 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/parallel/i; .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 .line 5 invoke-static {}, Lio/reactivex/internal/functions/Functions;->h()Lph/g; move-result-object v5 sget-object v7, Lio/reactivex/internal/functions/Functions;->c:Lph/a; .line 6 invoke-static {}, Lio/reactivex/internal/functions/Functions;->h()Lph/g; move-result-object v8 sget-object v9, Lio/reactivex/internal/functions/Functions;->g:Lph/q; move-object v1, v0 move-object v2, p0 move-object v6, v7 move-object v10, p1 invoke-direct/range {v1 .. v10}, Lio/reactivex/internal/operators/parallel/i;->(Lvh/a;Lph/g;Lph/g;Lph/g;Lph/a;Lph/a;Lph/g;Lph/q;Lph/a;)V .line 7 invoke-static {v0}, Lwh/a;->V(Lvh/a;)Lvh/a; move-result-object p1 return-object p1 .end method .method public final k(Lph/a;)Lvh/a; .locals 11 .param p1 # Lph/a; .annotation build Lio/reactivex/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/a;", ")", "Lvh/a<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation const-string v0, "onComplete 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/parallel/i; .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 .line 5 invoke-static {}, Lio/reactivex/internal/functions/Functions;->h()Lph/g; move-result-object v5 sget-object v10, Lio/reactivex/internal/functions/Functions;->c:Lph/a; .line 6 invoke-static {}, Lio/reactivex/internal/functions/Functions;->h()Lph/g; move-result-object v8 sget-object v9, Lio/reactivex/internal/functions/Functions;->g:Lph/q; move-object v1, v0 move-object v2, p0 move-object v6, p1 move-object v7, v10 invoke-direct/range {v1 .. v10}, Lio/reactivex/internal/operators/parallel/i;->(Lvh/a;Lph/g;Lph/g;Lph/g;Lph/a;Lph/a;Lph/g;Lph/q;Lph/a;)V .line 7 invoke-static {v0}, Lwh/a;->V(Lvh/a;)Lvh/a; move-result-object p1 return-object p1 .end method .method public final l(Lph/g;)Lvh/a; .locals 11 .param p1 # Lph/g; .annotation build Lio/reactivex/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/g<", "Ljava/lang/Throwable;", ">;)", "Lvh/a<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation const-string v0, "onError is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/parallel/i; .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 v10, Lio/reactivex/internal/functions/Functions;->c:Lph/a; .line 5 invoke-static {}, Lio/reactivex/internal/functions/Functions;->h()Lph/g; move-result-object v8 sget-object v9, Lio/reactivex/internal/functions/Functions;->g:Lph/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/internal/operators/parallel/i;->(Lvh/a;Lph/g;Lph/g;Lph/g;Lph/a;Lph/a;Lph/g;Lph/q;Lph/a;)V .line 6 invoke-static {v0}, Lwh/a;->V(Lvh/a;)Lvh/a; move-result-object p1 return-object p1 .end method .method public final m(Lph/g;)Lvh/a; .locals 11 .param p1 # Lph/g; .annotation build Lio/reactivex/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/g<", "-TT;>;)", "Lvh/a<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation const-string v0, "onNext 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/parallel/i; .line 3 invoke-static {}, Lio/reactivex/internal/functions/Functions;->h()Lph/g; move-result-object v4 .line 4 invoke-static {}, Lio/reactivex/internal/functions/Functions;->h()Lph/g; move-result-object v5 sget-object v10, Lio/reactivex/internal/functions/Functions;->c:Lph/a; .line 5 invoke-static {}, Lio/reactivex/internal/functions/Functions;->h()Lph/g; move-result-object v8 sget-object v9, Lio/reactivex/internal/functions/Functions;->g:Lph/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/internal/operators/parallel/i;->(Lvh/a;Lph/g;Lph/g;Lph/g;Lph/a;Lph/a;Lph/g;Lph/q;Lph/a;)V .line 6 invoke-static {v0}, Lwh/a;->V(Lvh/a;)Lvh/a; move-result-object p1 return-object p1 .end method .method public final n(Lph/g;Lio/reactivex/parallel/ParallelFailureHandling;)Lvh/a; .locals 1 .param p1 # Lph/g; .annotation build Lio/reactivex/annotations/NonNull; .end annotation .end param .param p2 # Lio/reactivex/parallel/ParallelFailureHandling; .annotation build Lio/reactivex/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/g<", "-TT;>;", "Lio/reactivex/parallel/ParallelFailureHandling;", ")", "Lvh/a<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation const-string v0, "onNext 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, "errorHandler 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/parallel/b; invoke-direct {v0, p0, p1, p2}, Lio/reactivex/internal/operators/parallel/b;->(Lvh/a;Lph/g;Lph/c;)V invoke-static {v0}, Lwh/a;->V(Lvh/a;)Lvh/a; move-result-object p1 return-object p1 .end method .method public final o(Lph/g;Lph/c;)Lvh/a; .locals 1 .param p1 # Lph/g; .annotation build Lio/reactivex/annotations/NonNull; .end annotation .end param .param p2 # Lph/c; .annotation build Lio/reactivex/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/g<", "-TT;>;", "Lph/c<", "-", "Ljava/lang/Long;", "-", "Ljava/lang/Throwable;", "Lio/reactivex/parallel/ParallelFailureHandling;", ">;)", "Lvh/a<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation const-string v0, "onNext 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, "errorHandler 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/parallel/b; invoke-direct {v0, p0, p1, p2}, Lio/reactivex/internal/operators/parallel/b;->(Lvh/a;Lph/g;Lph/c;)V invoke-static {v0}, Lwh/a;->V(Lvh/a;)Lvh/a; move-result-object p1 return-object p1 .end method .method public final p(Lph/q;)Lvh/a; .locals 11 .param p1 # Lph/q; .annotation build Lio/reactivex/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/q;", ")", "Lvh/a<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation const-string v0, "onRequest 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/parallel/i; .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 .line 5 invoke-static {}, Lio/reactivex/internal/functions/Functions;->h()Lph/g; move-result-object v5 sget-object v10, Lio/reactivex/internal/functions/Functions;->c:Lph/a; .line 6 invoke-static {}, Lio/reactivex/internal/functions/Functions;->h()Lph/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/internal/operators/parallel/i;->(Lvh/a;Lph/g;Lph/g;Lph/g;Lph/a;Lph/a;Lph/g;Lph/q;Lph/a;)V .line 7 invoke-static {v0}, Lwh/a;->V(Lvh/a;)Lvh/a; move-result-object p1 return-object p1 .end method .method public final q(Lph/g;)Lvh/a; .locals 11 .param p1 # Lph/g; .annotation build Lio/reactivex/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/g<", "-", "Lok/e;", ">;)", "Lvh/a<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation const-string v0, "onSubscribe is null" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; .line 2 new-instance v0, Lio/reactivex/internal/operators/parallel/i; .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 .line 5 invoke-static {}, Lio/reactivex/internal/functions/Functions;->h()Lph/g; move-result-object v5 sget-object v10, Lio/reactivex/internal/functions/Functions;->c:Lph/a; sget-object v9, Lio/reactivex/internal/functions/Functions;->g:Lph/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/internal/operators/parallel/i;->(Lvh/a;Lph/g;Lph/g;Lph/g;Lph/a;Lph/a;Lph/g;Lph/q;Lph/a;)V .line 6 invoke-static {v0}, Lwh/a;->V(Lvh/a;)Lvh/a; move-result-object p1 return-object p1 .end method .method public final r(Lph/r;)Lvh/a; .locals 1 .param p1 # Lph/r; .annotation build Lio/reactivex/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/r<", "-TT;>;)", "Lvh/a<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation const-string v0, "predicate" .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/parallel/c; invoke-direct {v0, p0, p1}, Lio/reactivex/internal/operators/parallel/c;->(Lvh/a;Lph/r;)V invoke-static {v0}, Lwh/a;->V(Lvh/a;)Lvh/a; move-result-object p1 return-object p1 .end method .method public final s(Lph/r;Lio/reactivex/parallel/ParallelFailureHandling;)Lvh/a; .locals 1 .param p1 # Lph/r; .annotation build Lio/reactivex/annotations/NonNull; .end annotation .end param .param p2 # Lio/reactivex/parallel/ParallelFailureHandling; .annotation build Lio/reactivex/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/r<", "-TT;>;", "Lio/reactivex/parallel/ParallelFailureHandling;", ")", "Lvh/a<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation const-string v0, "predicate" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "errorHandler 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/parallel/d; invoke-direct {v0, p0, p1, p2}, Lio/reactivex/internal/operators/parallel/d;->(Lvh/a;Lph/r;Lph/c;)V invoke-static {v0}, Lwh/a;->V(Lvh/a;)Lvh/a; move-result-object p1 return-object p1 .end method .method public final t(Lph/r;Lph/c;)Lvh/a; .locals 1 .param p1 # Lph/r; .annotation build Lio/reactivex/annotations/NonNull; .end annotation .end param .param p2 # Lph/c; .annotation build Lio/reactivex/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/r<", "-TT;>;", "Lph/c<", "-", "Ljava/lang/Long;", "-", "Ljava/lang/Throwable;", "Lio/reactivex/parallel/ParallelFailureHandling;", ">;)", "Lvh/a<", "TT;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation const-string v0, "predicate" .line 1 invoke-static {p1, v0}, Lio/reactivex/internal/functions/a;->g(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const-string v0, "errorHandler 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/parallel/d; invoke-direct {v0, p0, p1, p2}, Lio/reactivex/internal/operators/parallel/d;->(Lvh/a;Lph/r;Lph/c;)V invoke-static {v0}, Lwh/a;->V(Lvh/a;)Lvh/a; move-result-object p1 return-object p1 .end method .method public final u(Lph/o;)Lvh/a; .locals 3 .param p1 # Lph/o; .annotation build Lio/reactivex/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/o<", "-TT;+", "Lok/c<", "+TR;>;>;)", "Lvh/a<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .line 1 invoke-static {}, Lkh/j;->U()I move-result v0 const/4 v1, 0x0 const v2, 0x7fffffff invoke-virtual {p0, p1, v1, v2, v0}, Lvh/a;->x(Lph/o;ZII)Lvh/a; move-result-object p1 return-object p1 .end method .method public final v(Lph/o;Z)Lvh/a; .locals 2 .param p1 # Lph/o; .annotation build Lio/reactivex/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/o<", "-TT;+", "Lok/c<", "+TR;>;>;Z)", "Lvh/a<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .line 1 invoke-static {}, Lkh/j;->U()I move-result v0 const v1, 0x7fffffff invoke-virtual {p0, p1, p2, v1, v0}, Lvh/a;->x(Lph/o;ZII)Lvh/a; move-result-object p1 return-object p1 .end method .method public final w(Lph/o;ZI)Lvh/a; .locals 1 .param p1 # Lph/o; .annotation build Lio/reactivex/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/o<", "-TT;+", "Lok/c<", "+TR;>;>;ZI)", "Lvh/a<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .end annotation .line 1 invoke-static {}, Lkh/j;->U()I move-result v0 invoke-virtual {p0, p1, p2, p3, v0}, Lvh/a;->x(Lph/o;ZII)Lvh/a; move-result-object p1 return-object p1 .end method .method public final x(Lph/o;ZII)Lvh/a; .locals 7 .param p1 # Lph/o; .annotation build Lio/reactivex/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/Signature; value = { "(", "Lph/o<", "-TT;+", "Lok/c<", "+TR;>;>;ZII)", "Lvh/a<", "TR;>;" } .end annotation .annotation runtime Lio/reactivex/annotations/CheckReturnValue; .end annotation .annotation build Lio/reactivex/annotations/NonNull; .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, "maxConcurrency" .line 2 invoke-static {p3, v0}, Lio/reactivex/internal/functions/a;->h(ILjava/lang/String;)I const-string v0, "prefetch" .line 3 invoke-static {p4, v0}, Lio/reactivex/internal/functions/a;->h(ILjava/lang/String;)I .line 4 new-instance v0, Lio/reactivex/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/internal/operators/parallel/e;->(Lvh/a;Lph/o;ZII)V invoke-static {v0}, Lwh/a;->V(Lvh/a;)Lvh/a; move-result-object p1 return-object p1 .end method