reactor-kotlin-extensions/reactor.kotlin.adapter.rxjava/toObservable

toObservable

fun <T> Flux<T>.toObservable(): Observable<T>
Content copied to clipboard

Wraps a Flux instance into a RxJava Observable.

Return

the new Observable instance

Parameters

the value type