Top Description Fields Constructors Methods
io.reactivex.rxjava3.internal.jdk8

public final Class ParallelFlatMapStream<T, R>

extends ParallelFlowable<R>
Class Inheritance
Type Parameters
<T>
the input value type
<R>
the output value type
Imports
java.util.stream.Stream, org.reactivestreams.Subscriber, io.reactivex.rxjava3.functions.Function, io.reactivex.rxjava3.parallel.ParallelFlowable
Flattens the generated Streams on each rail.
Since
3.0.0

Field Summary

Modifier and TypeField and Description
pack-priv final Function<? super T, ? extends Stream<? extends R>>
mapper

pack-priv final int
prefetch

pack-priv final ParallelFlowable<T>
source

Constructor Summary

AccessConstructor and Description
public
ParallelFlatMapStream(ParallelFlowable<T> source, Function<? super T, ? extends Stream<? extends R>> mapper, 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

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

Constructor Detail

ParallelFlatMapStreamback to summary
public ParallelFlatMapStream(ParallelFlowable<T> source, Function<? super T, ? extends Stream<? extends R>> mapper, 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