reactor-core / reactor.core.publisher / org.reactivestreams.Publisher / toFlux

toFlux

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

Extension to convert any Publisher of T to a Flux.

Note this extension doesn't make much sense on a Flux but it won't be converted so it doesn't hurt.

Author
Simon Baslé

Since
3.1.1