reactor-kotlin-extensions/reactor.kotlin.adapter.rxjava/toFlux

toFlux

fun <T> Flowable<T>.toFlux(): Flux<T>
Content copied to clipboard

Wraps a Flowable instance into a Flux instance, composing the micro-fusion properties of the Flowable through.

Return

the new Flux instance

Parameters

the value type

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

the value type
strategy

the back-pressure strategy, default is BUFFER