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

toObservable

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

Wraps a Flux instance into a RxJava Observable.

Parameters

Return
the new Observable instance