fun <T> Flux<T>.toObservable(): Observable<T>
Wraps a Flux instance into a RxJava Observable.
Parameters
Return the new Observable instance