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

Extensions for io.reactivex.Observable

toFlux

Wraps an RxJava Observable and applies the given backpressure strategy.

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