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

Extensions for kotlin.collections.Iterable

toFlux

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

Extension for transforming an Iterable to a Flux.

whenComplete

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.

zip

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.