Package reactor. kotlin. adapter. rxjava
Functions
to Completable
Link copied to clipboard
Wraps a void-Mono instance into a RxJava Completable.
to Flowable
Link copied to clipboard
Wraps a Flux instance into a Flowable instance, composing the micro-fusion properties of the Flux through.
to Flux
Link copied to clipboard
Wraps a Flowable instance into a Flux instance, composing the micro-fusion properties of the Flowable through.
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.
to Mono
Link copied to clipboard
Wraps a RxJava Completable into a Mono instance.
Wraps an RxJava Maybe into a Mono instance.
to Observable
Link copied to clipboard
Wraps a Flux instance into a RxJava Observable.