Returns a new Flowable that emits items resulting from applying a function that you supply to each item emitted by the current Flowable, where that function returns a Publisher, and then emitting the items that result from concatenating those returned Publishers.
(@NonNull Function<? super T, @NonNull ? extends Publisher<? extends R>> mapper)
| 7645 | * @see <a href="http://reactivex.io/documentation/operators/flatmap.html">ReactiveX operators documentation: FlatMap</a> |
| 7646 | */ |
| 7647 | @CheckReturnValue |
| 7648 | @BackpressureSupport(BackpressureKind.FULL) |
| 7649 | @SchedulerSupport(SchedulerSupport.NONE) |
| 7650 | @NonNull |
| 7651 | public final <@NonNull R> Flowable<R> concatMap(@NonNull Function<? super T, @NonNull ? extends Publisher<? extends R>> mapper) { |
| 7652 | return concatMap(mapper, 2); |
| 7653 | } |
| 7654 | |
| 7655 | /** |
| 7656 | * Returns a new {@code Flowable} that emits items resulting from applying a function that you supply to each item |
no test coverage detected