-
Methods Method Description reactor.kotlin.adapter.rxjava.toFlux(Flowable) Wraps a Flowable instance into a Flux instance, composing the micro-fusion properties of the Flowable through. reactor.kotlin.adapter.rxjava.toFlux(Observable,BackpressureStrategy) Wraps an RxJava Observable and applies the given backpressure strategy. reactor.kotlin.adapter.rxjava.toFlowable(Flux) Wraps a Flux instance into a Flowable instance, composing the micro-fusion properties of the Flux through. reactor.kotlin.adapter.rxjava.toFlowable(Mono) Wraps a Mono instance into a Flowable instance, composing the micro-fusion properties of the Flux through. reactor.kotlin.adapter.rxjava.toCompletable(Mono) Wraps a void-Mono instance into a RxJava Completable. reactor.kotlin.adapter.rxjava.toMono(Completable) Wraps a RxJava Completable into a Mono instance. reactor.kotlin.adapter.rxjava.toMono(Single) Wraps a RxJava Single into a Mono instance. reactor.kotlin.adapter.rxjava.toMono(Maybe) Wraps an RxJava Maybe into a Mono instance. reactor.kotlin.adapter.rxjava.toSingle(Mono) Wraps a Mono instance into a RxJava Single. reactor.kotlin.adapter.rxjava.toObservable(Flux) Wraps a Flux instance into a RxJava Observable. reactor.kotlin.adapter.rxjava.toMaybe(Mono) WRaps Mono instance into an RxJava Maybe. reactor.kotlin.extra.math.sum(Flux) Extension to compute the Long sum of all values emitted by a Flux of Number and return it as a Mono of Long. reactor.kotlin.extra.math.sum(Flux,Function1) Extension to map arbitrary values in a Flux to Numbers and return the sum of these Numbers as a Mono of Long. reactor.kotlin.extra.math.sumDouble(Flux) Extension to compute the Double sum of all values emitted by a Flux of Number and return it as a Mono of Double. reactor.kotlin.extra.math.sumDouble(Flux,Function1) Extension to map arbitrary values in a Flux to Numbers and return the sum of these Numbers as a Mono of Double, thus avoiding rounding down to zero decimal places. reactor.kotlin.extra.math.average(Flux) Extension to compute the Double average of all values emitted by a Flux of Number and return it as a Mono of Double. reactor.kotlin.extra.math.average(Flux,Function1) Extension to map arbitrary values in a Flux to Numbers and return the average of these Numbers as a Mono of Double. reactor.kotlin.extra.retry.repeatExponentialBackoff(Flux,Long,Duration,Duration,Boolean,Function1) Extension to add a Flux.repeat variant to Flux that uses an exponential backoff, as enabled by reactor-extra's Repeat builder. reactor.kotlin.extra.retry.repeatExponentialBackoff(Mono,Long,Duration,Duration,Boolean,Function1) Extension to add a Mono.repeat variant to Mono that uses an exponential backoff, as enabled by reactor-extra's Repeat builder. reactor.kotlin.extra.retry.repeatRandomBackoff(Flux,Long,Duration,Duration,Function1) Extension to add a Flux.repeat variant to Flux that uses a randomized backoff, as enabled by reactor-extra's Repeat builder. reactor.kotlin.extra.retry.repeatRandomBackoff(Mono,Long,Duration,Duration,Function1) Extension to add a Mono.repeat variant to Mono that uses a randomized backoff, as enabled by reactor-extra's Repeat builder. reactor.kotlin.extra.retry.retryExponentialBackoff(Flux,Long,Duration,Duration,Boolean,Function1) Extension to add a Flux.retry variant to Flux that uses an exponential backoff, as enabled by reactor-extra's Retry builder. reactor.kotlin.extra.retry.retryExponentialBackoff(Mono,Long,Duration,Duration,Boolean,Function1) Extension to add a Mono.retry variant to Mono that uses an exponential backoff, as enabled by reactor-extra's Retry builder. reactor.kotlin.extra.retry.retryRandomBackoff(Flux,Long,Duration,Duration,Function1) Extension to add a Flux.retry variant to Flux that uses a random backoff, as enabled by reactor-extra's Retry builder. reactor.kotlin.extra.retry.retryRandomBackoff(Mono,Long,Duration,Duration,Function1) Extension to add a Mono.retry variant to Mono that uses a random backoff, as enabled by reactor-extra's Retry builder.