reactor-kotlin-extensions / reactor.kotlin.core.publisher / org.reactivestreams.Publisher

Extensions for org.reactivestreams.Publisher

toFlux

Extension to convert any Publisher of T to a Flux.

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

toMono

Extension to convert any Publisher of T to a Mono that only emits its first element.

fun <T> Publisher<T>.toMono(): Mono<T>