reactor-kotlin-extensions / reactor.kotlin.adapter.rxjava / reactor.core.publisher.Flux

Extensions for reactor.core.publisher.Flux

toFlowable

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

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

toObservable

Wraps a Flux instance into a RxJava Observable.

fun <T> Flux<T>.toObservable(): Observable<T>