MCPcopy Index your code
hub / github.com/ReactiveX/RxJava / concatMap

Method concatMap

src/main/java/io/reactivex/rxjava3/core/Flowable.java:7647–7653  ·  view source on GitHub ↗

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)

Source from the content-addressed store, hash-verified

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

Callers 1

concatMethod · 0.45

Calls 5

verifyPositiveMethod · 0.95
emptyMethod · 0.95
scalarXMapMethod · 0.95
onAssemblyMethod · 0.95
getMethod · 0.65

Tested by

no test coverage detected