reactor-kotlin-extensions / reactor.kotlin.core.publisher

Package reactor.kotlin.core.publisher

Extensions for External Classes

java.util.concurrent.Callable

java.util.concurrent.CompletableFuture

java.util.stream.Stream

kotlin.Array

kotlin.BooleanArray

kotlin.ByteArray

kotlin.collections.Iterable

kotlin.collections.Iterator

kotlin.DoubleArray

kotlin.FloatArray

kotlin.Function0

kotlin.IntArray

kotlin.LongArray

kotlin.sequences.Sequence

kotlin.ShortArray

kotlin.Throwable

org.reactivestreams.Publisher

reactor.core.publisher.Flux

reactor.core.publisher.Mono

Functions

toMono

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

Extension for transforming an object to a Mono.

whenComplete

fun whenComplete(vararg sources: Publisher<*>): Mono<Void>

Aggregates the given void Publishers into a new void Mono. An alias for a corresponding Mono.when to avoid use of when, which is a keyword in Kotlin.

zip

fun <R> zip(vararg monos: Mono<*>, combinator: (Array<*>) -> R): Mono<R>

Aggregates the given Monos into a new Mono.