Package io.reactivex.rxjava3.internal.operators.parallel

package io.reactivex.rxjava3.internal.operators.parallel

Classes

Class	Description
ParallelCollect<T,C>	Reduce the sequence of values in each 'rail' to a single value.
ParallelConcatMap<T,R>	Concatenates the generated Publishers on each rail.
ParallelDoOnNextTry<T>	Calls a Consumer for each upstream value passing by and handles any failure with a handler function.
ParallelFilter<T>	Filters each 'rail' of the source ParallelFlowable with a predicate function.
ParallelFilterTry<T>	Filters each 'rail' of the source ParallelFlowable with a predicate function.
ParallelFlatMap<T,R>	Flattens the generated Publishers on each rail.
ParallelFlatMapIterable<T,R>	Flattens the generated Iterables on each rail.
ParallelFromArray<T>	Wraps multiple Publishers into a ParallelFlowable which runs them in parallel.
ParallelFromPublisher<T>	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.
ParallelReduceFull<T>	Reduces all 'rails' into a single value which then gets reduced into a single Publisher sequence.
ParallelRunOn<T>	Ensures each 'rail' from upstream runs on a Worker from a Scheduler.
ParallelSortedJoin<T>	Given sorted rail sequences (according to the provided comparator) as List emit the smallest item from these parallel Lists to the Subscriber.