Concatenate the single values, in a non-overlapping fashion, of the SingleSources provided by an Iterable sequence. Backpressure: </
(@NonNull Iterable<@NonNull ? extends SingleSource<? extends T>> sources)
| 190 | * @since 2.0 |
| 191 | */ |
| 192 | @CheckReturnValue |
| 193 | @NonNull |
| 194 | @SchedulerSupport(SchedulerSupport.NONE) |
| 195 | @BackpressureSupport(BackpressureKind.FULL) |
| 196 | public static <@NonNull T> Flowable<T> concat(@NonNull Iterable<@NonNull ? extends SingleSource<? extends T>> sources) { |
| 197 | return Flowable.fromIterable(sources).concatMapSingleDelayError(Functions.identity(), false); |
| 198 | } |
| 199 | |
| 200 | /** |
| 201 | * Concatenate the single values, in a non-overlapping fashion, of the {@link SingleSource}s provided by |