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 typeR
- 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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description int
parallelism()
Returns the number of expected parallelSubscriber
s.void
subscribe(org.reactivestreams.Subscriber<? super R>[] subscribers)
Subscribes an array ofSubscriber
s to thisParallelFlowable
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
-
-
-
-
Field Detail
-
source
final ParallelFlowable<T> source
-
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 parallelSubscriber
s.- Specified by:
parallelism
in classParallelFlowable<R>
- Returns:
- the number of expected parallel
Subscriber
s
-
subscribe
public void subscribe(org.reactivestreams.Subscriber<? super R>[] subscribers)
Description copied from class:ParallelFlowable
Subscribes an array ofSubscriber
s to thisParallelFlowable
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 particularScheduler
.
- Specified by:
subscribe
in classParallelFlowable<R>
- Parameters:
subscribers
- the subscribers array to run in parallel, the number of items must be equal to the parallelism level of thisParallelFlowable
- See Also:
ParallelFlowable.parallelism()
-
-