Top Description Fields Constructors Methods
io.reactivex.rxjava3.internal.operators.parallel

public final Class ParallelFlatMap<T, R>

extends ParallelFlowable<R>
Class Inheritance
Type Parameters
<T>
the input value type
<R>
the output value type
Imports
org.reactivestreams.*, io.reactivex.rxjava3.functions.Function, io.reactivex.rxjava3.internal.operators.flowable.FlowableFlatMap, io.reactivex.rxjava3.parallel.ParallelFlowable, io.reactivex.rxjava3.plugins.RxJavaPlugins
Flattens the generated Publishers on each rail.

Field Summary

Modifier and TypeField and Description
pack-priv final boolean
delayError

pack-priv final Function<? super T, ? extends Publisher<? extends R>>
mapper

pack-priv final int
maxConcurrency

pack-priv final int
prefetch

pack-priv final ParallelFlowable<T>
source

Constructor Summary

AccessConstructor and Description
public
ParallelFlatMap(ParallelFlowable<T> source, Function<? super T, ? extends Publisher<? extends R>> mapper, boolean delayError, int maxConcurrency, int prefetch)

Method Summary

Modifier and TypeMethod and Description
public int
parallelism()

Implements abstract io.reactivex.rxjava3.parallel.ParallelFlowable.parallelism.

Returns the number of expected parallel Subscribers.
public void
subscribe(Subscriber<? super R>[] subscribers)

Inherited from io.reactivex.rxjava3.parallel.ParallelFlowable:
collectcollectcomposeconcatMapconcatMapconcatMapDelayErrorconcatMapDelayErrordoAfterNextdoAfterTerminateddoOnCanceldoOnCompletedoOnErrordoOnNextdoOnNextdoOnNextdoOnRequestdoOnSubscribefilterfilterfilterflatMapflatMapflatMapflatMapflatMapIterableflatMapIterableflatMapStreamflatMapStreamfromfromfromfromArraymapmapmapmapOptionalmapOptionalmapOptionalreducereducerunOnrunOnsequentialsequentialsequentialDelayErrorsequentialDelayErrorsortedsortedsubscribetotoSortedListtoSortedListvalidate

Field Detail

delayErrorback to summary
pack-priv final boolean delayError
mapperback to summary
pack-priv final Function<? super T, ? extends Publisher<? extends R>> mapper
maxConcurrencyback to summary
pack-priv final int maxConcurrency
prefetchback to summary
pack-priv final int prefetch
sourceback to summary
pack-priv final ParallelFlowable<T> source

Constructor Detail

ParallelFlatMapback to summary
public ParallelFlatMap(ParallelFlowable<T> source, Function<? super T, ? extends Publisher<? extends R>> mapper, boolean delayError, int maxConcurrency, int prefetch)

Method Detail

parallelismback to summary
public int parallelism()

Implements abstract io.reactivex.rxjava3.parallel.ParallelFlowable.parallelism.

Doc from io.reactivex.rxjava3.parallel.ParallelFlowable.parallelism.

Returns the number of expected parallel Subscribers.

Returns:int

the number of expected parallel Subscribers

Annotations
@Override
subscribeback to summary
public void subscribe(Subscriber<? super R>[] subscribers)
Annotations
@Override