@ SuppressWarnings ( { "unchecked" , "rawtypes" } ) @ CheckReturnValue @ BackpressureSupport ( BackpressureKind . FULL ) @ SchedulerSupport ( SchedulerSupport . NONE ) public static < T > Flowable < T > concatDelayError ( Iterable < ? extends Publisher < ? extends T > > sources ) { ObjectHelper . requireNonNull ( sources , "sources is null" ) ; return fromIterable ( sources ) . concatMapDelayError ( ( Function ) Functions . identity ( ) ) ; }
Concatenates the Iterable sequence of Publishers into a single sequence by subscribing to each Publisher one after the other one at a time and delays any errors till the all inner Publishers terminate .