T
- the input value typeR
- the output value typepublic final class ParallelFlatMap<T,R> extends ParallelFlowable<R>
Constructor and Description |
---|
ParallelFlatMap(ParallelFlowable<T> source,
Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper,
boolean delayError,
int maxConcurrency,
int prefetch) |
Modifier and Type | Method and 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'.
|
as, collect, compose, concatMap, concatMap, concatMapDelayError, concatMapDelayError, doAfterNext, doAfterTerminated, doOnCancel, doOnComplete, doOnError, doOnNext, doOnNext, doOnNext, doOnRequest, doOnSubscribe, filter, filter, filter, flatMap, flatMap, flatMap, flatMap, from, from, from, fromArray, map, map, map, reduce, reduce, runOn, runOn, sequential, sequential, sequentialDelayError, sequentialDelayError, sorted, sorted, to, toSortedList, toSortedList, validate
public ParallelFlatMap(ParallelFlowable<T> source, Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper, boolean delayError, int maxConcurrency, int prefetch)
public int parallelism()
ParallelFlowable
parallelism
in class ParallelFlowable<R>
public void subscribe(org.reactivestreams.Subscriber<? super R>[] subscribers)
ParallelFlowable
subscribe
in class ParallelFlowable<R>
subscribers
- the subscribers array to run in parallel, the number
of items must be equal to the parallelism level of this ParallelFlowableParallelFlowable.parallelism()
Copyright © 2018 JBoss by Red Hat. All rights reserved.