final < R > ParallelFlux < R > concatMap ( Function < ? super T , ? extends Publisher < ? extends R > > mapper , int prefetch , ErrorMode errorMode ) { return onAssembly ( new ParallelConcatMap <> ( this , mapper , Queues . get ( prefetch ) , prefetch , errorMode ) ) ; }
Generates and concatenates Publishers on each rail optionally delaying errors and using the given prefetch amount for generating Publishers upfront .