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

Class ParallelFlatMap<T,R>

java.lang.Object

io.reactivex.rxjava3.parallel.ParallelFlowable<R>

io.reactivex.rxjava3.internal.operators.parallel.ParallelFlatMap<T,R>

Type Parameters:

T - the input value type

R - the output value type

public final class ParallelFlatMap<T,R>
extends ParallelFlowable<R>

Flattens the generated Publishers on each rail.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) boolean	delayError
(package private) Function<? super T,? extends org.reactivestreams.Publisher<? extends R>>	mapper
(package private) int	maxConcurrency
(package private) int	prefetch
(package private) ParallelFlowable<T>	source

Constructor Summary

Constructors

Constructor	Description
ParallelFlatMap(ParallelFlowable<T> source, Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper, boolean delayError, int maxConcurrency, int prefetch)

Method Summary

Modifier and Type	Method	Description
int	parallelism()	Returns the number of expected parallel Subscribers.
void	subscribe(org.reactivestreams.Subscriber<? super R>[] subscribers)	Subscribes an array of Subscribers to this ParallelFlowable and triggers the execution chain for all 'rails'.

Methods inherited from class io.reactivex.rxjava3.parallel.ParallelFlowable

collect, collect, compose, concatMap, concatMap, concatMapDelayError, concatMapDelayError, doAfterNext, doAfterTerminated, doOnCancel, doOnComplete, doOnError, doOnNext, doOnNext, doOnNext, doOnRequest, doOnSubscribe, filter, filter, filter, flatMap, flatMap, flatMap, flatMap, flatMapIterable, flatMapIterable, flatMapStream, flatMapStream, from, from, from, fromArray, map, map, map, mapOptional, mapOptional, mapOptional, reduce, reduce, runOn, runOn, sequential, sequential, sequentialDelayError, sequentialDelayError, sorted, sorted, to, toSortedList, toSortedList, validate

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

source

final ParallelFlowable<T> source

mapper

final Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper

delayError

final boolean delayError

maxConcurrency

final int maxConcurrency

prefetch

final int prefetch

Constructor Detail

ParallelFlatMap

public ParallelFlatMap(ParallelFlowable<T> source,
                       Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper,
                       boolean delayError,
                       int maxConcurrency,
                       int prefetch)

Method Detail

parallelism

public int parallelism()

Description copied from class: ParallelFlowable

Returns the number of expected parallel Subscribers.

Specified by:

parallelism in class ParallelFlowable<R>

Returns:

the number of expected parallel Subscribers

subscribe

public void subscribe(org.reactivestreams.Subscriber<? super R>[] subscribers)

Description copied from class: ParallelFlowable

Subscribes an array of Subscribers to this ParallelFlowable and triggers the execution chain for all 'rails'.

Backpressure:

The backpressure behavior/expectation is determined by the supplied Subscriber.

Scheduler:

subscribe does not operate by default on a particular Scheduler.

Specified by:

subscribe in class ParallelFlowable<R>

Parameters:

subscribers - the subscribers array to run in parallel, the number of items must be equal to the parallelism level of this ParallelFlowable

See Also:

ParallelFlowable.parallelism()