final < R > ParallelFlux < R > concatMapDelayError ( Function < ? super T , ? extends Publisher < ? extends R > > mapper , boolean delayUntilEnd , int prefetch ) { return concatMap ( mapper , prefetch , delayUntilEnd ? ErrorMode . END : ErrorMode . BOUNDARY ) ; }
Generates and concatenates Publishers on each rail delaying errors and using the given prefetch amount for generating Publishers upfront .