Package reactor.kotlin.adapter.rxjava

Functions

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

Wraps a void-Mono instance into a RxJava Completable.

toFlowable
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.

toFlux
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.

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

WRaps Mono instance into an RxJava Maybe.

toMono
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.

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

Wraps a Flux instance into a RxJava Observable.

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

Wraps a Mono instance into a RxJava Single.