reactor-kotlin-extensions / reactor.kotlin.adapter.rxjava / io.reactivex.Observable / toFlux

toFlux

fun <T> Observable<T>.toFlux(strategy: BackpressureStrategy = BackpressureStrategy.BUFFER): Flux<T>

Wraps an RxJava Observable and applies the given backpressure strategy.

Parameters

strategy - the back-pressure strategy, default is BUFFER

Parameters

Return
the new Flux instance