public final < R > ParallelFlux < R > concatMap ( Function < ? super T , ? extends Publisher < ? extends R > > mapper ) { return concatMap ( mapper , 2 , ErrorMode . IMMEDIATE ) ; }
Generates and concatenates Publishers on each rail signalling errors immediately and generating 2 publishers upfront .