fun <T> Iterable<T>.toFlux(): Flux<T>
|
|
fun Iterable<Publisher<Void>>.whenComplete(): Mono<Void>
Aggregates this Iterable of void Publishers into a new Mono.
An alias for a corresponding Mono.when to avoid use of |
|
fun <T, R> Iterable<Mono<T>>.zip(combinator: (List<T>) -> R): Mono<R>
Merges this Iterable of Monos into a new Mono by combining them with combinator. |