Class ParallelMapOptional<T,R>
- java.lang.Object
-
- io.reactivex.rxjava3.parallel.ParallelFlowable<R>
-
- io.reactivex.rxjava3.internal.jdk8.ParallelMapOptional<T,R>
-
- Type Parameters:
T- the input value typeR- the output value type
public final class ParallelMapOptional<T,R> extends ParallelFlowable<R>
Maps each 'rail' of the source ParallelFlowable with a mapper function.- Since:
- 3.0.0
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description (package private) static classParallelMapOptional.ParallelMapConditionalSubscriber<T,R>(package private) static classParallelMapOptional.ParallelMapSubscriber<T,R>
-
Constructor Summary
Constructors Constructor Description ParallelMapOptional(ParallelFlowable<T> source, Function<? super T,java.util.Optional<? 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
-
ParallelMapOptional
public ParallelMapOptional(ParallelFlowable<T> source, Function<? super T,java.util.Optional<? 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
-
-