public final < R > ParallelFlux < R > flatMap ( Function < ? super T , ? extends Publisher < ? extends R > > mapper , boolean delayError , int maxConcurrency , int prefetch ) { return onAssembly ( new ParallelFlatMap <> ( this , mapper , delayError , maxConcurrency , Queues . get ( maxConcurrency ) , prefetch , Queues . get ( prefetch ) ) ) ; }
Generates and flattens Publishers on each rail optionally delaying errors having a total number of simultaneous subscriptions to the inner Publishers and using the given prefetch amount for the inner Publishers .