Uses of Class
io.reactivex.rxjava3.parallel.ParallelFlowable

Packages that use ParallelFlowable

Package	Description
io.reactivex.rxjava3.core	Base reactive classes: Flowable, Observable, Single, Maybe and Completable; base reactive consumers; other common base interfaces.
io.reactivex.rxjava3.internal.jdk8
io.reactivex.rxjava3.internal.operators.parallel
io.reactivex.rxjava3.parallel	Contains the base type ParallelFlowable, a sub-DSL for working with Flowable sequences in parallel.
io.reactivex.rxjava3.plugins	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 ParallelFlowable

Modifier and Type	Method	Description
final @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.jdk8

Modifier and Type	Class	Description
final class	ParallelFlatMapStream<T,R>	Flattens the generated Streams on each rail.
final class	ParallelMapOptional<T,R>	Maps each 'rail' of the source ParallelFlowable with a mapper function.
final class	ParallelMapTryOptional<T,R>	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 ParallelFlowable

Modifier and Type	Field	Description
(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 ParallelFlowable

Modifier	Constructor	Description
	ParallelCollector(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.parallel

Modifier and Type	Class	Description
final 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	ParallelDoOnNextTry<T>	Calls a Consumer for each upstream value passing by and handles any failure with a handler function.
final class	ParallelFilter<T>	Filters each 'rail' of the source ParallelFlowable with a predicate function.
final class	ParallelFilterTry<T>	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	ParallelFlatMapIterable<T,R>	Flattens the generated Iterables on each rail.
final class	ParallelFromArray<T>	Wraps multiple Publishers into a ParallelFlowable which runs them in parallel.
final class	ParallelFromPublisher<T>	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	ParallelRunOn<T>	Ensures each 'rail' from upstream runs on a Worker from a Scheduler.

Fields in io.reactivex.rxjava3.internal.operators.parallel declared as ParallelFlowable

Modifier and Type	Field	Description
(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 ParallelFlowable

Modifier	Constructor	Description
	ParallelCollect(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 ParallelFlowable

Modifier and Type	Method	Description
@NonNull ParallelFlowable<Downstream>	ParallelTransformer.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 a collectionSupplier and collected into with a collector action, emitting the collection at the end.
final <@NonNull U> @NonNull ParallelFlowable<U>	ParallelFlowable.compose(@NonNull ParallelTransformer<@NonNull T, @NonNull U> composer)	Allows composing operators, in assembly time, on top of this ParallelFlowable and returns another ParallelFlowable 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 concatenates Publishers 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 concatenates Publishers on each 'rail', signalling errors immediately and using the given prefetch amount for generating Publishers 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 concatenates Publishers 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 concatenates Publishers on each 'rail', optionally delaying errors and using the given prefetch amount for generating Publishers 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 specified Action when a 'rail' completes or signals an error.
final @NonNull ParallelFlowable<T>	ParallelFlowable.doOnCancel(@NonNull Action onCancel)	Run the specified Action when a 'rail' receives a cancellation.
final @NonNull ParallelFlowable<T>	ParallelFlowable.doOnComplete(@NonNull Action onComplete)	Run the specified Action when a 'rail' completes.
final @NonNull ParallelFlowable<T>	ParallelFlowable.doOnError(@NonNull Consumer<? super Throwable> onError)	Call the specified consumer with the exception passing through any 'rail'.
final @NonNull ParallelFlowable<T>	ParallelFlowable.doOnNext(@NonNull Consumer<? super @NonNull T> onNext)	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 given ParallelFailureHandling 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 a Subscription from its upstream.
final @NonNull ParallelFlowable<T>	ParallelFlowable.filter(@NonNull Predicate<? super @NonNull T> predicate)	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 given ParallelFailureHandling 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 flattens Publishers 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 flattens Publishers 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 flattens Publishers on each 'rail', optionally delaying errors and having a total number of simultaneous subscriptions to the inner Publishers.
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 flattens Publishers on each 'rail', optionally delaying errors, having a total number of simultaneous subscriptions to the inner Publishers and using the given prefetch amount for the inner Publishers.
final <@NonNull U> @NonNull ParallelFlowable<U>	ParallelFlowable.flatMapIterable(@NonNull Function<? super @NonNull T, @NonNull ? extends Iterable<? extends @NonNull U>> mapper)	Returns a ParallelFlowable that merges each item emitted by the source on each rail with the values in an Iterable 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 a ParallelFlowable that merges each item emitted by the source ParallelFlowable with the values in an Iterable 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 a Stream and emits the Stream'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 a Stream and emits the Stream's items to the downstream in a sequential fashion.
static <@NonNull T> @NonNull ParallelFlowable<T>	ParallelFlowable.from(@NonNull org.reactivestreams.Publisher<? extends @NonNull T> source)	Take a Publisher 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 a Publisher 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 a Publisher 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 source Publisher's values.
static <@NonNull T> @NonNull ParallelFlowable<T>	ParallelFlowable.fromArray(@NonNull org.reactivestreams.Publisher<@NonNull T>... publishers)	Wraps multiple Publishers into a ParallelFlowable which runs them in parallel and unordered.
final <@NonNull R> @NonNull ParallelFlowable<R>	ParallelFlowable.map(@NonNull Function<? super @NonNull T, ? extends @NonNull R> mapper)	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 given ParallelFailureHandling 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 given ParallelFailureHandling 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 an initialSupplier value.
final @NonNull ParallelFlowable<T>	ParallelFlowable.runOn(@NonNull Scheduler scheduler)	Specifies where each 'rail' will observe its incoming values, specified via a Scheduler, with no work-stealing and default prefetch amount.
final @NonNull ParallelFlowable<T>	ParallelFlowable.runOn(@NonNull Scheduler scheduler, int prefetch)	Specifies where each 'rail' will observe its incoming values, specified via a Scheduler, with possibly work-stealing and a given prefetch amount.

Methods in io.reactivex.rxjava3.parallel with parameters of type ParallelFlowable

Modifier and Type	Method	Description
R	ParallelFlowableConverter.apply(@NonNull ParallelFlowable<T> upstream)	Applies a function to the upstream ParallelFlowable and returns a converted value of type R.
@NonNull ParallelFlowable<Downstream>	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 ParallelFlowable

Modifier and Type	Field	Description
(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 ParallelFlowable

Modifier and Type	Method	Description
static <@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 ParallelFlowable

Modifier and Type	Method	Description
static @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 ParallelFlowable

Modifier and Type	Method	Description
static <@NonNull T> @NonNull ParallelFlowable<T>	RxJavaPlugins.onAssembly(@NonNull ParallelFlowable<@NonNull T> source)	Calls the associated hook function.
static <@NonNull T> @NonNull org.reactivestreams.Subscriber<? super T>[]	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 ParallelFlowable

Modifier and Type	Method	Description
static 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.