Package io.reactivex.rxjava3.internal.operators.parallel
package io.reactivex.rxjava3.internal.operators.parallel
-
ClassesClassDescriptionParallelCollect<T,
C> Reduce the sequence of values in each 'rail' to a single value.ParallelConcatMap<T,R> Concatenates the generated Publishers on each rail.Calls a Consumer for each upstream value passing by and handles any failure with a handler function.Filters each 'rail' of the source ParallelFlowable with a predicate function.Filters each 'rail' of the source ParallelFlowable with a predicate function.ParallelFlatMap<T,R> Flattens the generated Publishers on each rail.Flattens the generatedIterable
s on each rail.Wraps multiple Publishers into a ParallelFlowable which runs them in parallel.Dispatches the values from upstream in a round robin fashion to subscribers which are ready to consume elements.ParallelJoin<T>Merges the individual 'rails' of the source ParallelFlowable, unordered, into a single regular Publisher sequence (exposed as Flowable).ParallelMap<T,R> Maps each 'rail' of the source ParallelFlowable with a mapper function.ParallelMapTry<T,R> Maps each 'rail' of the source ParallelFlowable with a mapper function and handle any failure based on a handler function.ParallelPeek<T>Execute a Consumer in each 'rail' for the current element passing through.ParallelReduce<T,R> Reduce the sequence of values in each 'rail' to a single value.Reduces all 'rails' into a single value which then gets reduced into a single Publisher sequence.Ensures each 'rail' from upstream runs on a Worker from a Scheduler.Given sorted rail sequences (according to the provided comparator) as List emit the smallest item from these parallel Lists to the Subscriber.