apply

fun <T : Any, R : Any> apply(source: Flux<T>, mapper: (T) -> Publisher<out R>): Flux<R>