fun <T> Observable<T>.toFlux(strategy: BackpressureStrategy = BackpressureStrategy.BUFFER): Flux<T>
Wraps an RxJava Observable and applies the given backpressure strategy.
strategy
- the back-pressure strategy, default is BUFFER
Parameters
Return
the new Flux instance