Class 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 Detail

      • 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 Detail

      • ParallelFlatMap

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

      • 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:
        ParallelFlowable.parallelism()