to Flux
Wraps a Flowable instance into a Flux instance, composing the micro-fusion properties of the Flowable through.
Return
the new Flux instance
Parameters
fun <T> Observable<T>.toFlux(strategy: BackpressureStrategy = BackpressureStrategy.BUFFER): Flux<T>
Content copied to clipboard
Wraps an RxJava Observable and applies the given backpressure strategy.
Return
the new Flux instance
Parameters
strategy
the back-pressure strategy, default is BUFFER