reactor-kotlin-extensions / reactor.kotlin.adapter.rxjava / io.reactivex.Flowable / toFlux

toFlux

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

Wraps a Flowable instance into a Flux instance, composing the micro-fusion properties of the Flowable through.

Parameters

Return
the new Flux instance