reactor-core / reactor.core.publisher / kotlin.collections.Iterable

Extensions for kotlin.collections.Iterable


fun <T> Iterable<T>.toFlux(): Flux<T>

Extension for transforming an Iterable to a Flux.


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 when, which is a keyword in Kotlin.


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.