Class ParallelMap<T,R>
- java.lang.Object
-
- io.reactivex.rxjava3.parallel.ParallelFlowable<R>
-
- io.reactivex.rxjava3.internal.operators.parallel.ParallelMap<T,R>
-
- Type Parameters:
T- the input value typeR- the output value type
public final class ParallelMap<T,R> extends ParallelFlowable<R>
Maps each 'rail' of the source ParallelFlowable with a mapper function.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description (package private) static classParallelMap.ParallelMapConditionalSubscriber<T,R>(package private) static classParallelMap.ParallelMapSubscriber<T,R>
-
Constructor Summary
Constructors Constructor Description ParallelMap(ParallelFlowable<T> source, Function<? super T,? extends R> mapper)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description intparallelism()Returns the number of expected parallelSubscribers.voidsubscribe(org.reactivestreams.Subscriber<? super R>[] subscribers)Subscribes an array ofSubscribers to thisParallelFlowableand 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
-
-
Constructor Detail
-
ParallelMap
public ParallelMap(ParallelFlowable<T> source, Function<? super T,? extends R> mapper)
-
-
Method Detail
-
subscribe
public void subscribe(org.reactivestreams.Subscriber<? super R>[] subscribers)
Description copied from class:ParallelFlowableSubscribes an array ofSubscribers to thisParallelFlowableand triggers the execution chain for all 'rails'.- Backpressure:
- The backpressure behavior/expectation is determined by the supplied
Subscriber. - Scheduler:
subscribedoes not operate by default on a particularScheduler.
- Specified by:
subscribein 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()
-
parallelism
public int parallelism()
Description copied from class:ParallelFlowableReturns the number of expected parallelSubscribers.- Specified by:
parallelismin classParallelFlowable<R>- Returns:
- the number of expected parallel
Subscribers
-
-