Package reactor.kotlin.adapter.rxjava

Functions

Link copied to clipboard
fun Mono<*>.toCompletable(): Completable

Wraps a void-Mono instance into a RxJava Completable.

Link copied to clipboard
fun <T> Flux<T>.toFlowable(): Flowable<T>

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

fun <T> Mono<T>.toFlowable(): Flowable<T>

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

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

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>

Wraps an RxJava Observable and applies the given backpressure strategy.

Link copied to clipboard
fun <T> Mono<T>.toMaybe(): Maybe<T>

WRaps Mono instance into an RxJava Maybe.

Link copied to clipboard
fun Completable.toMono(): Mono<Void>

Wraps a RxJava Completable into a Mono instance.

fun <T> Maybe<T>.toMono(): Mono<T>

Wraps an RxJava Maybe into a Mono instance.

fun <T> Single<T>.toMono(): Mono<T>

Wraps a RxJava Single into a Mono instance.

Link copied to clipboard
fun <T> Flux<T>.toObservable(): Observable<T>

Wraps a Flux instance into a RxJava Observable.

Link copied to clipboard
fun <T> Mono<T>.toSingle(): Single<T>

Wraps a Mono instance into a RxJava Single.