Class ParallelFlatMap<T,R>

java.lang.Object
io.reactivex.rxjava3.parallel.ParallelFlowable<R>
io.reactivex.rxjava3.internal.operators.parallel.ParallelFlatMap<T,R>
Type Parameters:
T - the input value type
R - the output value type

public final class ParallelFlatMap<T,R> extends ParallelFlowable<R>
Flattens the generated Publishers on each rail.
  • Field Details

    • source

      final ParallelFlowable<T> source
    • mapper

      final Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper
    • delayError

      final boolean delayError
    • maxConcurrency

      final int maxConcurrency
    • prefetch

      final int prefetch
  • Constructor Details

    • ParallelFlatMap

      public ParallelFlatMap(ParallelFlowable<T> source, Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper, boolean delayError, int maxConcurrency, int prefetch)
  • Method Details

    • parallelism

      public int parallelism()
      Description copied from class: ParallelFlowable
      Returns the number of expected parallel Subscribers.
      Specified by:
      parallelism in class ParallelFlowable<R>
      Returns:
      the number of expected parallel Subscribers
    • subscribe

      public void subscribe(org.reactivestreams.Subscriber<? super R>[] subscribers)
      Description copied from class: ParallelFlowable
      Subscribes an array of Subscribers to this ParallelFlowable and triggers the execution chain for all 'rails'.
      Backpressure:
      The backpressure behavior/expectation is determined by the supplied Subscriber.
      Scheduler:
      subscribe does not operate by default on a particular Scheduler.
      Specified by:
      subscribe in class ParallelFlowable<R>
      Parameters:
      subscribers - the subscribers array to run in parallel, the number of items must be equal to the parallelism level of this ParallelFlowable
      See Also: