Concatenate the single values, in a non-overlapping fashion, of the MaybeSource sources provided by an Iterable sequence as a Flowable sequence.
(@NonNull Iterable<@NonNull ? extends MaybeSource<? extends T>> sources)
| 184 | * @throws NullPointerException if {@code sources} is {@code null} |
| 185 | */ |
| 186 | @BackpressureSupport(BackpressureKind.FULL) |
| 187 | @CheckReturnValue |
| 188 | @NonNull |
| 189 | @SchedulerSupport(SchedulerSupport.NONE) |
| 190 | public static <@NonNull T> Flowable<T> concat(@NonNull Iterable<@NonNull ? extends MaybeSource<? extends T>> sources) { |
| 191 | Objects.requireNonNull(sources, "sources is null"); |
| 192 | return RxJavaPlugins.onAssembly(new MaybeConcatIterable<>(sources)); |
| 193 | } |
| 194 | |
| 195 | /** |
| 196 | * Returns a {@link Flowable} that emits the items emitted by two {@link MaybeSource}s, one after the other. |