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

public final Class ParallelConcatMap<T, R>

extends ParallelFlowable<R>
Class Inheritance
Type Parameters
<T>
the input value type
<R>
the output value type
Imports
org.reactivestreams.*, io.reactivex.functions.Function, io.reactivex.internal.functions.ObjectHelper, io.reactivex.internal.operators.flowable.FlowableConcatMap, io.reactivex.internal.util.ErrorMode, io.reactivex.parallel.ParallelFlowable
Concatenates the generated Publishers on each rail.

Field Summary

Modifier and TypeField and Description
pack-priv final ErrorMode
errorMode

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

pack-priv final int
prefetch

pack-priv final ParallelFlowable<T>
source

Constructor Summary

AccessConstructor and Description
public
ParallelConcatMap(ParallelFlowable<T> source, Function<? super T, ? extends Publisher<? extends R>> mapper, int prefetch, ErrorMode errorMode)

Method Summary

Modifier and TypeMethod and Description
public int
parallelism()

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

Returns the number of expected parallel Subscribers.
public void
subscribe(Subscriber<? super R>[]
the subscribers array to run in parallel, the number of items must be equal to the parallelism level of this ParallelFlowable
subscribers)

Implements abstract io.reactivex.parallel.ParallelFlowable.subscribe.

Subscribes an array of Subscribers to this ParallelFlowable and triggers the execution chain for all 'rails'.
Inherited from io.reactivex.parallel.ParallelFlowable:
ascollectcomposeconcatMapconcatMapconcatMapDelayErrorconcatMapDelayErrordoAfterNextdoAfterTerminateddoOnCanceldoOnCompletedoOnErrordoOnNextdoOnNextdoOnNextdoOnRequestdoOnSubscribefilterfilterfilterflatMapflatMapflatMapflatMapfromfromfromfromArraymapmapmapreducereducerunOnrunOnsequentialsequentialsequentialDelayErrorsequentialDelayErrorsortedsortedtotoSortedListtoSortedListvalidate

Field Detail

errorModeback to summary
pack-priv final ErrorMode errorMode
mapperback to summary
pack-priv final Function<? super T, ? extends Publisher<? extends R>> mapper
prefetchback to summary
pack-priv final int prefetch
sourceback to summary
pack-priv final ParallelFlowable<T> source

Constructor Detail

ParallelConcatMapback to summary
public ParallelConcatMap(ParallelFlowable<T> source, Function<? super T, ? extends Publisher<? extends R>> mapper, int prefetch, ErrorMode errorMode)

Method Detail

parallelismback to summary
public int parallelism()

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

Doc from io.reactivex.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)

Implements abstract io.reactivex.parallel.ParallelFlowable.subscribe.

Doc from io.reactivex.parallel.ParallelFlowable.subscribe.

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

Parameters
subscribers:Subscriber<? super R>[]

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

Annotations
@Override