Class ParallelFlowable<T>

java.lang.Object
io.reactivex.rxjava3.parallel.ParallelFlowable<T>
Type Parameters:
T - the value type
Direct Known Subclasses:
ParallelCollect, ParallelConcatMap, ParallelDoOnNextTry, ParallelFilter, ParallelFilterTry, ParallelFlatMap, ParallelFlatMapIterable, ParallelFlatMapStream, ParallelFromArray, ParallelFromPublisher, ParallelMap, ParallelMapOptional, ParallelMapTry, ParallelMapTryOptional, ParallelPeek, ParallelReduce, ParallelRunOn

public abstract class ParallelFlowable<@NonNull T> extends Object
Abstract base class for parallel publishing of events signaled to an array of Subscribers.

Use from(Publisher) to start processing a regular Publisher in 'rails'. Use runOn(Scheduler) to introduce where each 'rail' should run on thread-vise. Use sequential() to merge the sources back into a single Flowable.

History: 2.0.5 - experimental; 2.1 - beta

Since:
2.2