Uses of Class
io.reactivex.rxjava3.parallel.ParallelFlowable
Packages that use ParallelFlowable
Package
Description
Base reactive classes:
Flowable
, Observable
,
Single
, Maybe
and
Completable
; base reactive consumers;
other common base interfaces.Contains the base type
ParallelFlowable
,
a sub-DSL for working with Flowable
sequences in parallel.Contains the central plugin handler
RxJavaPlugins
class to hook into the lifecycle of the base reactive types and schedulers.-
Uses of ParallelFlowable in io.reactivex.rxjava3.core
Methods in io.reactivex.rxjava3.core that return ParallelFlowableModifier and TypeMethodDescriptionfinal @NonNull ParallelFlowable
<T> Flowable.parallel()
Parallelizes the flow by creating multiple 'rails' (equal to the number of CPUs) and dispatches the upstream items to them in a round-robin fashion.final @NonNull ParallelFlowable
<T> Flowable.parallel
(int parallelism) Parallelizes the flow by creating the specified number of 'rails' and dispatches the upstream items to them in a round-robin fashion.final @NonNull ParallelFlowable
<T> Flowable.parallel
(int parallelism, int prefetch) Parallelizes the flow by creating the specified number of 'rails' and dispatches the upstream items to them in a round-robin fashion and uses the defined per-'rail' prefetch amount. -
Uses of ParallelFlowable in io.reactivex.rxjava3.internal.jdk8
Subclasses of ParallelFlowable in io.reactivex.rxjava3.internal.jdk8Modifier and TypeClassDescriptionfinal class
Flattens the generatedStream
s on each rail.final class
ParallelMapOptional<T,
R> Maps each 'rail' of the source ParallelFlowable with a mapper function.final class
Maps each 'rail' of the source ParallelFlowable with a mapper function and handle any failure based on a handler function.Fields in io.reactivex.rxjava3.internal.jdk8 declared as ParallelFlowableModifier and TypeFieldDescription(package private) final ParallelFlowable
<? extends T> ParallelCollector.source
(package private) final ParallelFlowable
<T> ParallelFlatMapStream.source
(package private) final ParallelFlowable
<T> ParallelMapOptional.source
(package private) final ParallelFlowable
<T> ParallelMapTryOptional.source
Constructors in io.reactivex.rxjava3.internal.jdk8 with parameters of type ParallelFlowableModifierConstructorDescriptionParallelCollector
(ParallelFlowable<? extends T> source, Collector<T, A, R> collector) ParallelFlatMapStream
(ParallelFlowable<T> source, Function<? super T, ? extends Stream<? extends R>> mapper, int prefetch) ParallelMapOptional
(ParallelFlowable<T> source, Function<? super T, Optional<? extends R>> mapper) ParallelMapTryOptional
(ParallelFlowable<T> source, Function<? super T, Optional<? extends R>> mapper, BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler) -
Uses of ParallelFlowable in io.reactivex.rxjava3.internal.operators.parallel
Subclasses of ParallelFlowable in io.reactivex.rxjava3.internal.operators.parallelModifier and TypeClassDescriptionfinal class
ParallelCollect<T,
C> Reduce the sequence of values in each 'rail' to a single value.final class
ParallelConcatMap<T,
R> Concatenates the generated Publishers on each rail.final class
Calls a Consumer for each upstream value passing by and handles any failure with a handler function.final class
Filters each 'rail' of the source ParallelFlowable with a predicate function.final class
Filters each 'rail' of the source ParallelFlowable with a predicate function.final class
ParallelFlatMap<T,
R> Flattens the generated Publishers on each rail.final class
Flattens the generatedIterable
s on each rail.final class
Wraps multiple Publishers into a ParallelFlowable which runs them in parallel.final class
Dispatches the values from upstream in a round robin fashion to subscribers which are ready to consume elements.final class
ParallelMap<T,
R> Maps each 'rail' of the source ParallelFlowable with a mapper function.final class
ParallelMapTry<T,
R> Maps each 'rail' of the source ParallelFlowable with a mapper function and handle any failure based on a handler function.final class
ParallelPeek<T>
Execute a Consumer in each 'rail' for the current element passing through.final class
ParallelReduce<T,
R> Reduce the sequence of values in each 'rail' to a single value.final class
Ensures each 'rail' from upstream runs on a Worker from a Scheduler.Fields in io.reactivex.rxjava3.internal.operators.parallel declared as ParallelFlowableModifier and TypeFieldDescription(package private) final ParallelFlowable
<? extends T> ParallelCollect.source
(package private) final ParallelFlowable
<T> ParallelConcatMap.source
(package private) final ParallelFlowable
<T> ParallelDoOnNextTry.source
(package private) final ParallelFlowable
<T> ParallelFilter.source
(package private) final ParallelFlowable
<T> ParallelFilterTry.source
(package private) final ParallelFlowable
<T> ParallelFlatMap.source
(package private) final ParallelFlowable
<T> ParallelFlatMapIterable.source
(package private) final ParallelFlowable
<? extends T> ParallelJoin.source
(package private) final ParallelFlowable
<T> ParallelMap.source
(package private) final ParallelFlowable
<T> ParallelMapTry.source
(package private) final ParallelFlowable
<T> ParallelPeek.source
(package private) final ParallelFlowable
<? extends T> ParallelReduce.source
(package private) final ParallelFlowable
<? extends T> ParallelReduceFull.source
(package private) final ParallelFlowable
<? extends T> ParallelRunOn.source
(package private) final ParallelFlowable
<List<T>> ParallelSortedJoin.source
Constructors in io.reactivex.rxjava3.internal.operators.parallel with parameters of type ParallelFlowableModifierConstructorDescriptionParallelCollect
(ParallelFlowable<? extends T> source, Supplier<? extends C> initialCollection, BiConsumer<? super C, ? super T> collector) ParallelConcatMap
(ParallelFlowable<T> source, Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>> mapper, int prefetch, ErrorMode errorMode) ParallelDoOnNextTry
(ParallelFlowable<T> source, Consumer<? super T> onNext, BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler) ParallelFilter
(ParallelFlowable<T> source, Predicate<? super T> predicate) ParallelFilterTry
(ParallelFlowable<T> source, Predicate<? super T> predicate, BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler) ParallelFlatMap
(ParallelFlowable<T> source, Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>> mapper, boolean delayError, int maxConcurrency, int prefetch) ParallelFlatMapIterable
(ParallelFlowable<T> source, Function<? super T, ? extends Iterable<? extends R>> mapper, int prefetch) ParallelJoin
(ParallelFlowable<? extends T> source, int prefetch, boolean delayErrors) ParallelMap
(ParallelFlowable<T> source, Function<? super T, ? extends R> mapper) ParallelMapTry
(ParallelFlowable<T> source, Function<? super T, ? extends R> mapper, BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler) ParallelPeek
(ParallelFlowable<T> source, Consumer<? super T> onNext, Consumer<? super T> onAfterNext, Consumer<? super Throwable> onError, Action onComplete, Action onAfterTerminated, Consumer<? super org.reactivestreams.Subscription> onSubscribe, LongConsumer onRequest, Action onCancel) ParallelReduce
(ParallelFlowable<? extends T> source, Supplier<R> initialSupplier, BiFunction<R, ? super T, R> reducer) ParallelReduceFull
(ParallelFlowable<? extends T> source, BiFunction<T, T, T> reducer) ParallelRunOn
(ParallelFlowable<? extends T> parent, Scheduler scheduler, int prefetch) ParallelSortedJoin
(ParallelFlowable<List<T>> source, Comparator<? super T> comparator) -
Uses of ParallelFlowable in io.reactivex.rxjava3.parallel
Methods in io.reactivex.rxjava3.parallel that return ParallelFlowableModifier and TypeMethodDescriptionParallelTransformer.apply
(@NonNull ParallelFlowable<@NonNull Upstream> upstream) Applies a function to the upstream ParallelFlowable and returns a ParallelFlowable with optionally different element type.final <@NonNull C>
@NonNull ParallelFlowable<C> ParallelFlowable.collect
(@NonNull Supplier<? extends @NonNull C> collectionSupplier, @NonNull BiConsumer<? super @NonNull C, ? super @NonNull T> collector) Collect the elements in each rail into a collection supplied via acollectionSupplier
and collected into with a collector action, emitting the collection at the end.final <@NonNull U>
@NonNull ParallelFlowable<U> Allows composing operators, in assembly time, on top of thisParallelFlowable
and returns anotherParallelFlowable
with composed features.final <@NonNull R>
@NonNull ParallelFlowable<R> ParallelFlowable.concatMap
(@NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper) Generates and concatenatesPublisher
s on each 'rail', signalling errors immediately and generating 2 publishers upfront.final <@NonNull R>
@NonNull ParallelFlowable<R> ParallelFlowable.concatMap
(@NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper, int prefetch) Generates and concatenatesPublisher
s on each 'rail', signalling errors immediately and using the given prefetch amount for generatingPublisher
s upfront.final <@NonNull R>
@NonNull ParallelFlowable<R> ParallelFlowable.concatMapDelayError
(@NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper, boolean tillTheEnd) Generates and concatenatesPublisher
s on each 'rail', optionally delaying errors and generating 2 publishers upfront.final <@NonNull R>
@NonNull ParallelFlowable<R> ParallelFlowable.concatMapDelayError
(@NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper, int prefetch, boolean tillTheEnd) Generates and concatenatesPublisher
s on each 'rail', optionally delaying errors and using the given prefetch amount for generatingPublisher
s upfront.final @NonNull ParallelFlowable
<T> ParallelFlowable.doAfterNext
(@NonNull Consumer<? super @NonNull T> onAfterNext) Call the specified consumer with the current element passing through any 'rail' after it has been delivered to downstream within the rail.final @NonNull ParallelFlowable
<T> ParallelFlowable.doAfterTerminated
(@NonNull Action onAfterTerminate) Run the specifiedAction
when a 'rail' completes or signals an error.final @NonNull ParallelFlowable
<T> ParallelFlowable.doOnCancel
(@NonNull Action onCancel) Run the specifiedAction
when a 'rail' receives a cancellation.final @NonNull ParallelFlowable
<T> ParallelFlowable.doOnComplete
(@NonNull Action onComplete) Run the specifiedAction
when a 'rail' completes.final @NonNull ParallelFlowable
<T> Call the specified consumer with the exception passing through any 'rail'.final @NonNull ParallelFlowable
<T> Call the specified consumer with the current element passing through any 'rail'.final @NonNull ParallelFlowable
<T> ParallelFlowable.doOnNext
(@NonNull Consumer<? super @NonNull T> onNext, @NonNull BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler) Call the specified consumer with the current element passing through any 'rail' and handles errors based on the returned value by the handler function.final @NonNull ParallelFlowable
<T> ParallelFlowable.doOnNext
(@NonNull Consumer<? super @NonNull T> onNext, @NonNull ParallelFailureHandling errorHandler) Call the specified consumer with the current element passing through any 'rail' and handles errors based on the givenParallelFailureHandling
enumeration value.final @NonNull ParallelFlowable
<T> ParallelFlowable.doOnRequest
(@NonNull LongConsumer onRequest) Call the specified consumer with the request amount if any rail receives a request.final @NonNull ParallelFlowable
<T> ParallelFlowable.doOnSubscribe
(@NonNull Consumer<? super org.reactivestreams.Subscription> onSubscribe) Call the specified callback when a 'rail' receives aSubscription
from its upstream.final @NonNull ParallelFlowable
<T> Filters the source values on each 'rail'.final @NonNull ParallelFlowable
<T> ParallelFlowable.filter
(@NonNull Predicate<? super @NonNull T> predicate, @NonNull BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler) Filters the source values on each 'rail' and handles errors based on the returned value by the handler function.final @NonNull ParallelFlowable
<T> ParallelFlowable.filter
(@NonNull Predicate<? super @NonNull T> predicate, @NonNull ParallelFailureHandling errorHandler) Filters the source values on each 'rail' and handles errors based on the givenParallelFailureHandling
enumeration value.final <@NonNull R>
@NonNull ParallelFlowable<R> ParallelFlowable.flatMap
(@NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper) Generates and flattensPublisher
s on each 'rail'.final <@NonNull R>
@NonNull ParallelFlowable<R> ParallelFlowable.flatMap
(@NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper, boolean delayError) Generates and flattensPublisher
s on each 'rail', optionally delaying errors.final <@NonNull R>
@NonNull ParallelFlowable<R> ParallelFlowable.flatMap
(@NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper, boolean delayError, int maxConcurrency) Generates and flattensPublisher
s on each 'rail', optionally delaying errors and having a total number of simultaneous subscriptions to the innerPublisher
s.final <@NonNull R>
@NonNull ParallelFlowable<R> ParallelFlowable.flatMap
(@NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper, boolean delayError, int maxConcurrency, int prefetch) Generates and flattensPublisher
s on each 'rail', optionally delaying errors, having a total number of simultaneous subscriptions to the innerPublisher
s and using the given prefetch amount for the innerPublisher
s.final <@NonNull U>
@NonNull ParallelFlowable<U> ParallelFlowable.flatMapIterable
(@NonNull Function<? super @NonNull T, @NonNull ? extends Iterable<? extends @NonNull U>> mapper) Returns aParallelFlowable
that merges each item emitted by the source on each rail with the values in anIterable
corresponding to that item that is generated by a selector.final <@NonNull U>
@NonNull ParallelFlowable<U> ParallelFlowable.flatMapIterable
(@NonNull Function<? super @NonNull T, @NonNull ? extends Iterable<? extends @NonNull U>> mapper, int bufferSize) Returns aParallelFlowable
that merges each item emitted by the sourceParallelFlowable
with the values in anIterable
corresponding to that item that is generated by a selector.final <@NonNull R>
@NonNull ParallelFlowable<R> ParallelFlowable.flatMapStream
(@NonNull Function<? super @NonNull T, @NonNull ? extends Stream<? extends @NonNull R>> mapper) Maps each upstream item on each rail into aStream
and emits theStream
's items to the downstream in a sequential fashion.final <@NonNull R>
@NonNull ParallelFlowable<R> ParallelFlowable.flatMapStream
(@NonNull Function<? super @NonNull T, @NonNull ? extends Stream<? extends @NonNull R>> mapper, int prefetch) Maps each upstream item of each rail into aStream
and emits theStream
's items to the downstream in a sequential fashion.static <@NonNull T>
@NonNull ParallelFlowable<T> Take aPublisher
and prepare to consume it on multiple 'rails' (number of CPUs) in a round-robin fashion.static <@NonNull T>
@NonNull ParallelFlowable<T> ParallelFlowable.from
(@NonNull org.reactivestreams.Publisher<? extends @NonNull T> source, int parallelism) Take aPublisher
and prepare to consume it on parallelism number of 'rails' in a round-robin fashion.static <@NonNull T>
@NonNull ParallelFlowable<T> ParallelFlowable.from
(@NonNull org.reactivestreams.Publisher<? extends @NonNull T> source, int parallelism, int prefetch) Take aPublisher
and prepare to consume it on parallelism number of 'rails' , possibly ordered and round-robin fashion and use custom prefetch amount and queue for dealing with the sourcePublisher
's values.static <@NonNull T>
@NonNull ParallelFlowable<T> Wraps multiplePublisher
s into aParallelFlowable
which runs them in parallel and unordered.final <@NonNull R>
@NonNull ParallelFlowable<R> Maps the source values on each 'rail' to another value.final <@NonNull R>
@NonNull ParallelFlowable<R> ParallelFlowable.map
(@NonNull Function<? super @NonNull T, ? extends @NonNull R> mapper, @NonNull BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler) Maps the source values on each 'rail' to another value and handles errors based on the returned value by the handler function.final <@NonNull R>
@NonNull ParallelFlowable<R> ParallelFlowable.map
(@NonNull Function<? super @NonNull T, ? extends @NonNull R> mapper, @NonNull ParallelFailureHandling errorHandler) Maps the source values on each 'rail' to another value and handles errors based on the givenParallelFailureHandling
enumeration value.final <@NonNull R>
@NonNull ParallelFlowable<R> ParallelFlowable.mapOptional
(@NonNull Function<? super @NonNull T, @NonNull Optional<? extends @NonNull R>> mapper) Maps the source values on each 'rail' to an optional and emits its value if any.final <@NonNull R>
@NonNull ParallelFlowable<R> ParallelFlowable.mapOptional
(@NonNull Function<? super @NonNull T, @NonNull Optional<? extends @NonNull R>> mapper, @NonNull BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler) Maps the source values on each 'rail' to an optional and emits its value if any and handles errors based on the returned value by the handler function.final <@NonNull R>
@NonNull ParallelFlowable<R> ParallelFlowable.mapOptional
(@NonNull Function<? super @NonNull T, @NonNull Optional<? extends @NonNull R>> mapper, @NonNull ParallelFailureHandling errorHandler) Maps the source values on each 'rail' to an optional and emits its value if any and handles errors based on the givenParallelFailureHandling
enumeration value.final <@NonNull R>
@NonNull ParallelFlowable<R> ParallelFlowable.reduce
(@NonNull Supplier<@NonNull R> initialSupplier, @NonNull BiFunction<@NonNull R, ? super @NonNull T, @NonNull R> reducer) Reduces all values within a 'rail' to a single value (with a possibly different type) via a reducer function that is initialized on each rail from aninitialSupplier
value.final @NonNull ParallelFlowable
<T> Specifies where each 'rail' will observe its incoming values, specified via aScheduler
, with no work-stealing and default prefetch amount.final @NonNull ParallelFlowable
<T> Specifies where each 'rail' will observe its incoming values, specified via aScheduler
, with possibly work-stealing and a given prefetch amount.Methods in io.reactivex.rxjava3.parallel with parameters of type ParallelFlowableModifier and TypeMethodDescriptionParallelFlowableConverter.apply
(@NonNull ParallelFlowable<T> upstream) Applies a function to the upstream ParallelFlowable and returns a converted value of typeR
.ParallelTransformer.apply
(@NonNull ParallelFlowable<@NonNull Upstream> upstream) Applies a function to the upstream ParallelFlowable and returns a ParallelFlowable with optionally different element type. -
Uses of ParallelFlowable in io.reactivex.rxjava3.plugins
Fields in io.reactivex.rxjava3.plugins with type parameters of type ParallelFlowableModifier and TypeFieldDescription(package private) static @Nullable Function
<? super ParallelFlowable, ? extends ParallelFlowable> RxJavaPlugins.onParallelAssembly
(package private) static @Nullable Function
<? super ParallelFlowable, ? extends ParallelFlowable> RxJavaPlugins.onParallelAssembly
(package private) static @Nullable BiFunction
<? super ParallelFlowable, @NonNull ? super org.reactivestreams.Subscriber[], @NonNull ? extends org.reactivestreams.Subscriber[]> RxJavaPlugins.onParallelSubscribe
Methods in io.reactivex.rxjava3.plugins that return ParallelFlowableModifier and TypeMethodDescriptionstatic <@NonNull T>
@NonNull ParallelFlowable<T> RxJavaPlugins.onAssembly
(@NonNull ParallelFlowable<@NonNull T> source) Calls the associated hook function.Methods in io.reactivex.rxjava3.plugins that return types with arguments of type ParallelFlowableModifier and TypeMethodDescriptionstatic @Nullable Function
<? super ParallelFlowable, ? extends ParallelFlowable> RxJavaPlugins.getOnParallelAssembly()
Returns the current hook function.static @Nullable Function
<? super ParallelFlowable, ? extends ParallelFlowable> RxJavaPlugins.getOnParallelAssembly()
Returns the current hook function.static @Nullable BiFunction
<? super ParallelFlowable, @NonNull ? super org.reactivestreams.Subscriber[], @NonNull ? extends org.reactivestreams.Subscriber[]> RxJavaPlugins.getOnParallelSubscribe()
Returns the current hook function.Methods in io.reactivex.rxjava3.plugins with parameters of type ParallelFlowableModifier and TypeMethodDescriptionstatic <@NonNull T>
@NonNull ParallelFlowable<T> RxJavaPlugins.onAssembly
(@NonNull ParallelFlowable<@NonNull T> source) Calls the associated hook function.RxJavaPlugins.onSubscribe
(@NonNull ParallelFlowable<@NonNull T> source, @NonNull org.reactivestreams.Subscriber<? super @NonNull T>[] subscribers) Calls the associated hook function.Method parameters in io.reactivex.rxjava3.plugins with type arguments of type ParallelFlowableModifier and TypeMethodDescriptionstatic void
RxJavaPlugins.setOnParallelAssembly
(@Nullable Function<? super ParallelFlowable, ? extends ParallelFlowable> handler) Sets the specific hook function.static void
RxJavaPlugins.setOnParallelAssembly
(@Nullable Function<? super ParallelFlowable, ? extends ParallelFlowable> handler) Sets the specific hook function.static void
RxJavaPlugins.setOnParallelSubscribe
(@Nullable BiFunction<? super ParallelFlowable, @NonNull ? super org.reactivestreams.Subscriber[], @NonNull ? extends org.reactivestreams.Subscriber[]> handler) Sets the specific hook function.